07:43:48,962 PM [test-akka.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started 07:43:48,984 PM [test-akka.actor.default-dispatcher-5] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [akka://test@127.0.0.1:2550] with UID [5020660551178670769] 07:43:48,986 PM [test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2550] - Starting up, Akka version [2.6.21] ... 07:43:48,992 PM [test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2550] - Registered cluster JMX MBean [akka:type=Cluster] 07:43:48,992 PM [test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2550] - Started up successfully 07:43:48,994 PM [test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2550] - No downing-provider-class configured, manual cluster downing required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#downing 07:43:48,994 PM [test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2550] - No seed-nodes configured, manual cluster join required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#joining 07:43:49,41 PM [test-akka.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started 07:43:49,59 PM [test-akka.actor.default-dispatcher-5] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [akka://test@127.0.0.1:2552] with UID [-5657254664052346300] 07:43:49,60 PM [test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2552] - Starting up, Akka version [2.6.21] ... 07:43:49,63 PM [test-akka.actor.default-dispatcher-5] [WARN] Cluster - Could not register Cluster JMX MBean with name=akka:type=Cluster as it is already registered. If you are running multiple clusters in the same JVM, set 'akka.cluster.jmx.multi-mbeans-in-same-jvm = on' in config 07:43:49,63 PM [test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2552] - Started up successfully 07:43:49,65 PM [test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2552] - No downing-provider-class configured, manual cluster downing required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#downing 07:43:49,65 PM [test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2552] - No seed-nodes configured, manual cluster join required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#joining 07:43:49,166 PM [test-akka.actor.default-dispatcher-5] [DEBUG] NetconfNodeManagerTest$TestMasterActor - Actor created TestActor[akka://test/user/akka:test@127.0.0.1:2552_device] 07:43:49,167 PM [test-akka.actor.default-dispatcher-5] [INFO] EmptyLocalActorRef - akkaDeadLetter Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[akka://test/user/akka:test@127.0.0.1:2552_device] to Actor[akka://test/user/termination-monitor] was not delivered. [1] dead letters encountered. If this is not an expected behavior then Actor[akka://test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'. 07:43:49,248 PM [main] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Operational state for node Uri{value=device} created: Node{nodeId=Uri{value=device}, augmentation=[NetconfNodeAugment{netconfNode=NetconfNode{clusteredConnectionStatus=ClusteredConnectionStatus{netconfMasterNode=akka://test@127.0.0.1:2552}, connectionStatus=Connected, host=Host{ipAddress=IpAddress{ipv4Address=Ipv4Address{value=127.0.0.1}}}, port=PortNumber{value=9999}}}]} 07:43:49,249 PM [test-akka.actor.default-dispatcher-5] [DEBUG] NetconfNodeActor - Actor created Actor[akka://test/user/$a#515199576] 07:43:49,250 PM [main] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Slave actor created with name Actor[akka://test/user/$a#515199576] 07:43:49,250 PM [main] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Sending AskForMasterMountPoint [slaveActorRef=Actor[akka://test/user/$a#515199576]] message to master ActorSelection[Anchor(akka://test@127.0.0.1:2552/), Path(/user/akka:test@127.0.0.1:2552_device)] 07:43:49,265 PM [test-akka.actor.default-dispatcher-5] [INFO] EmptyLocalActorRef - akkaDeadLetter Message [org.opendaylight.controller.cluster.common.actor.Monitor] from Actor[akka://test/user/$a#515199576] to Actor[akka://test/user/termination-monitor] was not delivered. [1] dead letters encountered. If this is not an expected behavior then Actor[akka://test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'. 07:43:49,332 PM [test-akka.actor.default-dispatcher-5] [DEBUG] NetconfNodeManagerTest$TestMasterActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: received message AskForMasterMountPoint [slaveActorRef=Actor[akka://test@127.0.0.1:2550/user/$a#515199576]] 07:43:49,332 PM [test-akka.actor.default-dispatcher-5] [WARN] NetconfNodeManagerTest$TestMasterActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Received AskForMasterMountPoint [slaveActorRef=Actor[akka://test@127.0.0.1:2550/user/$a#515199576]] but we don't appear to be the master 07:43:49,343 PM [test-akka.actor.default-dispatcher-11] [ERROR] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Failed to send message AskForMasterMountPoint [slaveActorRef=Actor[akka://test/user/$a#515199576]] to ActorSelection[Anchor(akka://test@127.0.0.1:2552/), Path(/user/akka:test@127.0.0.1:2552_device)]. Slave mount point could not be created org.opendaylight.netconf.topology.singleton.messages.NotMasterException: Actor TestActor[akka://test/user/akka:test@127.0.0.1:2552_device] is not the current master at org.opendaylight.netconf.topology.singleton.impl.actors.NetconfNodeActor.handleReceive(NetconfNodeActor.java:141) at org.opendaylight.netconf.topology.singleton.impl.NetconfNodeManagerTest$TestMasterActor.handleReceive(NetconfNodeManagerTest.java:413) at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) at scala.PartialFunction.applyOrElse(PartialFunction.scala:214) at scala.PartialFunction.applyOrElse$(PartialFunction.scala:213) at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:269) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:270) at akka.actor.Actor.aroundReceive(Actor.scala:537) at akka.actor.Actor.aroundReceive$(Actor.scala:535) at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220) at akka.actor.ActorCell.receiveMessage(ActorCell.scala:579) at akka.actor.ActorCell.invoke(ActorCell.scala:547) at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) at akka.dispatch.Mailbox.run(Mailbox.scala:231) at akka.dispatch.Mailbox.exec(Mailbox.scala:243) at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:387) at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1312) at java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1843) at java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1808) at java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:188) 07:43:50,269 PM [test-akka.actor.default-dispatcher-5] [DEBUG] NetconfNodeManagerTest$TestMasterActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: received message org.opendaylight.netconf.topology.singleton.messages.CreateInitialMasterActorData@a7b597b 07:43:50,271 PM [test-akka.actor.default-dispatcher-5] [DEBUG] NetconfNodeManagerTest$TestMasterActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Master is ready. 07:43:50,273 PM [main] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Operational state for node Uri{value=device} created: Node{nodeId=Uri{value=device}, augmentation=[NetconfNodeAugment{netconfNode=NetconfNode{clusteredConnectionStatus=ClusteredConnectionStatus{netconfMasterNode=akka://test@127.0.0.1:2552}, connectionStatus=Connected, host=Host{ipAddress=IpAddress{ipv4Address=Ipv4Address{value=127.0.0.1}}}, port=PortNumber{value=9999}}}]} 07:43:50,274 PM [test-akka.actor.default-dispatcher-11] [DEBUG] NetconfNodeActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: received message org.opendaylight.netconf.topology.singleton.messages.RefreshSlaveActor@5030b497 07:43:50,274 PM [main] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Sending AskForMasterMountPoint [slaveActorRef=Actor[akka://test/user/$a#515199576]] message to master ActorSelection[Anchor(akka://test@127.0.0.1:2552/), Path(/user/akka:test@127.0.0.1:2552_device)] 07:43:50,283 PM [test-akka.actor.default-dispatcher-5] [DEBUG] NetconfNodeManagerTest$TestMasterActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: received message AskForMasterMountPoint [slaveActorRef=Actor[akka://test@127.0.0.1:2550/user/$a#515199576]] 07:43:50,283 PM [test-akka.actor.default-dispatcher-5] [DEBUG] NetconfNodeManagerTest$TestMasterActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Sending RegisterMountPoint reply to Actor[akka://test@127.0.0.1:2550/user/$a#515199576] 07:43:50,291 PM [test-akka.actor.default-dispatcher-11] [DEBUG] NetconfNodeActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: received message RegisterMountPoint [allSourceIdentifiers=[SourceIdentifier [testID]], masterActorRef=Actor[akka://test@127.0.0.1:2552/user/akka:test@127.0.0.1:2552_device]] 07:43:50,293 PM [test-akka.actor.default-dispatcher-10] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: AskForMasterMountPoint [slaveActorRef=Actor[akka://test/user/$a#515199576]] message to ActorSelection[Anchor(akka://test@127.0.0.1:2552/), Path(/user/akka:test@127.0.0.1:2552_device)] succeeded 07:43:51,316 PM [test-akka.actor.default-dispatcher-11] [WARN] NetconfNodeActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Failed to resolve schema context - retrying... org.opendaylight.yangtools.yang.model.repo.api.MissingSchemaSourceException: All available providers exhausted at org.opendaylight.yangtools.yang.model.repo.spi.AbstractSchemaRepository.lambda$fetchSource$0(AbstractSchemaRepository.java:72) at com.google.common.util.concurrent.AbstractCatchingFuture$AsyncCatchingFuture.doFallback(AbstractCatchingFuture.java:210) at com.google.common.util.concurrent.AbstractCatchingFuture$AsyncCatchingFuture.doFallback(AbstractCatchingFuture.java:197) at com.google.common.util.concurrent.AbstractCatchingFuture.run(AbstractCatchingFuture.java:139) at com.google.common.util.concurrent.DirectExecutor.execute(DirectExecutor.java:31) at com.google.common.util.concurrent.AbstractFuture.executeListener(AbstractFuture.java:1299) at com.google.common.util.concurrent.AbstractFuture.complete(AbstractFuture.java:1060) at com.google.common.util.concurrent.AbstractFuture.setException(AbstractFuture.java:810) at com.google.common.util.concurrent.AbstractTransformFuture.run(AbstractTransformFuture.java:111) at com.google.common.util.concurrent.DirectExecutor.execute(DirectExecutor.java:31) at com.google.common.util.concurrent.AbstractFuture.executeListener(AbstractFuture.java:1299) at com.google.common.util.concurrent.AbstractFuture.complete(AbstractFuture.java:1060) at com.google.common.util.concurrent.AbstractFuture.setException(AbstractFuture.java:810) at com.google.common.util.concurrent.AbstractCatchingFuture.run(AbstractCatchingFuture.java:142) at com.google.common.util.concurrent.DirectExecutor.execute(DirectExecutor.java:31) at com.google.common.util.concurrent.AbstractFuture.executeListener(AbstractFuture.java:1299) at com.google.common.util.concurrent.AbstractFuture.complete(AbstractFuture.java:1060) at com.google.common.util.concurrent.AbstractFuture.setException(AbstractFuture.java:810) at com.google.common.util.concurrent.SettableFuture.setException(SettableFuture.java:55) at org.opendaylight.controller.cluster.schema.provider.impl.RemoteSchemaProvider$1.onComplete(RemoteSchemaProvider.java:50) at org.opendaylight.controller.cluster.schema.provider.impl.RemoteSchemaProvider$1.onComplete(RemoteSchemaProvider.java:43) at akka.dispatch.OnComplete.internal(Future.scala:299) at akka.dispatch.OnComplete.internal(Future.scala:297) at akka.dispatch.japi$CallbackBridge.apply(Future.scala:224) at akka.dispatch.japi$CallbackBridge.apply(Future.scala:221) at scala.concurrent.impl.Promise$Transformation.run(Promise.scala:484) at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:63) at akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:100) at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.scala:18) at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:94) at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:100) at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49) at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48) at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:387) at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1312) at java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1843) at java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1808) at java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:188) Caused by: org.opendaylight.yangtools.yang.model.repo.api.MissingSchemaSourceException: All available providers exhausted at org.opendaylight.yangtools.yang.model.repo.spi.AbstractSchemaRepository.lambda$fetchSource$0(AbstractSchemaRepository.java:72) at com.google.common.util.concurrent.AbstractCatchingFuture$AsyncCatchingFuture.doFallback(AbstractCatchingFuture.java:210) at com.google.common.util.concurrent.AbstractCatchingFuture$AsyncCatchingFuture.doFallback(AbstractCatchingFuture.java:197) at com.google.common.util.concurrent.AbstractCatchingFuture.run(AbstractCatchingFuture.java:139) ... 24 more Caused by: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka://test@127.0.0.1:2552/user/akka:test@127.0.0.1:2552_device]] after [1000 ms]. Message of type [org.opendaylight.netconf.topology.singleton.messages.YangTextSchemaSourceRequest]. A typical reason for `AskTimeoutException` is that the recipient actor didn't send a reply. 07:43:51,322 PM [test-akka.actor.default-dispatcher-5] [DEBUG] NetconfNodeManagerTest$TestMasterActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: received message YangTextSchemaSourceRequest [sourceIdentifier=SourceIdentifier [testID]] 07:43:51,323 PM [test-akka.actor.default-dispatcher-5] [DEBUG] NetconfNodeManagerTest$TestMasterActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: getSchemaSource for SourceIdentifier [testID] succeeded 07:43:51,334 PM [test-akka.actor.default-dispatcher-10] [INFO] NetconfNodeActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Schema context resolved: [ModuleEffectiveStatementImpl{argument=Unqualified{localName=testID}}] - registering slave mount point 07:43:51,335 PM [test-akka.actor.default-dispatcher-10] [INFO] SlaveSalFacade - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Slave mount point registered. 07:43:51,337 PM [main] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Operational state for node Uri{value=device} created: Node{nodeId=Uri{value=device}, augmentation=[NetconfNodeAugment{netconfNode=NetconfNode{clusteredConnectionStatus=ClusteredConnectionStatus{netconfMasterNode=akka://test@127.0.0.1:2552}, connectionStatus=Connected, host=Host{ipAddress=IpAddress{ipv4Address=Ipv4Address{value=127.0.0.1}}}, port=PortNumber{value=9999}}}]} 07:43:51,338 PM [test-akka.actor.default-dispatcher-10] [DEBUG] NetconfNodeActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: received message org.opendaylight.netconf.topology.singleton.messages.RefreshSlaveActor@61b42b61 07:43:51,338 PM [main] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Sending AskForMasterMountPoint [slaveActorRef=Actor[akka://test/user/$a#515199576]] message to master ActorSelection[Anchor(akka://test@127.0.0.1:2552/), Path(/user/akka:test@127.0.0.1:2552_device)] 07:43:52,356 PM [test-akka.actor.default-dispatcher-10] [WARN] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Failed to send message to ActorSelection[Anchor(akka://test@127.0.0.1:2552/), Path(/user/akka:test@127.0.0.1:2552_device)] - retrying... akka.pattern.AskTimeoutException: Ask timed out on [ActorSelection[Anchor(akka://test@127.0.0.1:2552/), Path(/user/akka:test@127.0.0.1:2552_device)]] after [1000 ms]. Message of type [org.opendaylight.netconf.topology.singleton.messages.AskForMasterMountPoint]. A typical reason for `AskTimeoutException` is that the recipient actor didn't send a reply. 07:43:52,361 PM [test-akka.actor.default-dispatcher-5] [DEBUG] NetconfNodeManagerTest$TestMasterActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: received message AskForMasterMountPoint [slaveActorRef=Actor[akka://test@127.0.0.1:2550/user/$a#515199576]] 07:43:52,362 PM [test-akka.actor.default-dispatcher-5] [DEBUG] NetconfNodeManagerTest$TestMasterActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Sending RegisterMountPoint reply to Actor[akka://test@127.0.0.1:2550/user/$a#515199576] 07:43:52,366 PM [test-akka.actor.default-dispatcher-10] [DEBUG] NetconfNodeActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: received message RegisterMountPoint [allSourceIdentifiers=[SourceIdentifier [testID]], masterActorRef=Actor[akka://test@127.0.0.1:2552/user/akka:test@127.0.0.1:2552_device]] 07:43:52,367 PM [test-akka.actor.default-dispatcher-10] [INFO] SlaveSalFacade - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Slave mount point unregistered. 07:43:52,367 PM [test-akka.actor.default-dispatcher-10] [INFO] NetconfNodeActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Schema context resolved: [ModuleEffectiveStatementImpl{argument=Unqualified{localName=testID}}] - registering slave mount point 07:43:52,367 PM [test-akka.actor.default-dispatcher-11] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: AskForMasterMountPoint [slaveActorRef=Actor[akka://test/user/$a#515199576]] message to ActorSelection[Anchor(akka://test@127.0.0.1:2552/), Path(/user/akka:test@127.0.0.1:2552_device)] succeeded 07:43:52,368 PM [test-akka.actor.default-dispatcher-10] [INFO] SlaveSalFacade - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Slave mount point registered. 07:43:52,369 PM [main] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Sending poison pill to Actor[akka://test/user/$a#515199576] 07:43:52,369 PM [test-akka.actor.default-dispatcher-10] [INFO] SlaveSalFacade - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Slave mount point unregistered. 07:43:52,370 PM [test-akka.actor.default-dispatcher-10] [INFO] CoordinatedShutdown - Running CoordinatedShutdown with reason [ActorSystemTerminateReason] 07:43:52,372 PM [test-akka.actor.default-dispatcher-10] [INFO] LocalActorRef - akkaDeadLetter Message [akka.cluster.ClusterUserAction$Leave] to Actor[akka://test/system/cluster/core/daemon#-1775203138] was unhandled. [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'. 07:43:52,372 PM [test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2550] - Exiting completed 07:43:52,372 PM [test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2550] - Shutting down... 07:43:52,372 PM [test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2550] - Successfully shut down 07:43:52,375 PM [test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon. 07:43:52,375 PM [test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports. 07:43:52,384 PM [test-akka.actor.default-dispatcher-10] [WARN] Materializer - [outbound connection to [akka://test@127.0.0.1:2552], message stream] Upstream failed, cause: StreamTcpException: The connection has been aborted 07:43:52,384 PM [test-akka.actor.default-dispatcher-10] [WARN] Materializer - [outbound connection to [akka://test@127.0.0.1:2552], control stream] Upstream failed, cause: StreamTcpException: The connection has been aborted 07:43:52,386 PM [test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down. 07:43:52,397 PM [test-akka.actor.default-dispatcher-5] [INFO] CoordinatedShutdown - Running CoordinatedShutdown with reason [ActorSystemTerminateReason] 07:43:52,399 PM [test-akka.actor.default-dispatcher-5] [INFO] LocalActorRef - akkaDeadLetter Message [akka.cluster.ClusterUserAction$Leave] to Actor[akka://test/system/cluster/core/daemon#-589821512] was unhandled. [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'. 07:43:52,400 PM [test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2552] - Exiting completed 07:43:52,400 PM [test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2552] - Shutting down... 07:43:52,400 PM [test-akka.actor.default-dispatcher-5] [WARN] Cluster - Could not unregister Cluster JMX MBean with name=akka:type=Cluster as it was not found. If you are running multiple clusters in the same JVM, set 'akka.cluster.jmx.multi-mbeans-in-same-jvm = on' in config 07:43:52,400 PM [test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2552] - Successfully shut down 07:43:52,406 PM [test-akka.actor.default-dispatcher-21] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon. 07:43:52,406 PM [test-akka.actor.default-dispatcher-21] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports. 07:43:53,440 PM [test-akka.actor.default-dispatcher-21] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down. 07:43:53,473 PM [test-akka.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started 07:43:53,496 PM [test-akka.actor.default-dispatcher-5] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [akka://test@127.0.0.1:2550] with UID [1190122248100621344] 07:43:53,496 PM [test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2550] - Starting up, Akka version [2.6.21] ... 07:43:53,500 PM [test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2550] - Registered cluster JMX MBean [akka:type=Cluster] 07:43:53,501 PM [test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2550] - Started up successfully 07:43:53,503 PM [test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2550] - No downing-provider-class configured, manual cluster downing required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#downing 07:43:53,503 PM [test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2550] - No seed-nodes configured, manual cluster join required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#joining 07:43:53,540 PM [test-akka.actor.default-dispatcher-6] [INFO] Slf4jLogger - Slf4jLogger started 07:43:53,558 PM [test-akka.actor.default-dispatcher-6] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [akka://test@127.0.0.1:2552] with UID [-3633866411186420328] 07:43:53,559 PM [test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2552] - Starting up, Akka version [2.6.21] ... 07:43:53,563 PM [test-akka.actor.default-dispatcher-6] [WARN] Cluster - Could not register Cluster JMX MBean with name=akka:type=Cluster as it is already registered. If you are running multiple clusters in the same JVM, set 'akka.cluster.jmx.multi-mbeans-in-same-jvm = on' in config 07:43:53,563 PM [test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2552] - Started up successfully 07:43:53,565 PM [test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2552] - No downing-provider-class configured, manual cluster downing required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#downing 07:43:53,565 PM [test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2552] - No seed-nodes configured, manual cluster join required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#joining 07:43:53,615 PM [test-akka.actor.default-dispatcher-10] [DEBUG] NetconfNodeManagerTest$TestMasterActor - Actor created TestActor[akka://test/user/akka:test@127.0.0.1:2552_device] 07:43:53,617 PM [test-akka.actor.default-dispatcher-10] [INFO] EmptyLocalActorRef - akkaDeadLetter Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[akka://test/user/akka:test@127.0.0.1:2552_device] to Actor[akka://test/user/termination-monitor] was not delivered. [1] dead letters encountered. If this is not an expected behavior then Actor[akka://test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'. 07:43:53,632 PM [test-akka.actor.default-dispatcher-11] [DEBUG] NetconfNodeManagerTest$TestMasterActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: received message org.opendaylight.netconf.topology.singleton.messages.CreateInitialMasterActorData@e0d142a 07:43:53,633 PM [test-akka.actor.default-dispatcher-11] [DEBUG] NetconfNodeManagerTest$TestMasterActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Master is ready. 07:43:53,638 PM [main] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Registering data tree change listener on path DataObjectIdentifier[ @ urn.tbd.params.xml.ns.yang.network.topology.rev131021.NetworkTopology ... network.topology.Topology[TopologyKey{topologyId=Uri{value=topology-netconf}}] ... topology.Node[NodeKey{nodeId=Uri{value=device}}] ] 07:43:53,640 PM [main] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Operational state for node Uri{value=device} created: Node{nodeId=Uri{value=device}, augmentation=[NetconfNodeAugment{netconfNode=NetconfNode{clusteredConnectionStatus=ClusteredConnectionStatus{netconfMasterNode=akka://test@127.0.0.1:2552}, connectionStatus=Connected, host=Host{ipAddress=IpAddress{ipv4Address=Ipv4Address{value=127.0.0.1}}}, port=PortNumber{value=9999}}}]} 07:43:53,641 PM [main] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Slave actor created with name Actor[akka://test/user/$a#5242470] 07:43:53,641 PM [test-akka.actor.default-dispatcher-5] [DEBUG] NetconfNodeActor - Actor created Actor[akka://test/user/$a#5242470] 07:43:53,641 PM [main] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Sending AskForMasterMountPoint [slaveActorRef=Actor[akka://test/user/$a#5242470]] message to master ActorSelection[Anchor(akka://test@127.0.0.1:2552/), Path(/user/akka:test@127.0.0.1:2552_device)] 07:43:53,642 PM [test-akka.actor.default-dispatcher-10] [INFO] EmptyLocalActorRef - akkaDeadLetter Message [org.opendaylight.controller.cluster.common.actor.Monitor] from Actor[akka://test/user/$a#5242470] to Actor[akka://test/user/termination-monitor] was not delivered. [1] dead letters encountered. If this is not an expected behavior then Actor[akka://test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'. 07:43:53,691 PM [test-akka.actor.default-dispatcher-11] [DEBUG] NetconfNodeManagerTest$TestMasterActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: received message AskForMasterMountPoint [slaveActorRef=Actor[akka://test@127.0.0.1:2550/user/$a#5242470]] 07:43:53,691 PM [test-akka.actor.default-dispatcher-11] [DEBUG] NetconfNodeManagerTest$TestMasterActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Sending RegisterMountPoint reply to Actor[akka://test@127.0.0.1:2550/user/$a#5242470] 07:43:53,694 PM [test-akka.actor.default-dispatcher-10] [DEBUG] NetconfNodeActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: received message RegisterMountPoint [allSourceIdentifiers=[SourceIdentifier [testID]], masterActorRef=Actor[akka://test@127.0.0.1:2552/user/akka:test@127.0.0.1:2552_device]] 07:43:53,695 PM [test-akka.actor.default-dispatcher-10] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: AskForMasterMountPoint [slaveActorRef=Actor[akka://test/user/$a#5242470]] message to ActorSelection[Anchor(akka://test@127.0.0.1:2552/), Path(/user/akka:test@127.0.0.1:2552_device)] succeeded 07:43:53,696 PM [test-akka.actor.default-dispatcher-11] [DEBUG] NetconfNodeManagerTest$TestMasterActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: received message YangTextSchemaSourceRequest [sourceIdentifier=SourceIdentifier [testID]] 07:43:53,697 PM [test-akka.actor.default-dispatcher-11] [DEBUG] NetconfNodeManagerTest$TestMasterActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: getSchemaSource for SourceIdentifier [testID] succeeded 07:43:53,704 PM [test-akka.actor.default-dispatcher-10] [INFO] NetconfNodeActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Schema context resolved: [ModuleEffectiveStatementImpl{argument=Unqualified{localName=testID}}] - registering slave mount point 07:43:53,705 PM [test-akka.actor.default-dispatcher-10] [INFO] SlaveSalFacade - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Slave mount point registered. 07:43:53,711 PM [main] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Operational state for node Uri{value=device} deleted. 07:43:53,711 PM [main] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Sending message to unregister slave mountpoint to Actor[akka://test/user/$a#5242470] 07:43:53,712 PM [test-akka.actor.default-dispatcher-10] [DEBUG] NetconfNodeActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: received message org.opendaylight.netconf.topology.singleton.messages.UnregisterSlaveMountPoint@15173a0c 07:43:53,712 PM [test-akka.actor.default-dispatcher-10] [INFO] SlaveSalFacade - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Slave mount point unregistered. 07:43:53,723 PM [main] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Operational state for node Uri{value=device} created: Node{nodeId=Uri{value=device}, augmentation=[NetconfNodeAugment{netconfNode=NetconfNode{clusteredConnectionStatus=ClusteredConnectionStatus{netconfMasterNode=akka://test@127.0.0.1:2552}, connectionStatus=Connected, host=Host{ipAddress=IpAddress{ipv4Address=Ipv4Address{value=127.0.0.1}}}, port=PortNumber{value=9999}}}]} 07:43:53,723 PM [main] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Sending AskForMasterMountPoint [slaveActorRef=Actor[akka://test/user/$a#5242470]] message to master ActorSelection[Anchor(akka://test@127.0.0.1:2552/), Path(/user/akka:test@127.0.0.1:2552_device)] 07:43:53,724 PM [test-akka.actor.default-dispatcher-10] [DEBUG] NetconfNodeActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: received message org.opendaylight.netconf.topology.singleton.messages.RefreshSlaveActor@618f1472 07:43:53,726 PM [test-akka.actor.default-dispatcher-11] [DEBUG] NetconfNodeManagerTest$TestMasterActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: received message AskForMasterMountPoint [slaveActorRef=Actor[akka://test@127.0.0.1:2550/user/$a#5242470]] 07:43:53,726 PM [test-akka.actor.default-dispatcher-11] [DEBUG] NetconfNodeManagerTest$TestMasterActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Sending RegisterMountPoint reply to Actor[akka://test@127.0.0.1:2550/user/$a#5242470] 07:43:53,729 PM [test-akka.actor.default-dispatcher-10] [DEBUG] NetconfNodeActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: received message RegisterMountPoint [allSourceIdentifiers=[SourceIdentifier [testID]], masterActorRef=Actor[akka://test@127.0.0.1:2552/user/akka:test@127.0.0.1:2552_device]] 07:43:53,730 PM [test-akka.actor.default-dispatcher-10] [INFO] NetconfNodeActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Schema context resolved: [ModuleEffectiveStatementImpl{argument=Unqualified{localName=testID}}] - registering slave mount point 07:43:53,731 PM [test-akka.actor.default-dispatcher-10] [INFO] SlaveSalFacade - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Slave mount point registered. 07:43:53,731 PM [test-akka.actor.default-dispatcher-10] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: AskForMasterMountPoint [slaveActorRef=Actor[akka://test/user/$a#5242470]] message to ActorSelection[Anchor(akka://test@127.0.0.1:2552/), Path(/user/akka:test@127.0.0.1:2552_device)] succeeded 07:43:53,735 PM [main] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Operational state for node Uri{value=device} updated from Node{nodeId=Uri{value=device}, augmentation=[NetconfNodeAugment{netconfNode=NetconfNode{clusteredConnectionStatus=ClusteredConnectionStatus{netconfMasterNode=akka://test@127.0.0.1:2552}, connectionStatus=Connected, host=Host{ipAddress=IpAddress{ipv4Address=Ipv4Address{value=127.0.0.1}}}, port=PortNumber{value=9999}}}]} to Node{nodeId=Uri{value=device}, augmentation=[NetconfNodeAugment{netconfNode=NetconfNode{clusteredConnectionStatus=ClusteredConnectionStatus{netconfMasterNode=akka://test@127.0.0.1:2552}, connectionStatus=Connected, host=Host{ipAddress=IpAddress{ipv4Address=Ipv4Address{value=127.0.0.1}}}, port=PortNumber{value=9999}}}]} 07:43:53,735 PM [test-akka.actor.default-dispatcher-10] [DEBUG] NetconfNodeActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: received message org.opendaylight.netconf.topology.singleton.messages.RefreshSlaveActor@4d648515 07:43:53,735 PM [main] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Sending AskForMasterMountPoint [slaveActorRef=Actor[akka://test/user/$a#5242470]] message to master ActorSelection[Anchor(akka://test@127.0.0.1:2552/), Path(/user/akka:test@127.0.0.1:2552_device)] 07:43:53,738 PM [test-akka.actor.default-dispatcher-11] [DEBUG] NetconfNodeManagerTest$TestMasterActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: received message AskForMasterMountPoint [slaveActorRef=Actor[akka://test@127.0.0.1:2550/user/$a#5242470]] 07:43:53,738 PM [test-akka.actor.default-dispatcher-11] [DEBUG] NetconfNodeManagerTest$TestMasterActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Sending RegisterMountPoint reply to Actor[akka://test@127.0.0.1:2550/user/$a#5242470] 07:43:53,739 PM [test-akka.actor.default-dispatcher-10] [DEBUG] NetconfNodeActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: received message RegisterMountPoint [allSourceIdentifiers=[SourceIdentifier [testID]], masterActorRef=Actor[akka://test@127.0.0.1:2552/user/akka:test@127.0.0.1:2552_device]] 07:43:53,740 PM [test-akka.actor.default-dispatcher-10] [INFO] SlaveSalFacade - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Slave mount point unregistered. 07:43:53,740 PM [test-akka.actor.default-dispatcher-10] [INFO] NetconfNodeActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Schema context resolved: [ModuleEffectiveStatementImpl{argument=Unqualified{localName=testID}}] - registering slave mount point 07:43:53,740 PM [test-akka.actor.default-dispatcher-5] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: AskForMasterMountPoint [slaveActorRef=Actor[akka://test/user/$a#5242470]] message to ActorSelection[Anchor(akka://test@127.0.0.1:2552/), Path(/user/akka:test@127.0.0.1:2552_device)] succeeded 07:43:53,741 PM [test-akka.actor.default-dispatcher-10] [INFO] SlaveSalFacade - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Slave mount point registered. 07:43:53,747 PM [main] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Operational state for node Uri{value=device} - subtree modified from Node{nodeId=Uri{value=device}, augmentation=[NetconfNodeAugment{netconfNode=NetconfNode{clusteredConnectionStatus=ClusteredConnectionStatus{netconfMasterNode=akka://test@127.0.0.1:2552}, connectionStatus=Connected, host=Host{ipAddress=IpAddress{ipv4Address=Ipv4Address{value=127.0.0.1}}}, port=PortNumber{value=9999}}}]} to Node{nodeId=Uri{value=device}, augmentation=[NetconfNodeAugment{netconfNode=NetconfNode{clusteredConnectionStatus=ClusteredConnectionStatus{netconfMasterNode=akka://test@127.0.0.1:2552}, connectionStatus=UnableToConnect, host=Host{ipAddress=IpAddress{ipv4Address=Ipv4Address{value=127.0.0.1}}}, port=PortNumber{value=9999}}}]} 07:43:53,747 PM [main] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Sending message to unregister slave mountpoint to Actor[akka://test/user/$a#5242470] 07:43:53,748 PM [test-akka.actor.default-dispatcher-10] [DEBUG] NetconfNodeActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: received message org.opendaylight.netconf.topology.singleton.messages.UnregisterSlaveMountPoint@3f45eefe 07:43:53,748 PM [test-akka.actor.default-dispatcher-10] [INFO] SlaveSalFacade - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Slave mount point unregistered. 07:43:53,758 PM [main] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Sending poison pill to Actor[akka://test/user/$a#5242470] 07:43:53,759 PM [test-akka.actor.default-dispatcher-10] [INFO] CoordinatedShutdown - Running CoordinatedShutdown with reason [ActorSystemTerminateReason] 07:43:53,760 PM [test-akka.actor.default-dispatcher-10] [INFO] LocalActorRef - akkaDeadLetter Message [akka.cluster.ClusterUserAction$Leave] to Actor[akka://test/system/cluster/core/daemon#-730725900] was unhandled. [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'. 07:43:53,761 PM [test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2550] - Exiting completed 07:43:53,761 PM [test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2550] - Shutting down... 07:43:53,761 PM [test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2550] - Successfully shut down 07:43:53,769 PM [test-akka.actor.default-dispatcher-5] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon. 07:43:53,769 PM [test-akka.actor.default-dispatcher-5] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports. 07:43:53,776 PM [test-akka.actor.default-dispatcher-5] [WARN] Materializer - [outbound connection to [akka://test@127.0.0.1:2552], message stream] Upstream failed, cause: StreamTcpException: The connection has been aborted 07:43:53,776 PM [test-akka.actor.default-dispatcher-5] [WARN] Materializer - [outbound connection to [akka://test@127.0.0.1:2552], control stream] Upstream failed, cause: StreamTcpException: The connection has been aborted 07:43:53,777 PM [test-akka.actor.default-dispatcher-5] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down. 07:43:53,789 PM [test-akka.actor.default-dispatcher-11] [INFO] CoordinatedShutdown - Running CoordinatedShutdown with reason [ActorSystemTerminateReason] 07:43:53,791 PM [test-akka.actor.default-dispatcher-11] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2552] - Exiting completed 07:43:53,791 PM [test-akka.actor.default-dispatcher-11] [INFO] LocalActorRef - akkaDeadLetter Message [akka.cluster.ClusterUserAction$Leave] to Actor[akka://test/system/cluster/core/daemon#1570272234] was unhandled. [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'. 07:43:53,793 PM [test-akka.actor.default-dispatcher-11] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2552] - Shutting down... 07:43:53,793 PM [test-akka.actor.default-dispatcher-11] [WARN] Cluster - Could not unregister Cluster JMX MBean with name=akka:type=Cluster as it was not found. If you are running multiple clusters in the same JVM, set 'akka.cluster.jmx.multi-mbeans-in-same-jvm = on' in config 07:43:53,793 PM [test-akka.actor.default-dispatcher-11] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2552] - Successfully shut down 07:43:53,796 PM [test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon. 07:43:53,796 PM [test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports. 07:43:54,822 PM [test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down.