Holy crap, it actually works!

This commit is contained in:
Viktor Klang 2010-08-13 21:03:15 +02:00
parent d2a5053ada
commit 01af2c4868
18 changed files with 313 additions and 863 deletions

View file

@ -22,7 +22,7 @@ import scala.reflect.BeanProperty
import CamelMessageConversion.toExchangeAdapter
import java.lang.Throwable
import se.scalablesolutions.akka.actor.{ActorRegistry, Actor, ActorRef}
import se.scalablesolutions.akka.actor.{ScalaActorRef, ActorRegistry, Actor, ActorRef}
/**
* Camel component for sending messages to and receiving replies from actors.
@ -197,7 +197,7 @@ private[akka] object AsyncCallbackAdapter {
*
* @author Martin Krasser
*/
private[akka] class AsyncCallbackAdapter(exchange: Exchange, callback: AsyncCallback) extends ActorRef {
private[akka] class AsyncCallbackAdapter(exchange: Exchange, callback: AsyncCallback) extends ActorRef with ScalaActorRef {
def start = {
_isRunning = true