raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Fixed issue with AMQP module

Browse source
This commit is contained in:
Jonas Bonér 2010-05-28 11:58:52 +02:00
parent 6d99341853
commit d04f69a31c
2 changed files with 1 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-amqp/src/main/scala/AMQP.scala
View file

@ -93,7 +93,7 @@ object AMQP {
import scala.collection.JavaConversions._
private val supervisor = actorOf[AMQPSupervisorActor].start
private val supervisor = actorOf(new AMQPSupervisorActor).start
private val connections = new ConcurrentHashMap[ActorRef, ActorRef]
def newProducer(

10
akka-core/src/main/scala/actor/ActorRef.scala
View file

@ -206,16 +206,6 @@ trait ActorRef extends TransactionManagement {
*/
protected[akka] val dispatcherLock = new ReentrantLock
/**
* Holds the reference to the sender of the currently processed message.
* - Is None if no sender was specified
* - Is Some(Left(Actor)) if sender is an actor
* - Is Some(Right(CompletableFuture)) if sender is holding on to a Future for the result
*/
// protected[this] var _replyTo: Option[Either[ActorRef, CompletableFuture[Any]]] = None
// protected[akka] def replyTo: Option[Either[ActorRef, CompletableFuture[Any]]] = guard.withGuard { _replyTo }
// protected[akka] def replyTo_=(rt: Option[Either[ActorRef, CompletableFuture[Any]]]) = guard.withGuard { _replyTo = rt }
protected[akka] var _sender: Option[ActorRef] = None
protected[akka] var _senderFuture: Option[CompletableFuture[Any]] = None
protected[akka] def sender_=(s: Option[ActorRef]) = guard.withGuard { _sender = s}