diff --git a/akka-actor-tests/src/test/scala/akka/routing/ActorPoolSpec.scala b/akka-actor-tests/src/test/scala/akka/routing/ActorPoolSpec.scala index 01fd35ba42..702f167b40 100644 --- a/akka-actor-tests/src/test/scala/akka/routing/ActorPoolSpec.scala +++ b/akka-actor-tests/src/test/scala/akka/routing/ActorPoolSpec.scala @@ -347,7 +347,7 @@ class ActorPoolSpec extends AkkaSpec { val pool = app.createProxy[Foo](createPool, Props().withFaultHandler(faultHandler)) - val results = for (i ← 1 to 100) yield (i, pool.sq(i, 100)) + val results = for (i ← 1 to 50) yield (i, pool.sq(i, 100)) for ((i, r) ← results) r.get must equal(i * i) } diff --git a/akka-actor/src/main/java/akka/dispatch/AbstractPromise.java b/akka-actor/src/main/java/akka/dispatch/AbstractPromise.java index 98451da1f4..a770a0b27a 100644 --- a/akka-actor/src/main/java/akka/dispatch/AbstractPromise.java +++ b/akka-actor/src/main/java/akka/dispatch/AbstractPromise.java @@ -7,7 +7,7 @@ package akka.dispatch; import java.util.concurrent.atomic.AtomicReferenceFieldUpdater; abstract class AbstractPromise { - private volatile Object _ref = FState.apply(); + private volatile Object _ref = DefaultPromise.EmptyPending(); protected final static AtomicReferenceFieldUpdater updater = AtomicReferenceFieldUpdater.newUpdater(AbstractPromise.class, Object.class, "_ref"); } diff --git a/akka-actor/src/main/scala/akka/actor/ActorRefProvider.scala b/akka-actor/src/main/scala/akka/actor/ActorRefProvider.scala index f05fbbe86a..8881d459ed 100644 --- a/akka-actor/src/main/scala/akka/actor/ActorRefProvider.scala +++ b/akka-actor/src/main/scala/akka/actor/ActorRefProvider.scala @@ -101,8 +101,6 @@ class LocalActorRefProvider(val app: AkkaApplication) extends ActorRefProvider { @volatile var stopped = false - def app = LocalActorRefProvider.this.app - override def address = app.name + ":BubbleWalker" override def toString = address diff --git a/akka-actor/src/main/scala/akka/dispatch/Future.scala b/akka-actor/src/main/scala/akka/dispatch/Future.scala index 6453403ce7..8984c4f085 100644 --- a/akka-actor/src/main/scala/akka/dispatch/Future.scala +++ b/akka-actor/src/main/scala/akka/dispatch/Future.scala @@ -824,8 +824,8 @@ trait Promise[T] extends Future[T] { } //Companion object to FState, just to provide a cheap, immutable default entry -private[akka] object FState { - def apply[T](): FState[T] = EmptyPending.asInstanceOf[FState[T]] +private[dispatch] object DefaultPromise { + def EmptyPending[T](): FState[T] = EmptyPending.asInstanceOf[FState[T]] /** * Represents the internal state of the DefaultCompletableFuture @@ -853,7 +853,7 @@ private[akka] object FState { class DefaultPromise[T](val timeout: Timeout)(implicit val dispatcher: MessageDispatcher) extends AbstractPromise with Promise[T] { self ⇒ - import FState.{ FState, Success, Failure, Pending, Expired } + import DefaultPromise.{ FState, Success, Failure, Pending, Expired } def this()(implicit dispatcher: MessageDispatcher, timeout: Timeout) = this(timeout) diff --git a/akka-remote/src/main/scala/akka/remote/RemoteActorRefProvider.scala b/akka-remote/src/main/scala/akka/remote/RemoteActorRefProvider.scala index dedf5a4044..8a34e8b118 100644 --- a/akka-remote/src/main/scala/akka/remote/RemoteActorRefProvider.scala +++ b/akka-remote/src/main/scala/akka/remote/RemoteActorRefProvider.scala @@ -264,7 +264,7 @@ private[akka] case class RemoteActorRef private[akka] ( } @throws(classOf[java.io.ObjectStreamException]) - private def writeReplace(): AnyRef = app.provider.serialize(this) + private def writeReplace(): AnyRef = remote.app.provider.serialize(this) def startsMonitoring(actorRef: ActorRef): ActorRef = unsupported diff --git a/akka-testkit/src/test/scala/akka/testkit/TestActorRefSpec.scala b/akka-testkit/src/test/scala/akka/testkit/TestActorRefSpec.scala index c5a989c17e..b994d6a956 100644 --- a/akka-testkit/src/test/scala/akka/testkit/TestActorRefSpec.scala +++ b/akka-testkit/src/test/scala/akka/testkit/TestActorRefSpec.scala @@ -224,10 +224,7 @@ class TestActorRefSpec extends AkkaSpec with BeforeAndAfterEach { "proxy apply for the underlying actor" in { val ref = TestActorRef[WorkerActor] ref("work") - val ch = Promise[String](5000) - ref ! ch - ch must be('completed) - ch.get must be("complexReply") + ref.isShutdown must be(true) } }