While using Akka remote death watch. System tries to restart reliableendpoint-writer infinitely. This is more evident when a actor watches a remote actor and has a long heart beat pause for transport and watcher. It happens even if we context.unwatch and context.stop the remote actor. In this receiver is stopped by pressing C-c. Which leads to D…

Receiver.log

[info] Running org.rm.Receiver 
[DEBUG] [11/25/2013 12:56:39.619] [run-main] [EventStream(akka://a)] logger log1-Logging$DefaultLogger started
[DEBUG] [11/25/2013 12:56:39.621] [run-main] [EventStream(akka://a)] Default Loggers started
[DEBUG] [11/25/2013 12:56:39.629] [a-akka.actor.default-dispatcher-4] [akka://a/system] now supervising Actor[akka://a/system/remoting-terminator#-1684393666]
[DEBUG] [11/25/2013 12:56:39.642] [a-akka.actor.default-dispatcher-3] [akka://a/system/remoting-terminator] started (akka.remote.RemoteActorRefProvider$RemotingTerminator@2a6fab4)
[DEBUG] [11/25/2013 12:56:39.680] [a-akka.actor.default-dispatcher-4] [akka://a/system] now supervising Actor[akka://a/system/transports#-291439597]
[DEBUG] [11/25/2013 12:56:39.681] [a-akka.actor.default-dispatcher-3] [akka://a/system/transports] started (akka.remote.Remoting$TransportSupervisor@e39c2c0)
[INFO] [11/25/2013 12:56:39.685] [run-main] [Remoting] Starting remoting
[DEBUG] [11/25/2013 12:56:39.688] [a-akka.actor.default-dispatcher-2] [akka://a/system/remoting-terminator] now monitoring Actor[akka://a/system]
[DEBUG] [11/25/2013 12:56:39.689] [a-akka.actor.default-dispatcher-2] [akka://a/system] now supervising Actor[akka://a/system/endpointManager#705140301]
[DEBUG] [11/25/2013 12:56:39.696] [a-akka.actor.default-dispatcher-4] [akka://a/system/endpointManager] started (akka.remote.EndpointManager@52beb78e)
[DEBUG] [11/25/2013 12:56:39.843] [a-akka.actor.default-dispatcher-4] [akka://a/system/transports] now supervising Actor[akka://a/system/transports/akkaprotocolmanager.tcp0#8449374]
[DEBUG] [11/25/2013 12:56:39.845] [a-akka.actor.default-dispatcher-3] [akka://a/system/transports/akkaprotocolmanager.tcp0] started (akka.remote.transport.AkkaProtocolManager@66d9ce6e)
[INFO] [11/25/2013 12:56:39.853] [run-main] [Remoting] Remoting started; listening on addresses :[akka.tcp://a@127.0.0.1:9998]
[DEBUG] [11/25/2013 12:56:39.860] [a-akka.actor.default-dispatcher-3] [akka://a/system] now supervising Actor[akka://a/system/remote-watcher#-1831622627]
[DEBUG] [11/25/2013 12:56:39.861] [a-akka.actor.default-dispatcher-3] [akka://a/system] now supervising Actor[akka://a/system/remote-deployment-watcher#-424817307]
[DEBUG] [11/25/2013 12:56:39.862] [a-akka.actor.default-dispatcher-4] [akka://a/system/remote-deployment-watcher] started (akka.remote.RemoteDeploymentWatcher@2042268d)
[DEBUG] [11/25/2013 12:56:39.862] [a-akka.actor.default-dispatcher-4] [akka://a/system] now supervising Actor[akka://a/system/deadLetterListener#286919452]
[DEBUG] [11/25/2013 12:56:39.864] [a-akka.actor.default-dispatcher-3] [akka://a/system/deadLetterListener] started (akka.event.DeadLetterListener@6f217815)
[DEBUG] [11/25/2013 12:56:39.867] [a-akka.actor.default-dispatcher-2] [akka://a/system/remote-watcher] started (akka.remote.RemoteWatcher@62e06c94)
Receiver started as:Actor[akka://a/user/ReceiverActor#2068119061]
[DEBUG] [11/25/2013 12:56:39.870] [a-akka.actor.default-dispatcher-2] [akka://a/user] now supervising Actor[akka://a/user/ReceiverActor#2068119061]
[DEBUG] [11/25/2013 12:56:39.879] [a-akka.actor.default-dispatcher-3] [akka://a/user/ReceiverActor] started (org.rm.ReceiverActor@5adbe549)
[DEBUG] [11/25/2013 12:56:39.885] [a-akka.actor.default-dispatcher-2] [akka://a/system/endpointManager] now supervising Actor[akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9999-0#-1493812065]
[DEBUG] [11/25/2013 12:56:39.898] [a-akka.actor.default-dispatcher-3] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9999-0] started (akka.remote.ReliableDeliverySupervisor@5a431ae9)
[DEBUG] [11/25/2013 12:56:39.898] [a-akka.actor.default-dispatcher-3] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9999-0] now monitoring Actor[akka://a/system/endpointManager#705140301]
[DEBUG] [11/25/2013 12:56:39.899] [a-akka.actor.default-dispatcher-3] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9999-0] now supervising Actor[akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9999-0/endpointWriter#848338738]
[DEBUG] [11/25/2013 12:56:39.910] [a-akka.actor.default-dispatcher-2] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9999-0/endpointWriter] started (akka.remote.EndpointWriter@2d899933)
[DEBUG] [11/25/2013 12:56:39.910] [a-akka.actor.default-dispatcher-2] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9999-0/endpointWriter] now monitoring Actor[akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9999-0#-1493812065]
[DEBUG] [11/25/2013 12:56:39.949] [a-akka.actor.default-dispatcher-3] [akka://a/system/transports/akkaprotocolmanager.tcp0] now supervising Actor[akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9999-1#1582099814]
[DEBUG] [11/25/2013 12:56:39.971] [a-akka.actor.default-dispatcher-4] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9999-1] started (akka.remote.transport.ProtocolStateActor@2aec5463)
[DEBUG] [11/25/2013 12:56:40.059] [a-akka.actor.default-dispatcher-3] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9999-0/endpointWriter] Associated [akka.tcp://a@127.0.0.1:9998] -> [akka.tcp://a@127.0.0.1:9999]
[DEBUG] [11/25/2013 12:56:40.059] [a-akka.actor.default-dispatcher-3] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9999-0/endpointWriter] now supervising Actor[akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9999-0/endpointWriter/endpointReader-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9999-0#781967797]
[DEBUG] [11/25/2013 12:56:40.063] [a-akka.actor.default-dispatcher-3] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9999-0/endpointWriter] sending message RemoteMessage: [SelectChildName(user,SelectChildName(FeederActor,SubscribeReceiver(Actor[akka://a/user/ReceiverActor#2068119061])))] to [Actor[akka.tcp://a@127.0.0.1:9999/]]<+[akka.tcp://a@127.0.0.1:9999/] from [Actor[akka://a/user/ReceiverActor#2068119061]]
Associated [akka.tcp://a@127.0.0.1:9998] -> [akka.tcp://a@127.0.0.1:9999]
[DEBUG] [11/25/2013 12:56:40.068] [a-akka.actor.default-dispatcher-12] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9999-0/endpointWriter/endpointReader-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9999-0] started (akka.remote.EndpointReader@31c3cead)
[DEBUG] [11/25/2013 12:56:40.068] [a-akka.actor.default-dispatcher-12] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9999-0/endpointWriter/endpointReader-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9999-0] now monitoring Actor[akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9999-0/endpointWriter#848338738]
[DEBUG] [11/25/2013 12:56:40.069] [a-akka.actor.default-dispatcher-3] [akka.serialization.Serialization(akka://a)] Using serializer[akka.remote.serialization.MessageContainerSerializer] for message [akka.actor.SelectChildName]
[DEBUG] [11/25/2013 12:56:40.076] [a-akka.actor.default-dispatcher-3] [akka.serialization.Serialization(akka://a)] Using serializer[akka.serialization.JavaSerializer] for message [org.rm.SubscribeReceiver]
[DEBUG] [11/25/2013 12:56:40.149] [a-akka.actor.default-dispatcher-12] [akka://a/user/ReceiverActor] now monitoring Actor[akka.tcp://a@127.0.0.1:9999/user/FeederActor#-483414050]
[DEBUG] [11/25/2013 12:56:40.150] [a-akka.actor.default-dispatcher-3] [akka://a/user/ReceiverActor] now monitoring Actor[akka.tcp://a@127.0.0.1:9999/system/remote-watcher#1986678359]
Watching....Actor[akka.tcp://a@127.0.0.1:9999/user/FeederActor#-483414050]
[DEBUG] [11/25/2013 12:56:40.152] [a-akka.actor.default-dispatcher-3] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9999-0/endpointWriter] sending message RemoteMessage: [Watch(Actor[akka.tcp://a@127.0.0.1:9999/user/FeederActor#-483414050],Actor[akka://a/user/ReceiverActor#2068119061])] to [Actor[akka.tcp://a@127.0.0.1:9999/user/FeederActor#-483414050]]<+[akka.tcp://a@127.0.0.1:9999/user/FeederActor] from [Actor[akka://a/deadLetters]]
[DEBUG] [11/25/2013 12:56:40.152] [a-akka.actor.default-dispatcher-3] [akka.serialization.Serialization(akka://a)] Using serializer[akka.serialization.JavaSerializer] for message [akka.dispatch.sysmsg.Watch]
[DEBUG] [11/25/2013 12:56:40.153] [a-akka.actor.default-dispatcher-14] [akka://a/system/remote-watcher] Watching: [akka://a/user/ReceiverActor -> akka.tcp://a@127.0.0.1:9999/user/FeederActor]
[DEBUG] [11/25/2013 12:56:40.154] [a-akka.actor.default-dispatcher-3] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9999-0/endpointWriter] sending message RemoteMessage: [Watch(Actor[akka.tcp://a@127.0.0.1:9999/user/FeederActor#-483414050],Actor[akka://a/system/remote-watcher#-1831622627])] to [Actor[akka.tcp://a@127.0.0.1:9999/user/FeederActor#-483414050]]<+[akka.tcp://a@127.0.0.1:9999/user/FeederActor] from [Actor[akka://a/deadLetters]]
may may 1
[DEBUG] [11/25/2013 12:56:40.881] [a-akka.actor.default-dispatcher-4] [akka://a/system/remote-watcher] Sending first Heartbeat to [akka.tcp://a@127.0.0.1:9999]
[DEBUG] [11/25/2013 12:56:40.883] [a-akka.actor.default-dispatcher-13] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9999-0/endpointWriter] sending message RemoteMessage: [SelectChildName(system,SelectChildName(remote-watcher,Heartbeat))] to [Actor[akka.tcp://a@127.0.0.1:9999/]]<+[akka.tcp://a@127.0.0.1:9999/] from [Actor[akka://a/system/remote-watcher#-1831622627]]
[DEBUG] [11/25/2013 12:56:40.883] [a-akka.actor.default-dispatcher-13] [akka.serialization.Serialization(akka://a)] Using serializer[akka.serialization.JavaSerializer] for message [akka.remote.RemoteWatcher$Heartbeat$]
[DEBUG] [11/25/2013 12:56:40.892] [a-akka.actor.default-dispatcher-3] [akka://a/system/remote-watcher] Received first heartbeat rsp from [akka.tcp://a@127.0.0.1:9999]
[DEBUG] [11/25/2013 12:56:40.893] [a-akka.actor.default-dispatcher-3] [akka://a/system/remote-watcher] Re-watch [Actor[akka://a/user/ReceiverActor#2068119061] -> Actor[akka.tcp://a@127.0.0.1:9999/user/FeederActor#-483414050]]
[DEBUG] [11/25/2013 12:56:40.893] [a-akka.actor.default-dispatcher-3] [akka://a/system/remote-watcher] Re-watch [Actor[akka://a/system/remote-watcher#-1831622627] -> Actor[akka.tcp://a@127.0.0.1:9999/user/FeederActor#-483414050]]
[DEBUG] [11/25/2013 12:56:40.893] [a-akka.actor.default-dispatcher-4] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9999-0/endpointWriter] sending message RemoteMessage: [Watch(Actor[akka.tcp://a@127.0.0.1:9999/user/FeederActor#-483414050],Actor[akka://a/user/ReceiverActor#2068119061])] to [Actor[akka.tcp://a@127.0.0.1:9999/user/FeederActor#-483414050]]<+[akka.tcp://a@127.0.0.1:9999/user/FeederActor] from [Actor[akka://a/deadLetters]]
[DEBUG] [11/25/2013 12:56:40.894] [a-akka.actor.default-dispatcher-14] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9999-0/endpointWriter] sending message RemoteMessage: [Watch(Actor[akka.tcp://a@127.0.0.1:9999/user/FeederActor#-483414050],Actor[akka://a/system/remote-watcher#-1831622627])] to [Actor[akka.tcp://a@127.0.0.1:9999/user/FeederActor#-483414050]]<+[akka.tcp://a@127.0.0.1:9999/user/FeederActor] from [Actor[akka://a/deadLetters]]
[DEBUG] [11/25/2013 12:56:40.894] [a-akka.actor.default-dispatcher-3] [akka://a/system/remote-watcher] Watching: [akka://a/user/ReceiverActor -> akka.tcp://a@127.0.0.1:9999/user/FeederActor]
may may 2
[DEBUG] [11/25/2013 12:56:41.106] [a-akka.actor.default-dispatcher-13] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9999-0/endpointWriter] sending message RemoteMessage: [HeartbeatRsp(1375829985)] to [Actor[akka.tcp://a@127.0.0.1:9999/system/remote-watcher#1986678359]]<+[akka.tcp://a@127.0.0.1:9999/system/remote-watcher] from [Actor[akka://a/system/remote-watcher#-1831622627]]
[DEBUG] [11/25/2013 12:56:41.106] [a-akka.actor.default-dispatcher-13] [akka.serialization.Serialization(akka://a)] Using serializer[akka.serialization.JavaSerializer] for message [akka.remote.RemoteWatcher$HeartbeatRsp]
words count 3
  C-c C-c^C

Sender.log

[info] Running org.rm.Sender 
[DEBUG] [11/25/2013 12:56:35.718] [run-main] [EventStream(akka://a)] logger log1-Logging$DefaultLogger started
[DEBUG] [11/25/2013 12:56:35.723] [run-main] [EventStream(akka://a)] Default Loggers started
[DEBUG] [11/25/2013 12:56:35.736] [a-akka.actor.default-dispatcher-3] [akka://a/system] now supervising Actor[akka://a/system/remoting-terminator#1404572120]
[DEBUG] [11/25/2013 12:56:35.750] [a-akka.actor.default-dispatcher-2] [akka://a/system/remoting-terminator] started (akka.remote.RemoteActorRefProvider$RemotingTerminator@6aa734bc)
[DEBUG] [11/25/2013 12:56:35.794] [a-akka.actor.default-dispatcher-3] [akka://a/system] now supervising Actor[akka://a/system/transports#171595497]
[DEBUG] [11/25/2013 12:56:35.794] [a-akka.actor.default-dispatcher-2] [akka://a/system/transports] started (akka.remote.Remoting$TransportSupervisor@7dfec051)
[DEBUG] [11/25/2013 12:56:35.814] [a-akka.actor.default-dispatcher-4] [akka://a/system/remoting-terminator] now monitoring Actor[akka://a/system]
[INFO] [11/25/2013 12:56:35.816] [run-main] [Remoting] Starting remoting
[DEBUG] [11/25/2013 12:56:35.828] [a-akka.actor.default-dispatcher-4] [akka://a/system] now supervising Actor[akka://a/system/endpointManager#1223930904]
[DEBUG] [11/25/2013 12:56:35.839] [a-akka.actor.default-dispatcher-4] [akka://a/system/endpointManager] started (akka.remote.EndpointManager@37b5fd0f)
[DEBUG] [11/25/2013 12:56:36.055] [a-akka.actor.default-dispatcher-4] [akka://a/system/transports] now supervising Actor[akka://a/system/transports/akkaprotocolmanager.tcp0#-1280890548]
[DEBUG] [11/25/2013 12:56:36.061] [a-akka.actor.default-dispatcher-5] [akka://a/system/transports/akkaprotocolmanager.tcp0] started (akka.remote.transport.AkkaProtocolManager@6a25347d)
[INFO] [11/25/2013 12:56:36.065] [run-main] [Remoting] Remoting started; listening on addresses :[akka.tcp://a@127.0.0.1:9999]
[DEBUG] [11/25/2013 12:56:36.070] [a-akka.actor.default-dispatcher-5] [akka://a/system] now supervising Actor[akka://a/system/remote-watcher#1986678359]
[DEBUG] [11/25/2013 12:56:36.071] [a-akka.actor.default-dispatcher-5] [akka://a/system] now supervising Actor[akka://a/system/remote-deployment-watcher#1229819355]
[DEBUG] [11/25/2013 12:56:36.072] [a-akka.actor.default-dispatcher-4] [akka://a/system/remote-deployment-watcher] started (akka.remote.RemoteDeploymentWatcher@37e38695)
[DEBUG] [11/25/2013 12:56:36.072] [a-akka.actor.default-dispatcher-4] [akka://a/system] now supervising Actor[akka://a/system/deadLetterListener#1261408957]
[DEBUG] [11/25/2013 12:56:36.075] [a-akka.actor.default-dispatcher-5] [akka://a/system/deadLetterListener] started (akka.event.DeadLetterListener@60648df2)
[DEBUG] [11/25/2013 12:56:36.077] [a-akka.actor.default-dispatcher-2] [akka://a/system/remote-watcher] started (akka.remote.RemoteWatcher@439acb5e)
Feeder started as:Actor[akka://a/user/FeederActor#-483414050]
[DEBUG] [11/25/2013 12:56:36.083] [a-akka.actor.default-dispatcher-2] [akka://a/user] now supervising Actor[akka://a/user/FeederActor#-483414050]
[DEBUG] [11/25/2013 12:56:36.084] [a-akka.actor.default-dispatcher-3] [akka://a/user/FeederActor] started (org.rm.FeederActor@52fca25e)
[DEBUG] [11/25/2013 12:56:40.004] [a-akka.actor.default-dispatcher-5] [akka://a/system/transports/akkaprotocolmanager.tcp0] now supervising Actor[akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A51055-1#557957852]
[DEBUG] [11/25/2013 12:56:40.011] [a-akka.actor.default-dispatcher-3] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A51055-1] started (akka.remote.transport.ProtocolStateActor@16480dea)
[DEBUG] [11/25/2013 12:56:40.042] [a-akka.actor.default-dispatcher-5] [Remoting] Associated [akka.tcp://a@127.0.0.1:9999] <- [akka.tcp://a@127.0.0.1:9998]
[DEBUG] [11/25/2013 12:56:40.047] [a-akka.actor.default-dispatcher-5] [akka://a/system/endpointManager] now supervising Actor[akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0#1071532253]
[DEBUG] [11/25/2013 12:56:40.058] [a-akka.actor.default-dispatcher-2] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0] started (akka.remote.ReliableDeliverySupervisor@1f026264)
[DEBUG] [11/25/2013 12:56:40.058] [a-akka.actor.default-dispatcher-2] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0] now monitoring Actor[akka://a/system/endpointManager#1223930904]
[DEBUG] [11/25/2013 12:56:40.058] [a-akka.actor.default-dispatcher-2] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0] now supervising Actor[akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter#-462025852]
[DEBUG] [11/25/2013 12:56:40.070] [a-akka.actor.default-dispatcher-5] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] started (akka.remote.EndpointWriter@b19adfc)
[DEBUG] [11/25/2013 12:56:40.070] [a-akka.actor.default-dispatcher-5] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] now monitoring Actor[akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0#1071532253]
[DEBUG] [11/25/2013 12:56:40.070] [a-akka.actor.default-dispatcher-5] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] now supervising Actor[akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter/endpointReader-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0#180430375]
[DEBUG] [11/25/2013 12:56:40.076] [a-akka.actor.default-dispatcher-3] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter/endpointReader-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0] started (akka.remote.EndpointReader@27b2533d)
[DEBUG] [11/25/2013 12:56:40.076] [a-akka.actor.default-dispatcher-3] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter/endpointReader-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0] now monitoring Actor[akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter#-462025852]
[DEBUG] [11/25/2013 12:56:40.123] [a-akka.actor.default-dispatcher-2] [akka://a/system/remote-watcher] Watching: [akka://a/user/FeederActor -> akka.tcp://a@127.0.0.1:9998/user/ReceiverActor]
received subscribe from Actor[akka.tcp://a@127.0.0.1:9998/user/ReceiverActor#2068119061]
[DEBUG] [11/25/2013 12:56:40.124] [a-akka.actor.default-dispatcher-5] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] sending message RemoteMessage: [Watch(Actor[akka.tcp://a@127.0.0.1:9998/user/ReceiverActor#2068119061],Actor[akka://a/user/FeederActor#-483414050])] to [Actor[akka.tcp://a@127.0.0.1:9998/user/ReceiverActor#2068119061]]<+[akka.tcp://a@127.0.0.1:9998/user/ReceiverActor] from [Actor[akka://a/deadLetters]]
[DEBUG] [11/25/2013 12:56:40.126] [a-akka.actor.default-dispatcher-5] [akka.serialization.Serialization(akka://a)] Using serializer[akka.serialization.JavaSerializer] for message [akka.dispatch.sysmsg.Watch]
[DEBUG] [11/25/2013 12:56:40.135] [a-akka.actor.default-dispatcher-5] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] sending message RemoteMessage: [Watch(Actor[akka.tcp://a@127.0.0.1:9998/user/ReceiverActor#2068119061],Actor[akka://a/system/remote-watcher#1986678359])] to [Actor[akka.tcp://a@127.0.0.1:9998/user/ReceiverActor#2068119061]]<+[akka.tcp://a@127.0.0.1:9998/user/ReceiverActor] from [Actor[akka://a/deadLetters]]
[DEBUG] [11/25/2013 12:56:40.135] [a-akka.actor.default-dispatcher-5] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] sending message RemoteMessage: [Ack] to [Actor[akka.tcp://a@127.0.0.1:9998/user/ReceiverActor#2068119061]]<+[akka.tcp://a@127.0.0.1:9998/user/ReceiverActor] from [Actor[akka://a/user/FeederActor#-483414050]]
[DEBUG] [11/25/2013 12:56:40.136] [a-akka.actor.default-dispatcher-5] [akka.serialization.Serialization(akka://a)] Using serializer[akka.serialization.JavaSerializer] for message [org.rm.Ack$]
[DEBUG] [11/25/2013 12:56:40.158] [a-akka.actor.default-dispatcher-13] [akka://a/user/FeederActor] now monitoring Actor[akka.tcp://a@127.0.0.1:9998/user/ReceiverActor#2068119061]
[DEBUG] [11/25/2013 12:56:40.159] [a-akka.actor.default-dispatcher-3] [akka://a/user/FeederActor] now monitoring Actor[akka.tcp://a@127.0.0.1:9998/system/remote-watcher#-1831622627]
[DEBUG] [11/25/2013 12:56:40.585] [a-akka.actor.default-dispatcher-3] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] sending message RemoteMessage: [may may 1] to [Actor[akka.tcp://a@127.0.0.1:9998/user/ReceiverActor#2068119061]]<+[akka.tcp://a@127.0.0.1:9998/user/ReceiverActor] from [Actor[akka://a/user/FeederActor#-483414050]]
[DEBUG] [11/25/2013 12:56:40.585] [a-akka.actor.default-dispatcher-3] [akka.serialization.Serialization(akka://a)] Using serializer[akka.serialization.JavaSerializer] for message [java.lang.String]
[DEBUG] [11/25/2013 12:56:40.888] [a-akka.actor.default-dispatcher-13] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] sending message RemoteMessage: [HeartbeatRsp(-1408704858)] to [Actor[akka.tcp://a@127.0.0.1:9998/system/remote-watcher#-1831622627]]<+[akka.tcp://a@127.0.0.1:9998/system/remote-watcher] from [Actor[akka://a/system/remote-watcher#1986678359]]
[DEBUG] [11/25/2013 12:56:40.888] [a-akka.actor.default-dispatcher-13] [akka.serialization.Serialization(akka://a)] Using serializer[akka.serialization.JavaSerializer] for message [akka.remote.RemoteWatcher$HeartbeatRsp]
[DEBUG] [11/25/2013 12:56:41.085] [a-akka.actor.default-dispatcher-13] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] sending message RemoteMessage: [may may 2] to [Actor[akka.tcp://a@127.0.0.1:9998/user/ReceiverActor#2068119061]]<+[akka.tcp://a@127.0.0.1:9998/user/ReceiverActor] from [Actor[akka://a/user/FeederActor#-483414050]]
[DEBUG] [11/25/2013 12:56:41.092] [a-akka.actor.default-dispatcher-4] [akka://a/system/remote-watcher] Sending first Heartbeat to [akka.tcp://a@127.0.0.1:9998]
[DEBUG] [11/25/2013 12:56:41.098] [a-akka.actor.default-dispatcher-3] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] sending message RemoteMessage: [SelectChildName(system,SelectChildName(remote-watcher,Heartbeat))] to [Actor[akka.tcp://a@127.0.0.1:9998/]]<+[akka.tcp://a@127.0.0.1:9998/] from [Actor[akka://a/system/remote-watcher#1986678359]]
[DEBUG] [11/25/2013 12:56:41.099] [a-akka.actor.default-dispatcher-3] [akka.serialization.Serialization(akka://a)] Using serializer[akka.remote.serialization.MessageContainerSerializer] for message [akka.actor.SelectChildName]
[DEBUG] [11/25/2013 12:56:41.100] [a-akka.actor.default-dispatcher-3] [akka.serialization.Serialization(akka://a)] Using serializer[akka.serialization.JavaSerializer] for message [akka.remote.RemoteWatcher$Heartbeat$]
[DEBUG] [11/25/2013 12:56:41.108] [a-akka.actor.default-dispatcher-4] [akka://a/system/remote-watcher] Received first heartbeat rsp from [akka.tcp://a@127.0.0.1:9998]
[DEBUG] [11/25/2013 12:56:41.109] [a-akka.actor.default-dispatcher-4] [akka://a/system/remote-watcher] Re-watch [Actor[akka://a/user/FeederActor#-483414050] -> Actor[akka.tcp://a@127.0.0.1:9998/user/ReceiverActor#2068119061]]
[DEBUG] [11/25/2013 12:56:41.109] [a-akka.actor.default-dispatcher-4] [akka://a/system/remote-watcher] Re-watch [Actor[akka://a/system/remote-watcher#1986678359] -> Actor[akka.tcp://a@127.0.0.1:9998/user/ReceiverActor#2068119061]]
[DEBUG] [11/25/2013 12:56:41.109] [a-akka.actor.default-dispatcher-5] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] sending message RemoteMessage: [Watch(Actor[akka.tcp://a@127.0.0.1:9998/user/ReceiverActor#2068119061],Actor[akka://a/user/FeederActor#-483414050])] to [Actor[akka.tcp://a@127.0.0.1:9998/user/ReceiverActor#2068119061]]<+[akka.tcp://a@127.0.0.1:9998/user/ReceiverActor] from [Actor[akka://a/deadLetters]]
[DEBUG] [11/25/2013 12:56:41.110] [a-akka.actor.default-dispatcher-5] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] sending message RemoteMessage: [Watch(Actor[akka.tcp://a@127.0.0.1:9998/user/ReceiverActor#2068119061],Actor[akka://a/system/remote-watcher#1986678359])] to [Actor[akka.tcp://a@127.0.0.1:9998/user/ReceiverActor#2068119061]]<+[akka.tcp://a@127.0.0.1:9998/user/ReceiverActor] from [Actor[akka://a/deadLetters]]
[DEBUG] [11/25/2013 12:56:41.111] [a-akka.actor.default-dispatcher-4] [akka://a/system/remote-watcher] Watching: [akka://a/user/FeederActor -> akka.tcp://a@127.0.0.1:9998/user/ReceiverActor]
[DEBUG] [11/25/2013 12:56:41.585] [a-akka.actor.default-dispatcher-3] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] sending message RemoteMessage: [words count 3] to [Actor[akka.tcp://a@127.0.0.1:9998/user/ReceiverActor#2068119061]]<+[akka.tcp://a@127.0.0.1:9998/user/ReceiverActor] from [Actor[akka://a/user/FeederActor#-483414050]]
[DEBUG] [11/25/2013 12:56:42.085] [a-akka.actor.default-dispatcher-4] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] sending message RemoteMessage: [may may 4] to [Actor[akka.tcp://a@127.0.0.1:9998/user/ReceiverActor#2068119061]]<+[akka.tcp://a@127.0.0.1:9998/user/ReceiverActor] from [Actor[akka://a/user/FeederActor#-483414050]]
[DEBUG] [11/25/2013 12:56:42.090] [a-akka.actor.default-dispatcher-5] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter/endpointReader-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0] stopped
[DEBUG] [11/25/2013 12:56:42.090] [a-akka.actor.default-dispatcher-3] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A51055-1] stopped
[DEBUG] [11/25/2013 12:56:42.091] [a-akka.actor.default-dispatcher-2] [akka://a/system/remote-watcher] Sending Heartbeat to [akka.tcp://a@127.0.0.1:9998]
[DEBUG] [11/25/2013 12:56:42.092] [a-akka.actor.default-dispatcher-4] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] Disassociated [akka.tcp://a@127.0.0.1:9999] <- [akka.tcp://a@127.0.0.1:9998]
[DEBUG] [11/25/2013 12:56:42.096] [a-akka.actor.default-dispatcher-16] [akka://a/system/remote-watcher] Unwatching: [akka://a/user/FeederActor -> akka.tcp://a@127.0.0.1:9998/user/ReceiverActor]
[DEBUG] [11/25/2013 12:56:42.096] [a-akka.actor.default-dispatcher-16] [akka://a/system/remote-watcher] Cleanup self watch of [akka.tcp://a@127.0.0.1:9998/user/ReceiverActor]
[error] (Thread-2) java.lang.InterruptedException: sleep interrupted
java.lang.InterruptedException: sleep interrupted
	at java.lang.Thread.sleep(Native Method)
	at org.rm.FeederActor$$anon$1.run(Testing.scala:100)
[trace] Stack trace suppressed: run last rm/compile:run for the full output.
[DEBUG] [11/25/2013 12:56:42.098] [a-akka.actor.default-dispatcher-16] [akka://a/system/remote-watcher] Unwatched last watchee of node: [akka.tcp://a@127.0.0.1:9998]
[DEBUG] [11/25/2013 12:56:42.102] [a-akka.actor.default-dispatcher-17] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] restarting
[DEBUG] [11/25/2013 12:56:42.105] [a-akka.actor.default-dispatcher-17] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] Disassociated [akka.tcp://a@127.0.0.1:9999] <- [akka.tcp://a@127.0.0.1:9998]
[INFO] [11/25/2013 12:56:42.105] [a-akka.actor.default-dispatcher-16] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A51055-1] Message [akka.remote.transport.ActorTransportAdapter$DisassociateUnderlying] from Actor[akka://a/deadLetters] to Actor[akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A51055-1#557957852] was not delivered. [1] dead letters encountered. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
[DEBUG] [11/25/2013 12:56:42.107] [a-akka.actor.default-dispatcher-17] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] restarted
[DEBUG] [11/25/2013 12:56:42.108] [a-akka.actor.default-dispatcher-16] [akka://a/system/transports/akkaprotocolmanager.tcp0] now supervising Actor[akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-2#1353344668]
[DEBUG] [11/25/2013 12:56:42.114] [a-akka.actor.default-dispatcher-17] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-2] started (akka.remote.transport.ProtocolStateActor@32b05021)
[DEBUG] [11/25/2013 12:56:42.120] [a-akka.actor.default-dispatcher-17] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-2] stopped
[ERROR] [11/25/2013 12:56:42.122] [a-akka.actor.default-dispatcher-16] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] AssociationError [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]: Error [Association failed with [akka.tcp://a@127.0.0.1:9998]] [
akka.remote.EndpointAssociationException: Association failed with [akka.tcp://a@127.0.0.1:9998]
Caused by: akka.remote.transport.netty.NettyTransport$$anonfun$associate$1$$anon$2: Connection refused: /127.0.0.1:9998
]
[DEBUG] [11/25/2013 12:56:42.122] [a-akka.actor.default-dispatcher-2] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] restarting
[DEBUG] [11/25/2013 12:56:42.122] [a-akka.actor.default-dispatcher-2] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] Disassociated [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]
[DEBUG] [11/25/2013 12:56:42.123] [a-akka.actor.default-dispatcher-2] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] restarted
[DEBUG] [11/25/2013 12:56:42.124] [a-akka.actor.default-dispatcher-17] [akka://a/system/transports/akkaprotocolmanager.tcp0] now supervising Actor[akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-3#-570691733]
[DEBUG] [11/25/2013 12:56:42.124] [a-akka.actor.default-dispatcher-4] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-3] started (akka.remote.transport.ProtocolStateActor@27c58846)
[DEBUG] [11/25/2013 12:56:42.125] [a-akka.actor.default-dispatcher-17] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-3] stopped
[ERROR] [11/25/2013 12:56:42.125] [a-akka.actor.default-dispatcher-16] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] AssociationError [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]: Error [Association failed with [akka.tcp://a@127.0.0.1:9998]] [
akka.remote.EndpointAssociationException: Association failed with [akka.tcp://a@127.0.0.1:9998]
Caused by: akka.remote.transport.netty.NettyTransport$$anonfun$associate$1$$anon$2: Connection refused: /127.0.0.1:9998
]
[DEBUG] [11/25/2013 12:56:42.126] [a-akka.actor.default-dispatcher-16] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] restarting
[DEBUG] [11/25/2013 12:56:42.126] [a-akka.actor.default-dispatcher-16] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] Disassociated [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]
[DEBUG] [11/25/2013 12:56:42.126] [a-akka.actor.default-dispatcher-16] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] restarted
[DEBUG] [11/25/2013 12:56:42.127] [a-akka.actor.default-dispatcher-2] [akka://a/system/transports/akkaprotocolmanager.tcp0] now supervising Actor[akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-4#-651065576]
[DEBUG] [11/25/2013 12:56:42.127] [a-akka.actor.default-dispatcher-17] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-4] started (akka.remote.transport.ProtocolStateActor@11771d18)
[DEBUG] [11/25/2013 12:56:42.128] [a-akka.actor.default-dispatcher-4] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-4] stopped
[ERROR] [11/25/2013 12:56:42.128] [a-akka.actor.default-dispatcher-2] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] AssociationError [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]: Error [Association failed with [akka.tcp://a@127.0.0.1:9998]] [
akka.remote.EndpointAssociationException: Association failed with [akka.tcp://a@127.0.0.1:9998]
Caused by: akka.remote.transport.netty.NettyTransport$$anonfun$associate$1$$anon$2: Connection refused: /127.0.0.1:9998
]
[DEBUG] [11/25/2013 12:56:42.129] [a-akka.actor.default-dispatcher-4] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] Disassociated [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]
[INFO] [11/25/2013 12:56:42.129] [a-akka.actor.default-dispatcher-14] [akka://a/deadLetters] Message [java.lang.String] from Actor[akka://a/user/FeederActor#-483414050] to Actor[akka://a/deadLetters] was not delivered. [2] dead letters encountered. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
[INFO] [11/25/2013 12:56:42.130] [a-akka.actor.default-dispatcher-14] [akka://a/deadLetters] Message [akka.remote.RemoteWatcher$Heartbeat$] from Actor[akka://a/system/remote-watcher#1986678359] to Actor[akka://a/deadLetters] was not delivered. [3] dead letters encountered. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
[DEBUG] [11/25/2013 12:56:42.131] [a-akka.actor.default-dispatcher-4] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] stopped
[DEBUG] [11/25/2013 12:56:43.142] [a-akka.actor.default-dispatcher-16] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0] now supervising Actor[akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter#-591924083]
[DEBUG] [11/25/2013 12:56:43.143] [a-akka.actor.default-dispatcher-4] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] started (akka.remote.EndpointWriter@3f857083)
[DEBUG] [11/25/2013 12:56:43.143] [a-akka.actor.default-dispatcher-4] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] now monitoring Actor[akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0#1071532253]
[DEBUG] [11/25/2013 12:56:43.145] [a-akka.actor.default-dispatcher-16] [akka://a/system/transports/akkaprotocolmanager.tcp0] now supervising Actor[akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-5#1620217608]
[DEBUG] [11/25/2013 12:56:43.145] [a-akka.actor.default-dispatcher-3] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-5] started (akka.remote.transport.ProtocolStateActor@519dc909)
[DEBUG] [11/25/2013 12:56:43.148] [a-akka.actor.default-dispatcher-4] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-5] stopped
[ERROR] [11/25/2013 12:56:43.148] [a-akka.actor.default-dispatcher-17] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] AssociationError [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]: Error [Association failed with [akka.tcp://a@127.0.0.1:9998]] [
akka.remote.EndpointAssociationException: Association failed with [akka.tcp://a@127.0.0.1:9998]
Caused by: akka.remote.transport.netty.NettyTransport$$anonfun$associate$1$$anon$2: Connection refused: /127.0.0.1:9998
]
[DEBUG] [11/25/2013 12:56:43.148] [a-akka.actor.default-dispatcher-4] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] restarting
[DEBUG] [11/25/2013 12:56:43.148] [a-akka.actor.default-dispatcher-4] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] Disassociated [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]
[DEBUG] [11/25/2013 12:56:43.149] [a-akka.actor.default-dispatcher-4] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] restarted
[DEBUG] [11/25/2013 12:56:43.151] [a-akka.actor.default-dispatcher-16] [akka://a/system/transports/akkaprotocolmanager.tcp0] now supervising Actor[akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-6#-693701054]
[DEBUG] [11/25/2013 12:56:43.152] [a-akka.actor.default-dispatcher-3] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-6] started (akka.remote.transport.ProtocolStateActor@48a6e183)
[DEBUG] [11/25/2013 12:56:43.153] [a-akka.actor.default-dispatcher-16] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-6] stopped
[ERROR] [11/25/2013 12:56:43.154] [a-akka.actor.default-dispatcher-14] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] AssociationError [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]: Error [Association failed with [akka.tcp://a@127.0.0.1:9998]] [
akka.remote.EndpointAssociationException: Association failed with [akka.tcp://a@127.0.0.1:9998]
Caused by: akka.remote.transport.netty.NettyTransport$$anonfun$associate$1$$anon$2: Connection refused: /127.0.0.1:9998
]
[DEBUG] [11/25/2013 12:56:43.154] [a-akka.actor.default-dispatcher-3] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] restarting
[DEBUG] [11/25/2013 12:56:43.154] [a-akka.actor.default-dispatcher-3] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] Disassociated [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]
[DEBUG] [11/25/2013 12:56:43.155] [a-akka.actor.default-dispatcher-3] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] restarted
[DEBUG] [11/25/2013 12:56:43.157] [a-akka.actor.default-dispatcher-4] [akka://a/system/transports/akkaprotocolmanager.tcp0] now supervising Actor[akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-7#261958464]
[DEBUG] [11/25/2013 12:56:43.157] [a-akka.actor.default-dispatcher-2] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-7] started (akka.remote.transport.ProtocolStateActor@168c1e51)
[DEBUG] [11/25/2013 12:56:43.159] [a-akka.actor.default-dispatcher-17] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-7] stopped
[ERROR] [11/25/2013 12:56:43.159] [a-akka.actor.default-dispatcher-3] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] AssociationError [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]: Error [Association failed with [akka.tcp://a@127.0.0.1:9998]] [
akka.remote.EndpointAssociationException: Association failed with [akka.tcp://a@127.0.0.1:9998]
Caused by: akka.remote.transport.netty.NettyTransport$$anonfun$associate$1$$anon$2: Connection refused: /127.0.0.1:9998
]
[DEBUG] [11/25/2013 12:56:43.159] [a-akka.actor.default-dispatcher-2] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] restarting
[DEBUG] [11/25/2013 12:56:43.160] [a-akka.actor.default-dispatcher-2] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] Disassociated [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]
[DEBUG] [11/25/2013 12:56:43.160] [a-akka.actor.default-dispatcher-2] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] restarted
[DEBUG] [11/25/2013 12:56:43.161] [a-akka.actor.default-dispatcher-3] [akka://a/system/transports/akkaprotocolmanager.tcp0] now supervising Actor[akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-8#453869686]
[DEBUG] [11/25/2013 12:56:43.163] [a-akka.actor.default-dispatcher-3] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-8] started (akka.remote.transport.ProtocolStateActor@26e0b66e)
[ERROR] [11/25/2013 12:56:43.163] [a-akka.actor.default-dispatcher-2] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] AssociationError [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]: Error [Association failed with [akka.tcp://a@127.0.0.1:9998]] [
akka.remote.EndpointAssociationException: Association failed with [akka.tcp://a@127.0.0.1:9998]
Caused by: akka.remote.transport.netty.NettyTransport$$anonfun$associate$1$$anon$2: Connection refused: /127.0.0.1:9998
]
[DEBUG] [11/25/2013 12:56:43.163] [a-akka.actor.default-dispatcher-15] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] Disassociated [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]
[DEBUG] [11/25/2013 12:56:43.164] [a-akka.actor.default-dispatcher-3] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-8] stopped
[DEBUG] [11/25/2013 12:56:43.165] [a-akka.actor.default-dispatcher-15] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] stopped
[DEBUG] [11/25/2013 12:56:44.183] [a-akka.actor.default-dispatcher-15] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0] now supervising Actor[akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter#1473452303]
[DEBUG] [11/25/2013 12:56:44.184] [a-akka.actor.default-dispatcher-20] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] started (akka.remote.EndpointWriter@18c52987)
[DEBUG] [11/25/2013 12:56:44.184] [a-akka.actor.default-dispatcher-20] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] now monitoring Actor[akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0#1071532253]
[DEBUG] [11/25/2013 12:56:44.186] [a-akka.actor.default-dispatcher-15] [akka://a/system/transports/akkaprotocolmanager.tcp0] now supervising Actor[akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-9#-1516909005]
[DEBUG] [11/25/2013 12:56:44.187] [a-akka.actor.default-dispatcher-15] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-9] started (akka.remote.transport.ProtocolStateActor@2720c851)
[ERROR] [11/25/2013 12:56:44.189] [a-akka.actor.default-dispatcher-17] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] AssociationError [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]: Error [Association failed with [akka.tcp://a@127.0.0.1:9998]] [
akka.remote.EndpointAssociationException: Association failed with [akka.tcp://a@127.0.0.1:9998]
Caused by: akka.remote.transport.netty.NettyTransport$$anonfun$associate$1$$anon$2: Connection refused: /127.0.0.1:9998
]
[DEBUG] [11/25/2013 12:56:44.189] [a-akka.actor.default-dispatcher-14] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] restarting
[DEBUG] [11/25/2013 12:56:44.189] [a-akka.actor.default-dispatcher-14] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] Disassociated [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]
[DEBUG] [11/25/2013 12:56:44.190] [a-akka.actor.default-dispatcher-14] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] restarted
[DEBUG] [11/25/2013 12:56:44.192] [a-akka.actor.default-dispatcher-2] [akka://a/system/transports/akkaprotocolmanager.tcp0] now supervising Actor[akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-10#1609339668]
[DEBUG] [11/25/2013 12:56:44.189] [a-akka.actor.default-dispatcher-18] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-9] stopped
[DEBUG] [11/25/2013 12:56:44.193] [a-akka.actor.default-dispatcher-15] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-10] started (akka.remote.transport.ProtocolStateActor@5936ca2b)
[ERROR] [11/25/2013 12:56:44.193] [a-akka.actor.default-dispatcher-2] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] AssociationError [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]: Error [Association failed with [akka.tcp://a@127.0.0.1:9998]] [
akka.remote.EndpointAssociationException: Association failed with [akka.tcp://a@127.0.0.1:9998]
Caused by: akka.remote.transport.netty.NettyTransport$$anonfun$associate$1$$anon$2: Connection refused: /127.0.0.1:9998
]
[DEBUG] [11/25/2013 12:56:44.193] [a-akka.actor.default-dispatcher-13] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] restarting
[DEBUG] [11/25/2013 12:56:44.193] [a-akka.actor.default-dispatcher-13] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] Disassociated [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]
[DEBUG] [11/25/2013 12:56:44.194] [a-akka.actor.default-dispatcher-13] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] restarted
[DEBUG] [11/25/2013 12:56:44.195] [a-akka.actor.default-dispatcher-13] [akka://a/system/transports/akkaprotocolmanager.tcp0] now supervising Actor[akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-11#1202058178]
[DEBUG] [11/25/2013 12:56:44.195] [a-akka.actor.default-dispatcher-13] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-11] started (akka.remote.transport.ProtocolStateActor@576c5ee1)
[DEBUG] [11/25/2013 12:56:44.196] [a-akka.actor.default-dispatcher-20] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-10] stopped
[DEBUG] [11/25/2013 12:56:44.200] [a-akka.actor.default-dispatcher-18] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-11] stopped
[ERROR] [11/25/2013 12:56:44.200] [a-akka.actor.default-dispatcher-16] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] AssociationError [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]: Error [Association failed with [akka.tcp://a@127.0.0.1:9998]] [
akka.remote.EndpointAssociationException: Association failed with [akka.tcp://a@127.0.0.1:9998]
Caused by: akka.remote.transport.netty.NettyTransport$$anonfun$associate$1$$anon$2: Connection refused: /127.0.0.1:9998
]
[DEBUG] [11/25/2013 12:56:44.200] [a-akka.actor.default-dispatcher-3] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] restarting
[DEBUG] [11/25/2013 12:56:44.200] [a-akka.actor.default-dispatcher-3] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] Disassociated [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]
[DEBUG] [11/25/2013 12:56:44.200] [a-akka.actor.default-dispatcher-3] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] restarted
[DEBUG] [11/25/2013 12:56:44.203] [a-akka.actor.default-dispatcher-19] [akka://a/system/transports/akkaprotocolmanager.tcp0] now supervising Actor[akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-12#1112817145]
[DEBUG] [11/25/2013 12:56:44.203] [a-akka.actor.default-dispatcher-3] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-12] started (akka.remote.transport.ProtocolStateActor@58fc2912)
[DEBUG] [11/25/2013 12:56:44.204] [a-akka.actor.default-dispatcher-20] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-12] stopped
[ERROR] [11/25/2013 12:56:44.204] [a-akka.actor.default-dispatcher-3] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] AssociationError [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]: Error [Association failed with [akka.tcp://a@127.0.0.1:9998]] [
akka.remote.EndpointAssociationException: Association failed with [akka.tcp://a@127.0.0.1:9998]
Caused by: akka.remote.transport.netty.NettyTransport$$anonfun$associate$1$$anon$2: Connection refused: /127.0.0.1:9998
]
[DEBUG] [11/25/2013 12:56:44.204] [a-akka.actor.default-dispatcher-19] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] Disassociated [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]
[DEBUG] [11/25/2013 12:56:44.204] [a-akka.actor.default-dispatcher-19] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] stopped
[DEBUG] [11/25/2013 12:56:44.205] [a-akka.actor.default-dispatcher-16] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0] now supervising Actor[akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter#46139219]
[DEBUG] [11/25/2013 12:56:44.205] [a-akka.actor.default-dispatcher-19] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] started (akka.remote.EndpointWriter@353116ab)
[DEBUG] [11/25/2013 12:56:44.206] [a-akka.actor.default-dispatcher-19] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] now monitoring Actor[akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0#1071532253]
[DEBUG] [11/25/2013 12:56:44.207] [a-akka.actor.default-dispatcher-18] [akka://a/system/transports/akkaprotocolmanager.tcp0] now supervising Actor[akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-13#1615432600]
[DEBUG] [11/25/2013 12:56:44.207] [a-akka.actor.default-dispatcher-19] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-13] started (akka.remote.transport.ProtocolStateActor@29c74fd5)
[ERROR] [11/25/2013 12:56:44.211] [a-akka.actor.default-dispatcher-19] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] AssociationError [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]: Error [Association failed with [akka.tcp://a@127.0.0.1:9998]] [
akka.remote.EndpointAssociationException: Association failed with [akka.tcp://a@127.0.0.1:9998]
Caused by: akka.remote.transport.netty.NettyTransport$$anonfun$associate$1$$anon$2: Connection refused: /127.0.0.1:9998
]
[DEBUG] [11/25/2013 12:56:44.211] [a-akka.actor.default-dispatcher-19] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] restarting
[DEBUG] [11/25/2013 12:56:44.211] [a-akka.actor.default-dispatcher-20] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-13] stopped
[DEBUG] [11/25/2013 12:56:44.211] [a-akka.actor.default-dispatcher-19] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] Disassociated [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]
[DEBUG] [11/25/2013 12:56:44.212] [a-akka.actor.default-dispatcher-19] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] restarted
[DEBUG] [11/25/2013 12:56:44.213] [a-akka.actor.default-dispatcher-18] [akka://a/system/transports/akkaprotocolmanager.tcp0] now supervising Actor[akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-14#-1732661054]
[DEBUG] [11/25/2013 12:56:44.213] [a-akka.actor.default-dispatcher-16] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-14] started (akka.remote.transport.ProtocolStateActor@7cb32c0e)
[DEBUG] [11/25/2013 12:56:44.215] [a-akka.actor.default-dispatcher-20] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-14] stopped
[ERROR] [11/25/2013 12:56:44.215] [a-akka.actor.default-dispatcher-16] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] AssociationError [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]: Error [Association failed with [akka.tcp://a@127.0.0.1:9998]] [
akka.remote.EndpointAssociationException: Association failed with [akka.tcp://a@127.0.0.1:9998]
Caused by: akka.remote.transport.netty.NettyTransport$$anonfun$associate$1$$anon$2: Connection refused: /127.0.0.1:9998
]
[DEBUG] [11/25/2013 12:56:44.215] [a-akka.actor.default-dispatcher-19] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] restarting
[DEBUG] [11/25/2013 12:56:44.215] [a-akka.actor.default-dispatcher-19] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] Disassociated [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]
[DEBUG] [11/25/2013 12:56:44.215] [a-akka.actor.default-dispatcher-19] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] restarted
[DEBUG] [11/25/2013 12:56:44.217] [a-akka.actor.default-dispatcher-20] [akka://a/system/transports/akkaprotocolmanager.tcp0] now supervising Actor[akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-15#232327251]
[DEBUG] [11/25/2013 12:56:44.217] [a-akka.actor.default-dispatcher-16] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-15] started (akka.remote.transport.ProtocolStateActor@195e53b7)
[DEBUG] [11/25/2013 12:56:44.218] [a-akka.actor.default-dispatcher-19] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-15] stopped
[ERROR] [11/25/2013 12:56:44.218] [a-akka.actor.default-dispatcher-16] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] AssociationError [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]: Error [Association failed with [akka.tcp://a@127.0.0.1:9998]] [
akka.remote.EndpointAssociationException: Association failed with [akka.tcp://a@127.0.0.1:9998]
Caused by: akka.remote.transport.netty.NettyTransport$$anonfun$associate$1$$anon$2: Connection refused: /127.0.0.1:9998
]
[DEBUG] [11/25/2013 12:56:44.218] [a-akka.actor.default-dispatcher-16] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] restarting
[DEBUG] [11/25/2013 12:56:44.218] [a-akka.actor.default-dispatcher-16] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] Disassociated [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]
[DEBUG] [11/25/2013 12:56:44.219] [a-akka.actor.default-dispatcher-16] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] restarted
[DEBUG] [11/25/2013 12:56:44.220] [a-akka.actor.default-dispatcher-19] [akka://a/system/transports/akkaprotocolmanager.tcp0] now supervising Actor[akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-16#-316198838]
[DEBUG] [11/25/2013 12:56:44.220] [a-akka.actor.default-dispatcher-3] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-16] started (akka.remote.transport.ProtocolStateActor@4fc1f243)
[DEBUG] [11/25/2013 12:56:44.221] [a-akka.actor.default-dispatcher-19] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-16] stopped
[ERROR] [11/25/2013 12:56:44.221] [a-akka.actor.default-dispatcher-16] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] AssociationError [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]: Error [Association failed with [akka.tcp://a@127.0.0.1:9998]] [
akka.remote.EndpointAssociationException: Association failed with [akka.tcp://a@127.0.0.1:9998]
Caused by: akka.remote.transport.netty.NettyTransport$$anonfun$associate$1$$anon$2: Connection refused: /127.0.0.1:9998
]
[DEBUG] [11/25/2013 12:56:44.221] [a-akka.actor.default-dispatcher-20] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] Disassociated [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]
[DEBUG] [11/25/2013 12:56:44.221] [a-akka.actor.default-dispatcher-20] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] stopped
[DEBUG] [11/25/2013 12:56:45.223] [a-akka.actor.default-dispatcher-15] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0] now supervising Actor[akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter#-1584826493]
[DEBUG] [11/25/2013 12:56:45.223] [a-akka.actor.default-dispatcher-16] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] started (akka.remote.EndpointWriter@27976c8e)
[DEBUG] [11/25/2013 12:56:45.224] [a-akka.actor.default-dispatcher-16] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] now monitoring Actor[akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0#1071532253]
[DEBUG] [11/25/2013 12:56:45.225] [a-akka.actor.default-dispatcher-15] [akka://a/system/transports/akkaprotocolmanager.tcp0] now supervising Actor[akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-17#2146233524]
[DEBUG] [11/25/2013 12:56:45.226] [a-akka.actor.default-dispatcher-19] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-17] started (akka.remote.transport.ProtocolStateActor@43b6cdbc)
[DEBUG] [11/25/2013 12:56:45.229] [a-akka.actor.default-dispatcher-16] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-17] stopped
[ERROR] [11/25/2013 12:56:45.229] [a-akka.actor.default-dispatcher-19] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] AssociationError [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]: Error [Association failed with [akka.tcp://a@127.0.0.1:9998]] [
akka.remote.EndpointAssociationException: Association failed with [akka.tcp://a@127.0.0.1:9998]
Caused by: akka.remote.transport.netty.NettyTransport$$anonfun$associate$1$$anon$2: Connection refused: /127.0.0.1:9998
]
[DEBUG] [11/25/2013 12:56:45.230] [a-akka.actor.default-dispatcher-3] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] restarting
[DEBUG] [11/25/2013 12:56:45.230] [a-akka.actor.default-dispatcher-3] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] Disassociated [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]
[DEBUG] [11/25/2013 12:56:45.231] [a-akka.actor.default-dispatcher-3] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] restarted
[DEBUG] [11/25/2013 12:56:45.233] [a-akka.actor.default-dispatcher-20] [akka://a/system/transports/akkaprotocolmanager.tcp0] now supervising Actor[akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-18#-869357513]
[DEBUG] [11/25/2013 12:56:45.233] [a-akka.actor.default-dispatcher-16] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-18] started (akka.remote.transport.ProtocolStateActor@6708c0f5)
[DEBUG] [11/25/2013 12:56:45.235] [a-akka.actor.default-dispatcher-19] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-18] stopped
[ERROR] [11/25/2013 12:56:45.236] [a-akka.actor.default-dispatcher-20] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] AssociationError [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]: Error [Association failed with [akka.tcp://a@127.0.0.1:9998]] [
akka.remote.EndpointAssociationException: Association failed with [akka.tcp://a@127.0.0.1:9998]
Caused by: akka.remote.transport.netty.NettyTransport$$anonfun$associate$1$$anon$2: Connection refused: /127.0.0.1:9998
]
[DEBUG] [11/25/2013 12:56:45.236] [a-akka.actor.default-dispatcher-20] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] restarting
[DEBUG] [11/25/2013 12:56:45.236] [a-akka.actor.default-dispatcher-20] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] Disassociated [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]
[DEBUG] [11/25/2013 12:56:45.237] [a-akka.actor.default-dispatcher-20] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] restarted
[DEBUG] [11/25/2013 12:56:45.238] [a-akka.actor.default-dispatcher-16] [akka://a/system/transports/akkaprotocolmanager.tcp0] now supervising Actor[akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-19#-581898456]
[DEBUG] [11/25/2013 12:56:45.238] [a-akka.actor.default-dispatcher-20] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-19] started (akka.remote.transport.ProtocolStateActor@e807c3)
[ERROR] [11/25/2013 12:56:45.241] [a-akka.actor.default-dispatcher-19] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] AssociationError [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]: Error [Association failed with [akka.tcp://a@127.0.0.1:9998]] [
akka.remote.EndpointAssociationException: Association failed with [akka.tcp://a@127.0.0.1:9998]
Caused by: akka.remote.transport.netty.NettyTransport$$anonfun$associate$1$$anon$2: Connection refused: /127.0.0.1:9998
]
[DEBUG] [11/25/2013 12:56:45.241] [a-akka.actor.default-dispatcher-19] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] restarting
[DEBUG] [11/25/2013 12:56:45.241] [a-akka.actor.default-dispatcher-19] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] Disassociated [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]
[DEBUG] [11/25/2013 12:56:45.242] [a-akka.actor.default-dispatcher-15] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-19] stopped
[DEBUG] [11/25/2013 12:56:45.242] [a-akka.actor.default-dispatcher-19] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] restarted
[DEBUG] [11/25/2013 12:56:45.243] [a-akka.actor.default-dispatcher-16] [akka://a/system/transports/akkaprotocolmanager.tcp0] now supervising Actor[akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-20#1584061054]
[DEBUG] [11/25/2013 12:56:45.243] [a-akka.actor.default-dispatcher-19] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-20] started (akka.remote.transport.ProtocolStateActor@4ae4230)
[DEBUG] [11/25/2013 12:56:45.244] [a-akka.actor.default-dispatcher-19] [akka://a/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2Fa%40127.0.0.1%3A9998-20] stopped
[ERROR] [11/25/2013 12:56:45.245] [a-akka.actor.default-dispatcher-16] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] AssociationError [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]: Error [Association failed with [akka.tcp://a@127.0.0.1:9998]] [
akka.remote.EndpointAssociationException: Association failed with [akka.tcp://a@127.0.0.1:9998]
Caused by: akka.remote.transport.netty.NettyTransport$$anonfun$associate$1$$anon$2: Connection refused: /127.0.0.1:9998
]
[DEBUG] [11/25/2013 12:56:45.245] [a-akka.actor.default-dispatcher-16] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] Disassociated [akka.tcp://a@127.0.0.1:9999] -> [akka.tcp://a@127.0.0.1:9998]
[DEBUG] [11/25/2013 12:56:45.245] [a-akka.actor.default-dispatcher-16] [akka://a/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fa%40127.0.0.1%3A9998-0/endpointWriter] stopped
  C-c C-c^C

Testing.scala

package org.rm



import akka.actor.{Props, ActorRef, Actor, ActorSystem}
import com.typesafe.config.ConfigFactory
import scala.util.Random
import scala.collection.mutable.LinkedList
import scala.reflect.ClassTag
import scala.collection.mutable
import akka.actor.Terminated
import akka.remote.{AssociationErrorEvent, DisassociatedEvent, RemotingLifecycleEvent}

case class SubscribeReceiver(receiverActor: ActorRef)

case class UnsubscribeReceiver(receiverActor: ActorRef)

case object Ack

object Receiver {
  def main(args: Array[String]) {

    val a = ActorSystem("a", ConfigFactory.parseString(
      """
        |akka.loglevel = "DEBUG"
        |akka.actor.debug.lifecycle = on
        |akka.remote.log-sent-messages = on
        |akka.log-dead-letters = 100
        |akka.daemonic = on
        |akka.remote.watch-failure-detector.acceptable-heartbeat-pause = 20 s
        |akka.remote.watch-failure-detector.threshold = 12.0
        |akka.remote.transport-failure-detector.heartbeat-interval = 10 s
        |akka.remote.transport-failure-detector.acceptable-heartbeat-pause = 60 s
        |akka.remote.transport-failure-detector.threshold = 12.0
        |akka.actor.provider = "akka.remote.RemoteActorRefProvider"
        |akka.remote.netty.tcp.connection-timeout = 120 s
        |akka.remote.netty.tcp.transport-class = "akka.remote.transport.netty.NettyTransport"
        |akka.remote.netty.tcp.host = "127.0.0.1"
        |akka.remote.netty.tcp.port = 9998
      """.stripMargin))

    val feeder = a.actorOf(Props(new ReceiverActor("akka.tcp://a@127.0.0.1:9999/user/FeederActor")), "ReceiverActor")

    println("Receiver started as:" + feeder)

    a.awaitTermination()
  }
}

class ReceiverActor[T: ClassTag](urlOfPublisher: String)
  extends Actor {

  lazy private val remotePublisher = context.actorSelection(urlOfPublisher)

  override def preStart() = {
    remotePublisher ! SubscribeReceiver(context.self)
    context.system.eventStream.subscribe(self, classOf[RemotingLifecycleEvent])
  }
  var toUnwatch: ActorRef = _
  def receive = {
    case Terminated(actor) ⇒ println("Terminating....")
      context.stop(toUnwatch)
      context.unwatch(toUnwatch)

    case DisassociatedEvent(_, address, _) => 
      context.stop(toUnwatch)
      context.unwatch(toUnwatch)
      println("Diss....")

    case Ack ⇒ println(s"Watching....$sender")
      context.watch(sender)
      toUnwatch = sender

    case msg ⇒ println(msg)
  }

  override def postStop() = remotePublisher ! UnsubscribeReceiver(context.self)

}

class FeederActor extends Actor {

  val rand = new Random()
  var receivers: mutable.LinkedList[ActorRef] = new mutable.LinkedList[ActorRef]()

  val strings: Array[String] = Array("words ", "may ", "count ")
  var i =0
  def makeMessage(): String = {
    i+=1
    val x = rand.nextInt(3)
    strings(x) + strings(2 - x) + i
  }
  override def preStart() {
          context.system.eventStream.subscribe(self, classOf[RemotingLifecycleEvent])
  }
  /*
   * A thread to generate random messages
   */
  val temp =  new Thread() {
    override def run() {
      while (true) {
        Thread.sleep(500)
        receivers.foreach(_ ! makeMessage)
      }
    }
  }
  temp.start()

  def receive: Receive = {

    case DisassociatedEvent(_, address, _) => 
      receivers.foreach{x => 
        context.stop(x)
        context.unwatch(x)}
      temp.interrupt() // Stop sending messages

    case Terminated(receiverActor) ⇒  receivers = receivers.dropWhile(x => x eq receiverActor)
            temp.interrupt() // Stop sending messages

    case SubscribeReceiver(receiverActor: ActorRef) =>
      context.watch(sender)
      sender ! Ack
      println("received subscribe from %s".format(receiverActor.toString))
      receivers = mutable.LinkedList(receiverActor) ++ receivers

    case UnsubscribeReceiver(receiverActor: ActorRef) =>
      println("received unsubscribe from %s".format(receiverActor.toString))
      receivers = receivers.dropWhile(x => x eq receiverActor)

  }
}

object Sender {
  def main(args: Array[String]) {

    val a = ActorSystem("a", ConfigFactory.parseString(
      """
        |akka.loglevel = "DEBUG"
        |akka.actor.debug.lifecycle = on
        |akka.remote.log-sent-messages = on
        |akka.log-dead-letters = 100
        |akka.daemonic = on
        |akka.remote.watch-failure-detector.acceptable-heartbeat-pause = 20 s
        |akka.remote.watch-failure-detector.threshold = 12.0
        |akka.remote.transport-failure-detector.heartbeat-interval = 10 s
        |akka.remote.transport-failure-detector.acceptable-heartbeat-pause = 60 s
        |akka.remote.transport-failure-detector.threshold = 12.0
        |akka.actor.provider = "akka.remote.RemoteActorRefProvider"
        |akka.remote.netty.tcp.connection-timeout = 120 s
        |akka.remote.netty.tcp.transport-class = "akka.remote.transport.netty.NettyTransport"
        |akka.remote.netty.tcp.host = "127.0.0.1"
        |akka.remote.netty.tcp.port = 9999
      """.stripMargin))

    val feeder = a.actorOf(Props[FeederActor], "FeederActor")

    println("Feeder started as:" + feeder)

    a.awaitTermination()
  }
}