diff --git a/akka-actor-tests/src/test/scala/akka/actor/ActorLifeCycleSpec.scala b/akka-actor-tests/src/test/scala/akka/actor/ActorLifeCycleSpec.scala index 14fbd13756..ba49a4f24b 100644 --- a/akka-actor-tests/src/test/scala/akka/actor/ActorLifeCycleSpec.scala +++ b/akka-actor-tests/src/test/scala/akka/actor/ActorLifeCycleSpec.scala @@ -131,7 +131,7 @@ class ActorLifeCycleSpec extends AkkaSpec("akka.actor.serialize-messages=off") w case class Become(recv: ActorContext ⇒ Receive) val a = system.actorOf(Props(new Actor { def receive = { - case Become(beh) ⇒ context.become(beh(context), discardOld = false); sender ! "ok" + case Become(beh) ⇒ { context.become(beh(context), discardOld = false); sender ! "ok" } case x ⇒ sender ! 42 } })) diff --git a/akka-actor-tests/src/test/scala/akka/actor/FSMTimingSpec.scala b/akka-actor-tests/src/test/scala/akka/actor/FSMTimingSpec.scala index 7260249e44..f4a7c3a72c 100644 --- a/akka-actor-tests/src/test/scala/akka/actor/FSMTimingSpec.scala +++ b/akka-actor-tests/src/test/scala/akka/actor/FSMTimingSpec.scala @@ -201,8 +201,13 @@ object FSMTimingSpec { case Initial -> TestSingleTimerResubmit ⇒ setTimer("blah", Tick, 500.millis.dilated, false) } when(TestSingleTimerResubmit) { - case Event(Tick, _) ⇒ tester ! Tick; setTimer("blah", Tock, 500.millis.dilated, false); stay() - case Event(Tock, _) ⇒ tester ! Tock; goto(Initial) + case Event(Tick, _) ⇒ + tester ! Tick + setTimer("blah", Tock, 500.millis.dilated, false) + stay() + case Event(Tock, _) ⇒ + tester ! Tock + goto(Initial) } when(TestCancelTimer) { case Event(Tick, _) ⇒ diff --git a/akka-actor-tests/src/test/scala/akka/actor/dispatch/DispatcherActorSpec.scala b/akka-actor-tests/src/test/scala/akka/actor/dispatch/DispatcherActorSpec.scala index db3574a29d..2a10adf26e 100644 --- a/akka-actor-tests/src/test/scala/akka/actor/dispatch/DispatcherActorSpec.scala +++ b/akka-actor-tests/src/test/scala/akka/actor/dispatch/DispatcherActorSpec.scala @@ -86,7 +86,7 @@ class DispatcherActorSpec extends AkkaSpec(DispatcherActorSpec.config) with Defa val slowOne = system.actorOf( Props(new Actor { def receive = { - case "hogexecutor" ⇒ sender ! "OK"; start.await + case "hogexecutor" ⇒ { sender ! "OK"; start.await } case "ping" ⇒ if (works.get) latch.countDown() } }).withDispatcher(throughputDispatcher)) @@ -120,8 +120,8 @@ class DispatcherActorSpec extends AkkaSpec(DispatcherActorSpec.config) with Defa val slowOne = system.actorOf( Props(new Actor { def receive = { - case "hogexecutor" ⇒ ready.countDown(); start.await - case "ping" ⇒ works.set(false); context.stop(self) + case "hogexecutor" ⇒ { ready.countDown(); start.await } + case "ping" ⇒ { works.set(false); context.stop(self) } } }).withDispatcher(throughputDispatcher)) diff --git a/akka-actor-tests/src/test/scala/akka/event/EventStreamSpec.scala b/akka-actor-tests/src/test/scala/akka/event/EventStreamSpec.scala index 23fb529cb9..e0257b89d2 100644 --- a/akka-actor-tests/src/test/scala/akka/event/EventStreamSpec.scala +++ b/akka-actor-tests/src/test/scala/akka/event/EventStreamSpec.scala @@ -44,7 +44,7 @@ object EventStreamSpec { bus.subscribe(context.self, classOf[SetTarget]) bus.subscribe(context.self, classOf[UnhandledMessage]) sender ! Logging.LoggerInitialized - case SetTarget(ref) ⇒ dst = ref; dst ! "OK" + case SetTarget(ref) ⇒ { dst = ref; dst ! "OK" } case e: Logging.LogEvent ⇒ dst ! e case u: UnhandledMessage ⇒ dst ! u } diff --git a/akka-actor/src/main/scala/akka/actor/dungeon/FaultHandling.scala b/akka-actor/src/main/scala/akka/actor/dungeon/FaultHandling.scala index 324559df6b..159a371eed 100644 --- a/akka-actor/src/main/scala/akka/actor/dungeon/FaultHandling.scala +++ b/akka-actor/src/main/scala/akka/actor/dungeon/FaultHandling.scala @@ -170,8 +170,8 @@ private[akka] trait FaultHandling { this: ActorCell ⇒ suspendNonRecursive() // suspend children val skip: Set[ActorRef] = currentMessage match { - case Envelope(Failed(_, _, _), child) ⇒ setFailed(child); Set(child) - case _ ⇒ setFailed(self); Set.empty + case Envelope(Failed(_, _, _), child) ⇒ { setFailed(child); Set(child) } + case _ ⇒ { setFailed(self); Set.empty } } suspendChildren(exceptFor = skip ++ childrenNotToSuspend) t match { diff --git a/akka-actor/src/main/scala/akka/io/SslTlsSupport.scala b/akka-actor/src/main/scala/akka/io/SslTlsSupport.scala index c6b63b4a91..fa3f2c56e8 100644 --- a/akka-actor/src/main/scala/akka/io/SslTlsSupport.scala +++ b/akka-actor/src/main/scala/akka/io/SslTlsSupport.scala @@ -94,7 +94,7 @@ class SslTlsSupport(engine: SSLEngine) extends PipelineStage[HasLogging, Command // to shutdown the connection when getting CLOSED in encrypt closeEngine() - case x: Tcp.WriteCommand => + case x: Tcp.WriteCommand ⇒ throw new IllegalArgumentException( "SslTlsSupport doesn't support Tcp.WriteCommands of type " + x.getClass.getSimpleName) diff --git a/akka-actor/src/main/scala/akka/io/Tcp.scala b/akka-actor/src/main/scala/akka/io/Tcp.scala index 9076155e55..54490c4843 100644 --- a/akka-actor/src/main/scala/akka/io/Tcp.scala +++ b/akka-actor/src/main/scala/akka/io/Tcp.scala @@ -370,8 +370,8 @@ object Tcp extends ExtensionId[TcpExt] with ExtensionIdProvider { def next(): SimpleWriteCommand = current match { case null ⇒ Iterator.empty.next() - case CompoundWrite(h, t) ⇒ current = t; h - case x: SimpleWriteCommand ⇒ current = null; x + case CompoundWrite(h, t) ⇒ { current = t; h } + case x: SimpleWriteCommand ⇒ { current = null; x } } } } diff --git a/akka-actor/src/main/scala/akka/io/TcpManager.scala b/akka-actor/src/main/scala/akka/io/TcpManager.scala index 237011c8f3..50963081a6 100644 --- a/akka-actor/src/main/scala/akka/io/TcpManager.scala +++ b/akka-actor/src/main/scala/akka/io/TcpManager.scala @@ -50,11 +50,11 @@ private[io] class TcpManager(tcp: TcpExt) def receive = workerForCommandHandler { case c: Connect ⇒ val commander = sender // cache because we create a function that will run asyncly - registry ⇒ Props(classOf[TcpOutgoingConnection], tcp, registry, commander, c) + (registry ⇒ Props(classOf[TcpOutgoingConnection], tcp, registry, commander, c)) case b: Bind ⇒ val commander = sender // cache because we create a function that will run asyncly - registry ⇒ Props(classOf[TcpListener], selectorPool, tcp, registry, commander, b) + (registry ⇒ Props(classOf[TcpListener], selectorPool, tcp, registry, commander, b)) } } diff --git a/akka-actor/src/main/scala/akka/io/UdpManager.scala b/akka-actor/src/main/scala/akka/io/UdpManager.scala index b7e91d6ab6..140e0dac4c 100644 --- a/akka-actor/src/main/scala/akka/io/UdpManager.scala +++ b/akka-actor/src/main/scala/akka/io/UdpManager.scala @@ -48,11 +48,11 @@ private[io] class UdpManager(udp: UdpExt) extends SelectionHandler.SelectorBased def receive = workerForCommandHandler { case b: Bind ⇒ val commander = sender // cache because we create a function that will run asyncly - registry ⇒ Props(classOf[UdpListener], udp, registry, commander, b) + (registry ⇒ Props(classOf[UdpListener], udp, registry, commander, b)) case SimpleSender(options) ⇒ val commander = sender // cache because we create a function that will run asyncly - registry ⇒ Props(classOf[UdpSender], udp, registry, commander, options) + (registry ⇒ Props(classOf[UdpSender], udp, registry, commander, options)) } } diff --git a/akka-dataflow/src/test/scala/akka/dataflow/DataflowSpec.scala b/akka-dataflow/src/test/scala/akka/dataflow/DataflowSpec.scala index 5298ae5f2c..f1546d3b52 100644 --- a/akka-dataflow/src/test/scala/akka/dataflow/DataflowSpec.scala +++ b/akka-dataflow/src/test/scala/akka/dataflow/DataflowSpec.scala @@ -27,8 +27,11 @@ object DataflowSpec { class TestDelayActor(await: TestLatch) extends Actor { def receive = { - case "Hello" ⇒ Await.ready(await, TestLatch.DefaultTimeout); sender ! "World" - case "NoReply" ⇒ Await.ready(await, TestLatch.DefaultTimeout) + case "Hello" ⇒ + Await.ready(await, TestLatch.DefaultTimeout) + sender ! "World" + case "NoReply" ⇒ + Await.ready(await, TestLatch.DefaultTimeout) case "Failure" ⇒ Await.ready(await, TestLatch.DefaultTimeout) sender ! Status.Failure(new RuntimeException("Expected exception; to test fault-tolerance")) diff --git a/akka-persistence/src/main/scala/akka/persistence/Channel.scala b/akka-persistence/src/main/scala/akka/persistence/Channel.scala index 4d903d4272..68de29cce8 100644 --- a/akka-persistence/src/main/scala/akka/persistence/Channel.scala +++ b/akka-persistence/src/main/scala/akka/persistence/Channel.scala @@ -90,7 +90,7 @@ class Channel private (_channelId: Option[String]) extends Actor with Stash { } private val buffering: Actor.Receive = { - case DeliveredResolved | DeliveredUnresolved ⇒ context.unbecome(); unstashAll() // TODO: optimize + case DeliveredResolved | DeliveredUnresolved ⇒ { context.unbecome(); unstashAll() } // TODO: optimize case _: Deliver ⇒ stash() } @@ -232,9 +232,9 @@ private trait ResolvedDelivery extends Actor { def receive = { case DeliverResolved ⇒ context.actorSelection(path) ! Identify(1) - case ActorIdentity(1, Some(ref)) ⇒ onResolveSuccess(ref); shutdown(DeliveredResolved) - case ActorIdentity(1, None) ⇒ onResolveFailure(); shutdown(DeliveredUnresolved) - case ReceiveTimeout ⇒ onResolveFailure(); shutdown(DeliveredUnresolved) + case ActorIdentity(1, Some(ref)) ⇒ { onResolveSuccess(ref); shutdown(DeliveredResolved) } + case ActorIdentity(1, None) ⇒ { onResolveFailure(); shutdown(DeliveredUnresolved) } + case ReceiveTimeout ⇒ { onResolveFailure(); shutdown(DeliveredUnresolved) } } def shutdown(message: Any) { diff --git a/akka-persistence/src/main/scala/akka/persistence/journal/inmem/InmemJournal.scala b/akka-persistence/src/main/scala/akka/persistence/journal/inmem/InmemJournal.scala index 11660b1db5..c6f28e56b8 100644 --- a/akka-persistence/src/main/scala/akka/persistence/journal/inmem/InmemJournal.scala +++ b/akka-persistence/src/main/scala/akka/persistence/journal/inmem/InmemJournal.scala @@ -50,10 +50,18 @@ private[persistence] class InmemStore extends Actor { var messages = Map.empty[String, Vector[PersistentImpl]] def receive = { - case Write(p) ⇒ add(p); success() - case WriteBatch(pb) ⇒ pb.foreach(add); success() - case Delete(p) ⇒ update(p.processorId, p.sequenceNr)(_.copy(deleted = true)); success() - case Confirm(pid, snr, cid) ⇒ update(pid, snr)(p ⇒ p.copy(confirms = cid +: p.confirms)); success() + case Write(p) ⇒ + add(p) + success() + case WriteBatch(pb) ⇒ + pb.foreach(add) + success() + case Delete(p) ⇒ + update(p.processorId, p.sequenceNr)(_.copy(deleted = true)) + success() + case Confirm(pid, snr, cid) ⇒ + update(pid, snr)(p ⇒ p.copy(confirms = cid +: p.confirms)) + success() case Replay(pid, fromSnr, toSnr, callback) ⇒ { for { ms ← messages.get(pid) diff --git a/akka-persistence/src/test/scala/akka/persistence/ProcessorStashSpec.scala b/akka-persistence/src/test/scala/akka/persistence/ProcessorStashSpec.scala index 08cf455c49..e9b9354db9 100644 --- a/akka-persistence/src/test/scala/akka/persistence/ProcessorStashSpec.scala +++ b/akka-persistence/src/test/scala/akka/persistence/ProcessorStashSpec.scala @@ -14,9 +14,9 @@ object ProcessorStashSpec { var state: List[String] = Nil val behaviorA: Actor.Receive = { - case Persistent("a", snr) ⇒ update("a", snr); context.become(behaviorB) + case Persistent("a", snr) ⇒ { update("a", snr); context.become(behaviorB) } case Persistent("b", snr) ⇒ update("b", snr) - case Persistent("c", snr) ⇒ update("c", snr); unstashAll() + case Persistent("c", snr) ⇒ { update("c", snr); unstashAll() } case "x" ⇒ update("x") case "boom" ⇒ throw new TestException("boom") case Persistent("boom", _) ⇒ throw new TestException("boom") @@ -24,7 +24,7 @@ object ProcessorStashSpec { } val behaviorB: Actor.Receive = { - case Persistent("b", _) ⇒ stash(); context.become(behaviorA) + case Persistent("b", _) ⇒ { stash(); context.become(behaviorA) } case "x" ⇒ stash() } diff --git a/akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteNodeShutdownAndComesBackSpec.scala b/akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteNodeShutdownAndComesBackSpec.scala index b675b4474e..e12782101d 100644 --- a/akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteNodeShutdownAndComesBackSpec.scala +++ b/akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteNodeShutdownAndComesBackSpec.scala @@ -8,7 +8,7 @@ import scala.concurrent.duration._ import com.typesafe.config.ConfigFactory import akka.actor._ import akka.remote.testconductor.RoleName -import akka.remote.transport.ThrottlerTransportAdapter.{ForceDisassociate, Direction} +import akka.remote.transport.ThrottlerTransportAdapter.{ ForceDisassociate, Direction } import akka.remote.testkit.MultiNodeConfig import akka.remote.testkit.MultiNodeSpec import akka.remote.testkit.STMultiNodeSpec @@ -35,8 +35,8 @@ object RemoteNodeShutdownAndComesBackSpec extends MultiNodeConfig { class Subject extends Actor { def receive = { - case "shutdown" => context.system.shutdown() - case msg ⇒ sender ! msg + case "shutdown" ⇒ context.system.shutdown() + case msg ⇒ sender ! msg } } @@ -47,7 +47,7 @@ class RemoteNodeShutdownAndComesBackMultiJvmNode2 extends RemoteNodeShutdownAndC abstract class RemoteNodeShutdownAndComesBackSpec extends MultiNodeSpec(RemoteNodeShutdownAndComesBackSpec) - with STMultiNodeSpec with ImplicitSender { + with STMultiNodeSpec with ImplicitSender { import RemoteNodeShutdownAndComesBackSpec._ @@ -137,7 +137,6 @@ abstract class RemoteNodeShutdownAndComesBackSpec """).withFallback(system.settings.config)) freshSystem.actorOf(Props[Subject], "subject") - freshSystem.awaitTermination(30.seconds) } diff --git a/akka-remote-tests/src/multi-jvm/scala/akka/remote/testconductor/TestConductorSpec.scala b/akka-remote-tests/src/multi-jvm/scala/akka/remote/testconductor/TestConductorSpec.scala index b6d5dd0259..66b46dd82c 100644 --- a/akka-remote-tests/src/multi-jvm/scala/akka/remote/testconductor/TestConductorSpec.scala +++ b/akka-remote-tests/src/multi-jvm/scala/akka/remote/testconductor/TestConductorSpec.scala @@ -5,7 +5,7 @@ package akka.remote.testconductor import language.postfixOps import com.typesafe.config.ConfigFactory -import akka.actor.{Props, Actor, ActorIdentity, Identify, Deploy} +import akka.actor.{ Props, Actor, ActorIdentity, Identify, Deploy } import scala.concurrent.Await import scala.concurrent.Awaitable import scala.concurrent.duration._ diff --git a/akka-samples/akka-sample-cluster/src/multi-jvm/scala/sample/cluster/stats/StatsSampleSingleMasterSpec.scala b/akka-samples/akka-sample-cluster/src/multi-jvm/scala/sample/cluster/stats/StatsSampleSingleMasterSpec.scala index d98bc02207..9388a39c40 100644 --- a/akka-samples/akka-sample-cluster/src/multi-jvm/scala/sample/cluster/stats/StatsSampleSingleMasterSpec.scala +++ b/akka-samples/akka-sample-cluster/src/multi-jvm/scala/sample/cluster/stats/StatsSampleSingleMasterSpec.scala @@ -79,8 +79,8 @@ abstract class StatsSampleSingleMasterSpec extends MultiNodeSpec(StatsSampleSing Cluster(system) join firstAddress - receiveN(3).collect { case MemberUp(m) => m.address }.toSet must be ( - Set(firstAddress, secondAddress, thirdAddress)) + receiveN(3).collect { case MemberUp(m) ⇒ m.address }.toSet must be( + Set(firstAddress, secondAddress, thirdAddress)) Cluster(system).unsubscribe(testActor) diff --git a/akka-samples/akka-sample-cluster/src/multi-jvm/scala/sample/cluster/stats/StatsSampleSpec.scala b/akka-samples/akka-sample-cluster/src/multi-jvm/scala/sample/cluster/stats/StatsSampleSpec.scala index efd18eb7ff..39b639c289 100644 --- a/akka-samples/akka-sample-cluster/src/multi-jvm/scala/sample/cluster/stats/StatsSampleSpec.scala +++ b/akka-samples/akka-sample-cluster/src/multi-jvm/scala/sample/cluster/stats/StatsSampleSpec.scala @@ -96,8 +96,8 @@ abstract class StatsSampleSpec extends MultiNodeSpec(StatsSampleSpecConfig) system.actorOf(Props[StatsWorker], "statsWorker") system.actorOf(Props[StatsService], "statsService") - receiveN(3).collect { case MemberUp(m) => m.address }.toSet must be ( - Set(firstAddress, secondAddress, thirdAddress)) + receiveN(3).collect { case MemberUp(m) ⇒ m.address }.toSet must be( + Set(firstAddress, secondAddress, thirdAddress)) Cluster(system).unsubscribe(testActor) diff --git a/akka-samples/akka-sample-cluster/src/multi-jvm/scala/sample/cluster/stats/japi/StatsSampleJapiSpec.scala b/akka-samples/akka-sample-cluster/src/multi-jvm/scala/sample/cluster/stats/japi/StatsSampleJapiSpec.scala index 3210a3999f..97905b9344 100644 --- a/akka-samples/akka-sample-cluster/src/multi-jvm/scala/sample/cluster/stats/japi/StatsSampleJapiSpec.scala +++ b/akka-samples/akka-sample-cluster/src/multi-jvm/scala/sample/cluster/stats/japi/StatsSampleJapiSpec.scala @@ -81,8 +81,8 @@ abstract class StatsSampleJapiSpec extends MultiNodeSpec(StatsSampleJapiSpecConf system.actorOf(Props[StatsWorker], "statsWorker") system.actorOf(Props[StatsService], "statsService") - receiveN(3).collect { case MemberUp(m) => m.address }.toSet must be ( - Set(firstAddress, secondAddress, thirdAddress)) + receiveN(3).collect { case MemberUp(m) ⇒ m.address }.toSet must be( + Set(firstAddress, secondAddress, thirdAddress)) Cluster(system).unsubscribe(testActor) diff --git a/akka-samples/akka-sample-cluster/src/multi-jvm/scala/sample/cluster/stats/japi/StatsSampleSingleMasterJapiSpec.scala b/akka-samples/akka-sample-cluster/src/multi-jvm/scala/sample/cluster/stats/japi/StatsSampleSingleMasterJapiSpec.scala index 5b96281c50..e24c35172d 100644 --- a/akka-samples/akka-sample-cluster/src/multi-jvm/scala/sample/cluster/stats/japi/StatsSampleSingleMasterJapiSpec.scala +++ b/akka-samples/akka-sample-cluster/src/multi-jvm/scala/sample/cluster/stats/japi/StatsSampleSingleMasterJapiSpec.scala @@ -78,13 +78,13 @@ abstract class StatsSampleSingleMasterJapiSpec extends MultiNodeSpec(StatsSample Cluster(system) join firstAddress - receiveN(3).collect { case MemberUp(m) => m.address }.toSet must be ( - Set(firstAddress, secondAddress, thirdAddress)) + receiveN(3).collect { case MemberUp(m) ⇒ m.address }.toSet must be( + Set(firstAddress, secondAddress, thirdAddress)) Cluster(system).unsubscribe(testActor) system.actorOf(ClusterSingletonManager.defaultProps( - Props[StatsService], + Props[StatsService], singletonName = "statsService", terminationMessage = PoisonPill, role = null), name = "singleton") diff --git a/akka-samples/akka-sample-multi-node/src/multi-jvm/scala/sample/multinode/MultiNodeSample.scala b/akka-samples/akka-sample-multi-node/src/multi-jvm/scala/sample/multinode/MultiNodeSample.scala index 35fc4e7774..e1aed49bc7 100644 --- a/akka-samples/akka-sample-multi-node/src/multi-jvm/scala/sample/multinode/MultiNodeSample.scala +++ b/akka-samples/akka-sample-multi-node/src/multi-jvm/scala/sample/multinode/MultiNodeSample.scala @@ -17,7 +17,7 @@ object MultiNodeSampleConfig extends MultiNodeConfig { //#spec import akka.remote.testkit.MultiNodeSpec import akka.testkit.ImplicitSender -import akka.actor.{Props, Actor} +import akka.actor.{ Props, Actor } class MultiNodeSampleSpecMultiJvmNode1 extends MultiNodeSample class MultiNodeSampleSpecMultiJvmNode2 extends MultiNodeSample @@ -46,7 +46,7 @@ class MultiNodeSample extends MultiNodeSpec(MultiNodeSampleConfig) runOn(node2) { system.actorOf(Props(new Actor { def receive = { - case "ping" => sender ! "pong" + case "ping" ⇒ sender ! "pong" } }), "ponger") enterBarrier("deployed") diff --git a/akka-samples/akka-sample-persistence/src/main/scala/sample/persistence/SnapshotExample.scala b/akka-samples/akka-sample-persistence/src/main/scala/sample/persistence/SnapshotExample.scala index 967a03ba2b..17f02e1095 100644 --- a/akka-samples/akka-sample-persistence/src/main/scala/sample/persistence/SnapshotExample.scala +++ b/akka-samples/akka-sample-persistence/src/main/scala/sample/persistence/SnapshotExample.scala @@ -20,7 +20,7 @@ object SnapshotExample extends App { case Persistent(s, snr) ⇒ state = state.update(s"${s}-${snr}") case SaveSnapshotSuccess(metadata) ⇒ // ... case SaveSnapshotFailure(metadata, reason) ⇒ // ... - case SnapshotOffer(_, s: ExampleState) ⇒ println("offered state = " + s); state = s + case SnapshotOffer(_, s: ExampleState) ⇒ { println("offered state = " + s); state = s } case "print" ⇒ println("current state = " + state) case "snap" ⇒ saveSnapshot(state) } diff --git a/akka-zeromq/src/main/scala/akka/zeromq/ConcurrentSocketActor.scala b/akka-zeromq/src/main/scala/akka/zeromq/ConcurrentSocketActor.scala index 0a8f98abd9..1c6e52b80a 100644 --- a/akka-zeromq/src/main/scala/akka/zeromq/ConcurrentSocketActor.scala +++ b/akka-zeromq/src/main/scala/akka/zeromq/ConcurrentSocketActor.scala @@ -63,7 +63,7 @@ private[zeromq] class ConcurrentSocketActor(params: immutable.Seq[SocketOption]) } private def handleConnectOption(msg: SocketConnectOption): Unit = msg match { - case Connect(endpoint) ⇒ socket.connect(endpoint); notifyListener(Connecting) + case Connect(endpoint) ⇒ { socket.connect(endpoint); notifyListener(Connecting) } case Bind(endpoint) ⇒ socket.bind(endpoint) }