05:40:29,509 AM [test-pekko.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started 05:40:29,537 AM [test-pekko.actor.default-dispatcher-5] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [pekko://test@127.0.0.1:2550] with UID [-5202762778157474659] 05:40:29,538 AM [test-pekko.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [pekko://test@127.0.0.1:2550] - Starting up, Pekko version [1.0.3] ... 05:40:29,543 AM [test-pekko.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [pekko://test@127.0.0.1:2550] - Registered cluster JMX MBean [pekko:type=Cluster] 05:40:29,543 AM [test-pekko.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [pekko://test@127.0.0.1:2550] - Started up successfully 05:40:29,545 AM [test-pekko.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [pekko://test@127.0.0.1:2550] - No downing-provider-class configured, manual cluster downing required, see https://pekko.apache.org/docs/pekko/current/typed/cluster.html#downing 05:40:29,545 AM [test-pekko.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [pekko://test@127.0.0.1:2550] - No seed-nodes configured, manual cluster join required, see https://pekko.apache.org/docs/pekko/current/typed/cluster.html#joining 05:40:29,594 AM [test-pekko.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started 05:40:29,617 AM [test-pekko.actor.default-dispatcher-5] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [pekko://test@127.0.0.1:2552] with UID [4220538591732961091] 05:40:29,618 AM [test-pekko.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [pekko://test@127.0.0.1:2552] - Starting up, Pekko version [1.0.3] ... 05:40:29,623 AM [test-pekko.actor.default-dispatcher-5] [WARN] Cluster - Could not register Cluster JMX MBean with name=pekko:type=Cluster as it is already registered. If you are running multiple clusters in the same JVM, set 'pekko.cluster.jmx.multi-mbeans-in-same-jvm = on' in config 05:40:29,623 AM [test-pekko.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [pekko://test@127.0.0.1:2552] - Started up successfully 05:40:29,629 AM [test-pekko.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [pekko://test@127.0.0.1:2552] - No downing-provider-class configured, manual cluster downing required, see https://pekko.apache.org/docs/pekko/current/typed/cluster.html#downing 05:40:29,629 AM [test-pekko.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [pekko://test@127.0.0.1:2552] - No seed-nodes configured, manual cluster join required, see https://pekko.apache.org/docs/pekko/current/typed/cluster.html#joining 05:40:29,724 AM [test-pekko.actor.default-dispatcher-10] [DEBUG] NetconfNodeManagerTest$TestMasterActor - Actor created TestActor[pekko://test/user/pekko:test@127.0.0.1:2552_device] 05:40:29,725 AM [test-pekko.actor.default-dispatcher-10] [INFO] EmptyLocalActorRef - pekkoDeadLetter Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[pekko://test/user/pekko:test@127.0.0.1:2552_device] to Actor[pekko://test/user/termination-monitor] was not delivered. [1] dead letters encountered. If this is not an expected behavior then Actor[pekko://test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'pekko.log-dead-letters' and 'pekko.log-dead-letters-during-shutdown'. 05:40:29,825 AM [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=pekko://test@127.0.0.1:2552}, connectionStatus=Connected, host=Host{ipAddress=IpAddress{ipv4Address=Ipv4Address{value=127.0.0.1}}}, port=PortNumber{value=9999}}}]} 05:40:29,827 AM [main] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Slave actor created with name Actor[pekko://test/user/$a#1975343083] 05:40:29,827 AM [test-pekko.actor.default-dispatcher-10] [DEBUG] NetconfNodeActor - Actor created Actor[pekko://test/user/$a#1975343083] 05:40:29,828 AM [test-pekko.actor.default-dispatcher-10] [INFO] EmptyLocalActorRef - pekkoDeadLetter Message [org.opendaylight.controller.cluster.common.actor.Monitor] from Actor[pekko://test/user/$a#1975343083] to Actor[pekko://test/user/termination-monitor] was not delivered. [1] dead letters encountered. If this is not an expected behavior then Actor[pekko://test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'pekko.log-dead-letters' and 'pekko.log-dead-letters-during-shutdown'. 05:40:29,830 AM [main] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Sending AskForMasterMountPoint [slaveActorRef=Actor[pekko://test/user/$a#1975343083]] message to master ActorSelection[Anchor(pekko://test@127.0.0.1:2552/), Path(/user/pekko:test@127.0.0.1:2552_device)] 05:40:30,291 AM [test-pekko.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[pekko://test@127.0.0.1:2550/user/$a#1975343083]] 05:40:30,291 AM [test-pekko.actor.default-dispatcher-5] [WARN] NetconfNodeManagerTest$TestMasterActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Received AskForMasterMountPoint [slaveActorRef=Actor[pekko://test@127.0.0.1:2550/user/$a#1975343083]] but we don't appear to be the master 05:40:30,327 AM [test-pekko.actor.default-dispatcher-10] [ERROR] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Failed to send message AskForMasterMountPoint [slaveActorRef=Actor[pekko://test/user/$a#1975343083]] to ActorSelection[Anchor(pekko://test@127.0.0.1:2552/), Path(/user/pekko:test@127.0.0.1:2552_device)]. Slave mount point could not be created org.opendaylight.netconf.topology.singleton.messages.NotMasterException: Actor TestActor[pekko://test/user/pekko: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:410) at org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:33) at org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:29) at scala.PartialFunction.applyOrElse(PartialFunction.scala:225) at scala.PartialFunction.applyOrElse$(PartialFunction.scala:224) at org.apache.pekko.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:29) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:280) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:281) at org.apache.pekko.actor.Actor.aroundReceive(Actor.scala:547) at org.apache.pekko.actor.Actor.aroundReceive$(Actor.scala:545) at org.apache.pekko.actor.AbstractActor.aroundReceive(AbstractActor.scala:229) at org.apache.pekko.actor.ActorCell.receiveMessage(ActorCell.scala:590) at org.apache.pekko.actor.ActorCell.invoke(ActorCell.scala:557) at org.apache.pekko.dispatch.Mailbox.processMailbox(Mailbox.scala:280) at org.apache.pekko.dispatch.Mailbox.run(Mailbox.scala:241) at org.apache.pekko.dispatch.Mailbox.exec(Mailbox.scala:253) 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) 05:40:30,890 AM [test-pekko.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@1d95780d 05:40:30,896 AM [test-pekko.actor.default-dispatcher-5] [DEBUG] NetconfNodeManagerTest$TestMasterActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Master is ready. 05:40:30,898 AM [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=pekko://test@127.0.0.1:2552}, connectionStatus=Connected, host=Host{ipAddress=IpAddress{ipv4Address=Ipv4Address{value=127.0.0.1}}}, port=PortNumber{value=9999}}}]} 05:40:30,900 AM [test-pekko.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@2a6d4aee 05:40:30,900 AM [main] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Sending AskForMasterMountPoint [slaveActorRef=Actor[pekko://test/user/$a#1975343083]] message to master ActorSelection[Anchor(pekko://test@127.0.0.1:2552/), Path(/user/pekko:test@127.0.0.1:2552_device)] 05:40:30,906 AM [test-pekko.actor.default-dispatcher-10] [DEBUG] NetconfNodeManagerTest$TestMasterActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: received message AskForMasterMountPoint [slaveActorRef=Actor[pekko://test@127.0.0.1:2550/user/$a#1975343083]] 05:40:30,907 AM [test-pekko.actor.default-dispatcher-10] [DEBUG] NetconfNodeManagerTest$TestMasterActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Sending RegisterMountPoint reply to Actor[pekko://test@127.0.0.1:2550/user/$a#1975343083] 05:40:30,929 AM [test-pekko.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[pekko://test@127.0.0.1:2552/user/pekko:test@127.0.0.1:2552_device]] 05:40:30,949 AM [test-pekko.actor.default-dispatcher-10] [INFO] SharedEffectiveModelContextFactory - Using weak references 05:40:30,971 AM [test-pekko.actor.default-dispatcher-5] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: AskForMasterMountPoint [slaveActorRef=Actor[pekko://test/user/$a#1975343083]] message to ActorSelection[Anchor(pekko://test@127.0.0.1:2552/), Path(/user/pekko:test@127.0.0.1:2552_device)] succeeded 05:40:31,988 AM [test-pekko.actor.default-dispatcher-10] [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:70) at com.google.common.util.concurrent.AbstractCatchingFuture$AsyncCatchingFuture.doFallback(AbstractCatchingFuture.java:207) at com.google.common.util.concurrent.AbstractCatchingFuture$AsyncCatchingFuture.doFallback(AbstractCatchingFuture.java:194) at com.google.common.util.concurrent.AbstractCatchingFuture.run(AbstractCatchingFuture.java:136) at com.google.common.util.concurrent.DirectExecutor.execute(DirectExecutor.java:30) at com.google.common.util.concurrent.AbstractFuture.executeListener(AbstractFuture.java:1004) at com.google.common.util.concurrent.AbstractFuture.complete(AbstractFuture.java:767) at com.google.common.util.concurrent.AbstractFuture.setException(AbstractFuture.java:516) at com.google.common.util.concurrent.AbstractTransformFuture.run(AbstractTransformFuture.java:108) at com.google.common.util.concurrent.DirectExecutor.execute(DirectExecutor.java:30) at com.google.common.util.concurrent.AbstractFuture.executeListener(AbstractFuture.java:1004) at com.google.common.util.concurrent.AbstractFuture.complete(AbstractFuture.java:767) at com.google.common.util.concurrent.AbstractFuture.setException(AbstractFuture.java:516) at com.google.common.util.concurrent.AbstractCatchingFuture.run(AbstractCatchingFuture.java:139) at com.google.common.util.concurrent.DirectExecutor.execute(DirectExecutor.java:30) at com.google.common.util.concurrent.AbstractFuture.executeListener(AbstractFuture.java:1004) at com.google.common.util.concurrent.AbstractFuture.complete(AbstractFuture.java:767) at com.google.common.util.concurrent.AbstractFuture.setException(AbstractFuture.java:516) at com.google.common.util.concurrent.SettableFuture.setException(SettableFuture.java:54) 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 org.apache.pekko.dispatch.OnComplete.internal(Future.scala:309) at org.apache.pekko.dispatch.OnComplete.internal(Future.scala:307) at org.apache.pekko.dispatch.japi$CallbackBridge.apply(Future.scala:234) at org.apache.pekko.dispatch.japi$CallbackBridge.apply(Future.scala:231) at scala.concurrent.impl.Promise$Transformation.run(Promise.scala:517) at org.apache.pekko.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:73) at org.apache.pekko.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:110) at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.scala:18) at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:94) at org.apache.pekko.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:110) at org.apache.pekko.dispatch.TaskInvocation.run(AbstractDispatcher.scala:59) at org.apache.pekko.dispatch.ForkJoinExecutorConfigurator$PekkoForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:57) 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:70) at com.google.common.util.concurrent.AbstractCatchingFuture$AsyncCatchingFuture.doFallback(AbstractCatchingFuture.java:207) at com.google.common.util.concurrent.AbstractCatchingFuture$AsyncCatchingFuture.doFallback(AbstractCatchingFuture.java:194) at com.google.common.util.concurrent.AbstractCatchingFuture.run(AbstractCatchingFuture.java:136) ... 24 more Caused by: org.apache.pekko.pattern.AskTimeoutException: Ask timed out on [Actor[pekko://test@127.0.0.1:2552/user/pekko: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. 05:40:31,996 AM [test-pekko.actor.default-dispatcher-10] [DEBUG] NetconfNodeManagerTest$TestMasterActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: received message YangTextSchemaSourceRequest [sourceIdentifier=SourceIdentifier [testID]] 05:40:32,2 AM [test-pekko.actor.default-dispatcher-10] [DEBUG] NetconfNodeManagerTest$TestMasterActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: getSchemaSource for SourceIdentifier [testID] succeeded 05:40:32,234 AM [test-pekko.actor.default-dispatcher-5] [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 05:40:32,287 AM [test-pekko.actor.default-dispatcher-5] [INFO] SlaveSalFacade - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Slave mount point registered. 05:40:32,295 AM [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=pekko://test@127.0.0.1:2552}, connectionStatus=Connected, host=Host{ipAddress=IpAddress{ipv4Address=Ipv4Address{value=127.0.0.1}}}, port=PortNumber{value=9999}}}]} 05:40:32,296 AM [test-pekko.actor.default-dispatcher-5] [DEBUG] NetconfNodeActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: received message org.opendaylight.netconf.topology.singleton.messages.RefreshSlaveActor@47f59a0a 05:40:32,296 AM [main] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Sending AskForMasterMountPoint [slaveActorRef=Actor[pekko://test/user/$a#1975343083]] message to master ActorSelection[Anchor(pekko://test@127.0.0.1:2552/), Path(/user/pekko:test@127.0.0.1:2552_device)] 05:40:33,309 AM [test-pekko.actor.default-dispatcher-5] [WARN] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Failed to send message to ActorSelection[Anchor(pekko://test@127.0.0.1:2552/), Path(/user/pekko:test@127.0.0.1:2552_device)] - retrying... org.apache.pekko.pattern.AskTimeoutException: Ask timed out on [ActorSelection[Anchor(pekko://test@127.0.0.1:2552/), Path(/user/pekko: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. 05:40:33,316 AM [test-pekko.actor.default-dispatcher-10] [DEBUG] NetconfNodeManagerTest$TestMasterActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: received message AskForMasterMountPoint [slaveActorRef=Actor[pekko://test@127.0.0.1:2550/user/$a#1975343083]] 05:40:33,316 AM [test-pekko.actor.default-dispatcher-10] [DEBUG] NetconfNodeManagerTest$TestMasterActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Sending RegisterMountPoint reply to Actor[pekko://test@127.0.0.1:2550/user/$a#1975343083] 05:40:33,321 AM [test-pekko.actor.default-dispatcher-5] [DEBUG] NetconfNodeActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: received message RegisterMountPoint [allSourceIdentifiers=[SourceIdentifier [testID]], masterActorRef=Actor[pekko://test@127.0.0.1:2552/user/pekko:test@127.0.0.1:2552_device]] 05:40:33,323 AM [test-pekko.actor.default-dispatcher-5] [INFO] SlaveSalFacade - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Slave mount point unregistered. 05:40:33,325 AM [test-pekko.actor.default-dispatcher-10] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: AskForMasterMountPoint [slaveActorRef=Actor[pekko://test/user/$a#1975343083]] message to ActorSelection[Anchor(pekko://test@127.0.0.1:2552/), Path(/user/pekko:test@127.0.0.1:2552_device)] succeeded 05:40:33,325 AM [test-pekko.actor.default-dispatcher-5] [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 05:40:33,327 AM [test-pekko.actor.default-dispatcher-5] [INFO] SlaveSalFacade - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Slave mount point registered. 05:40:33,329 AM [main] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Sending poison pill to Actor[pekko://test/user/$a#1975343083] 05:40:33,330 AM [test-pekko.actor.default-dispatcher-5] [INFO] SlaveSalFacade - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Slave mount point unregistered. 05:40:33,341 AM [test-pekko.actor.default-dispatcher-5] [INFO] CoordinatedShutdown - Running CoordinatedShutdown with reason [ActorSystemTerminateReason] 05:40:33,343 AM [test-pekko.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [pekko://test@127.0.0.1:2550] - Exiting completed 05:40:33,343 AM [test-pekko.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [pekko://test@127.0.0.1:2550] - Shutting down... 05:40:33,344 AM [test-pekko.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [pekko://test@127.0.0.1:2550] - Successfully shut down 05:40:33,344 AM [test-pekko.actor.default-dispatcher-10] [INFO] LocalActorRef - pekkoDeadLetter Message [org.apache.pekko.cluster.ClusterUserAction$Leave] to Actor[pekko://test/system/cluster/core/daemon#-1594575401] was unhandled. [2] dead letters encountered. This logging can be turned off or adjusted with configuration settings 'pekko.log-dead-letters' and 'pekko.log-dead-letters-during-shutdown'. 05:40:33,346 AM [test-pekko.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon. 05:40:33,347 AM [test-pekko.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports. 05:40:33,378 AM [test-pekko.actor.default-dispatcher-10] [WARN] Materializer - [outbound connection to [pekko://test@127.0.0.1:2552], control stream] Upstream failed, cause: StreamTcpException: The connection has been aborted 05:40:33,378 AM [test-pekko.actor.default-dispatcher-10] [WARN] Materializer - [outbound connection to [pekko://test@127.0.0.1:2552], message stream] Upstream failed, cause: StreamTcpException: The connection has been aborted 05:40:33,382 AM [test-pekko.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down. 05:40:33,401 AM [test-pekko.actor.default-dispatcher-10] [INFO] CoordinatedShutdown - Running CoordinatedShutdown with reason [ActorSystemTerminateReason] 05:40:33,404 AM [test-pekko.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [pekko://test@127.0.0.1:2552] - Exiting completed 05:40:33,404 AM [test-pekko.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [pekko://test@127.0.0.1:2552] - Shutting down... 05:40:33,404 AM [test-pekko.actor.default-dispatcher-10] [WARN] Cluster - Could not unregister Cluster JMX MBean with name=pekko:type=Cluster as it was not found. If you are running multiple clusters in the same JVM, set 'pekko.cluster.jmx.multi-mbeans-in-same-jvm = on' in config 05:40:33,404 AM [test-pekko.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [pekko://test@127.0.0.1:2552] - Successfully shut down 05:40:33,404 AM [test-pekko.actor.default-dispatcher-10] [INFO] LocalActorRef - pekkoDeadLetter Message [org.apache.pekko.cluster.ClusterUserAction$Leave] to Actor[pekko://test/system/cluster/core/daemon#-2082533850] was unhandled. [2] dead letters encountered. This logging can be turned off or adjusted with configuration settings 'pekko.log-dead-letters' and 'pekko.log-dead-letters-during-shutdown'. 05:40:33,406 AM [test-pekko.actor.default-dispatcher-21] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon. 05:40:33,407 AM [test-pekko.actor.default-dispatcher-21] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports. 05:40:34,432 AM [test-pekko.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down. 05:40:34,466 AM [test-pekko.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started 05:40:34,490 AM [test-pekko.actor.default-dispatcher-5] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [pekko://test@127.0.0.1:2550] with UID [8398948917265569891] 05:40:34,491 AM [test-pekko.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [pekko://test@127.0.0.1:2550] - Starting up, Pekko version [1.0.3] ... 05:40:34,495 AM [test-pekko.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [pekko://test@127.0.0.1:2550] - Registered cluster JMX MBean [pekko:type=Cluster] 05:40:34,496 AM [test-pekko.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [pekko://test@127.0.0.1:2550] - Started up successfully 05:40:34,497 AM [test-pekko.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [pekko://test@127.0.0.1:2550] - No downing-provider-class configured, manual cluster downing required, see https://pekko.apache.org/docs/pekko/current/typed/cluster.html#downing 05:40:34,497 AM [test-pekko.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [pekko://test@127.0.0.1:2550] - No seed-nodes configured, manual cluster join required, see https://pekko.apache.org/docs/pekko/current/typed/cluster.html#joining 05:40:34,535 AM [test-pekko.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started 05:40:34,556 AM [test-pekko.actor.default-dispatcher-5] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [pekko://test@127.0.0.1:2552] with UID [5281545479215632288] 05:40:34,558 AM [test-pekko.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [pekko://test@127.0.0.1:2552] - Starting up, Pekko version [1.0.3] ... 05:40:34,561 AM [test-pekko.actor.default-dispatcher-5] [WARN] Cluster - Could not register Cluster JMX MBean with name=pekko:type=Cluster as it is already registered. If you are running multiple clusters in the same JVM, set 'pekko.cluster.jmx.multi-mbeans-in-same-jvm = on' in config 05:40:34,561 AM [test-pekko.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [pekko://test@127.0.0.1:2552] - Started up successfully 05:40:34,564 AM [test-pekko.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [pekko://test@127.0.0.1:2552] - No downing-provider-class configured, manual cluster downing required, see https://pekko.apache.org/docs/pekko/current/typed/cluster.html#downing 05:40:34,564 AM [test-pekko.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [pekko://test@127.0.0.1:2552] - No seed-nodes configured, manual cluster join required, see https://pekko.apache.org/docs/pekko/current/typed/cluster.html#joining 05:40:34,591 AM [test-pekko.actor.default-dispatcher-10] [DEBUG] NetconfNodeManagerTest$TestMasterActor - Actor created TestActor[pekko://test/user/pekko:test@127.0.0.1:2552_device] 05:40:34,592 AM [test-pekko.actor.default-dispatcher-10] [INFO] EmptyLocalActorRef - pekkoDeadLetter Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[pekko://test/user/pekko:test@127.0.0.1:2552_device] to Actor[pekko://test/user/termination-monitor] was not delivered. [1] dead letters encountered. If this is not an expected behavior then Actor[pekko://test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'pekko.log-dead-letters' and 'pekko.log-dead-letters-during-shutdown'. 05:40:34,605 AM [test-pekko.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@7918e15 05:40:34,607 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] NetconfNodeManagerTest$TestMasterActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Master is ready. 05:40:34,619 AM [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}}] ] 05:40:34,620 AM [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=pekko://test@127.0.0.1:2552}, connectionStatus=Connected, host=Host{ipAddress=IpAddress{ipv4Address=Ipv4Address{value=127.0.0.1}}}, port=PortNumber{value=9999}}}]} 05:40:34,620 AM [main] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Slave actor created with name Actor[pekko://test/user/$a#-1522936208] 05:40:34,621 AM [test-pekko.actor.default-dispatcher-10] [DEBUG] NetconfNodeActor - Actor created Actor[pekko://test/user/$a#-1522936208] 05:40:34,621 AM [main] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Sending AskForMasterMountPoint [slaveActorRef=Actor[pekko://test/user/$a#-1522936208]] message to master ActorSelection[Anchor(pekko://test@127.0.0.1:2552/), Path(/user/pekko:test@127.0.0.1:2552_device)] 05:40:34,622 AM [test-pekko.actor.default-dispatcher-5] [INFO] EmptyLocalActorRef - pekkoDeadLetter Message [org.opendaylight.controller.cluster.common.actor.Monitor] from Actor[pekko://test/user/$a#-1522936208] to Actor[pekko://test/user/termination-monitor] was not delivered. [1] dead letters encountered. If this is not an expected behavior then Actor[pekko://test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'pekko.log-dead-letters' and 'pekko.log-dead-letters-during-shutdown'. 05:40:34,663 AM [test-pekko.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[pekko://test@127.0.0.1:2550/user/$a#-1522936208]] 05:40:34,663 AM [test-pekko.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[pekko://test@127.0.0.1:2550/user/$a#-1522936208] 05:40:34,667 AM [test-pekko.actor.default-dispatcher-5] [DEBUG] NetconfNodeActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: received message RegisterMountPoint [allSourceIdentifiers=[SourceIdentifier [testID]], masterActorRef=Actor[pekko://test@127.0.0.1:2552/user/pekko:test@127.0.0.1:2552_device]] 05:40:34,669 AM [test-pekko.actor.default-dispatcher-10] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: AskForMasterMountPoint [slaveActorRef=Actor[pekko://test/user/$a#-1522936208]] message to ActorSelection[Anchor(pekko://test@127.0.0.1:2552/), Path(/user/pekko:test@127.0.0.1:2552_device)] succeeded 05:40:34,671 AM [test-pekko.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]] 05:40:34,671 AM [test-pekko.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 05:40:34,683 AM [test-pekko.actor.default-dispatcher-5] [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 05:40:34,684 AM [test-pekko.actor.default-dispatcher-5] [INFO] SlaveSalFacade - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Slave mount point registered. 05:40:34,687 AM [main] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Operational state for node Uri{value=device} deleted. 05:40:34,687 AM [main] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Sending message to unregister slave mountpoint to Actor[pekko://test/user/$a#-1522936208] 05:40:34,687 AM [test-pekko.actor.default-dispatcher-5] [DEBUG] NetconfNodeActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: received message org.opendaylight.netconf.topology.singleton.messages.UnregisterSlaveMountPoint@4de89df6 05:40:34,688 AM [test-pekko.actor.default-dispatcher-5] [INFO] SlaveSalFacade - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Slave mount point unregistered. 05:40:34,698 AM [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=pekko://test@127.0.0.1:2552}, connectionStatus=Connected, host=Host{ipAddress=IpAddress{ipv4Address=Ipv4Address{value=127.0.0.1}}}, port=PortNumber{value=9999}}}]} 05:40:34,699 AM [test-pekko.actor.default-dispatcher-5] [DEBUG] NetconfNodeActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: received message org.opendaylight.netconf.topology.singleton.messages.RefreshSlaveActor@2fb54908 05:40:34,699 AM [main] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Sending AskForMasterMountPoint [slaveActorRef=Actor[pekko://test/user/$a#-1522936208]] message to master ActorSelection[Anchor(pekko://test@127.0.0.1:2552/), Path(/user/pekko:test@127.0.0.1:2552_device)] 05:40:34,703 AM [test-pekko.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[pekko://test@127.0.0.1:2550/user/$a#-1522936208]] 05:40:34,703 AM [test-pekko.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[pekko://test@127.0.0.1:2550/user/$a#-1522936208] 05:40:34,707 AM [test-pekko.actor.default-dispatcher-5] [DEBUG] NetconfNodeActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: received message RegisterMountPoint [allSourceIdentifiers=[SourceIdentifier [testID]], masterActorRef=Actor[pekko://test@127.0.0.1:2552/user/pekko:test@127.0.0.1:2552_device]] 05:40:34,708 AM [test-pekko.actor.default-dispatcher-5] [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 05:40:34,708 AM [test-pekko.actor.default-dispatcher-10] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: AskForMasterMountPoint [slaveActorRef=Actor[pekko://test/user/$a#-1522936208]] message to ActorSelection[Anchor(pekko://test@127.0.0.1:2552/), Path(/user/pekko:test@127.0.0.1:2552_device)] succeeded 05:40:34,708 AM [test-pekko.actor.default-dispatcher-5] [INFO] SlaveSalFacade - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Slave mount point registered. 05:40:34,711 AM [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=pekko://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=pekko://test@127.0.0.1:2552}, connectionStatus=Connected, host=Host{ipAddress=IpAddress{ipv4Address=Ipv4Address{value=127.0.0.1}}}, port=PortNumber{value=9999}}}]} 05:40:34,711 AM [test-pekko.actor.default-dispatcher-5] [DEBUG] NetconfNodeActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: received message org.opendaylight.netconf.topology.singleton.messages.RefreshSlaveActor@263b6625 05:40:34,711 AM [main] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Sending AskForMasterMountPoint [slaveActorRef=Actor[pekko://test/user/$a#-1522936208]] message to master ActorSelection[Anchor(pekko://test@127.0.0.1:2552/), Path(/user/pekko:test@127.0.0.1:2552_device)] 05:40:34,714 AM [test-pekko.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[pekko://test@127.0.0.1:2550/user/$a#-1522936208]] 05:40:34,714 AM [test-pekko.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[pekko://test@127.0.0.1:2550/user/$a#-1522936208] 05:40:34,716 AM [test-pekko.actor.default-dispatcher-5] [DEBUG] NetconfNodeActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: received message RegisterMountPoint [allSourceIdentifiers=[SourceIdentifier [testID]], masterActorRef=Actor[pekko://test@127.0.0.1:2552/user/pekko:test@127.0.0.1:2552_device]] 05:40:34,717 AM [test-pekko.actor.default-dispatcher-5] [INFO] SlaveSalFacade - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Slave mount point unregistered. 05:40:34,717 AM [test-pekko.actor.default-dispatcher-10] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: AskForMasterMountPoint [slaveActorRef=Actor[pekko://test/user/$a#-1522936208]] message to ActorSelection[Anchor(pekko://test@127.0.0.1:2552/), Path(/user/pekko:test@127.0.0.1:2552_device)] succeeded 05:40:34,717 AM [test-pekko.actor.default-dispatcher-5] [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 05:40:34,718 AM [test-pekko.actor.default-dispatcher-5] [INFO] SlaveSalFacade - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Slave mount point registered. 05:40:34,723 AM [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=pekko://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=pekko://test@127.0.0.1:2552}, connectionStatus=UnableToConnect, host=Host{ipAddress=IpAddress{ipv4Address=Ipv4Address{value=127.0.0.1}}}, port=PortNumber{value=9999}}}]} 05:40:34,723 AM [main] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Sending message to unregister slave mountpoint to Actor[pekko://test/user/$a#-1522936208] 05:40:34,723 AM [test-pekko.actor.default-dispatcher-5] [DEBUG] NetconfNodeActor - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: received message org.opendaylight.netconf.topology.singleton.messages.UnregisterSlaveMountPoint@2bfb1204 05:40:34,724 AM [test-pekko.actor.default-dispatcher-5] [INFO] SlaveSalFacade - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Slave mount point unregistered. 05:40:34,724 AM [main] [DEBUG] NetconfNodeManager - RemoteDeviceId[name=device, address=0.0.0.0/0.0.0.0:65535]: Sending poison pill to Actor[pekko://test/user/$a#-1522936208] 05:40:34,725 AM [test-pekko.actor.default-dispatcher-5] [INFO] CoordinatedShutdown - Running CoordinatedShutdown with reason [ActorSystemTerminateReason] 05:40:34,726 AM [test-pekko.actor.default-dispatcher-5] [INFO] LocalActorRef - pekkoDeadLetter Message [org.apache.pekko.cluster.ClusterUserAction$Leave] to Actor[pekko://test/system/cluster/core/daemon#881957921] was unhandled. [2] dead letters encountered. This logging can be turned off or adjusted with configuration settings 'pekko.log-dead-letters' and 'pekko.log-dead-letters-during-shutdown'. 05:40:34,726 AM [test-pekko.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [pekko://test@127.0.0.1:2550] - Exiting completed 05:40:34,727 AM [test-pekko.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [pekko://test@127.0.0.1:2550] - Shutting down... 05:40:34,727 AM [test-pekko.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [pekko://test@127.0.0.1:2550] - Successfully shut down 05:40:34,730 AM [test-pekko.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon. 05:40:34,730 AM [test-pekko.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports. 05:40:34,738 AM [test-pekko.actor.default-dispatcher-5] [WARN] Materializer - [outbound connection to [pekko://test@127.0.0.1:2552], message stream] Upstream failed, cause: StreamTcpException: The connection has been aborted 05:40:34,739 AM [test-pekko.actor.default-dispatcher-5] [WARN] Materializer - [outbound connection to [pekko://test@127.0.0.1:2552], control stream] Upstream failed, cause: StreamTcpException: The connection has been aborted 05:40:34,741 AM [test-pekko.actor.default-dispatcher-5] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down. 05:40:34,753 AM [test-pekko.actor.default-dispatcher-11] [INFO] CoordinatedShutdown - Running CoordinatedShutdown with reason [ActorSystemTerminateReason] 05:40:34,754 AM [test-pekko.actor.default-dispatcher-11] [INFO] LocalActorRef - pekkoDeadLetter Message [org.apache.pekko.cluster.ClusterUserAction$Leave] to Actor[pekko://test/system/cluster/core/daemon#-1060607570] was unhandled. [2] dead letters encountered. This logging can be turned off or adjusted with configuration settings 'pekko.log-dead-letters' and 'pekko.log-dead-letters-during-shutdown'. 05:40:34,755 AM [test-pekko.actor.default-dispatcher-11] [INFO] Cluster - Cluster Node [pekko://test@127.0.0.1:2552] - Exiting completed 05:40:34,755 AM [test-pekko.actor.default-dispatcher-11] [INFO] Cluster - Cluster Node [pekko://test@127.0.0.1:2552] - Shutting down... 05:40:34,755 AM [test-pekko.actor.default-dispatcher-11] [WARN] Cluster - Could not unregister Cluster JMX MBean with name=pekko:type=Cluster as it was not found. If you are running multiple clusters in the same JVM, set 'pekko.cluster.jmx.multi-mbeans-in-same-jvm = on' in config 05:40:34,755 AM [test-pekko.actor.default-dispatcher-11] [INFO] Cluster - Cluster Node [pekko://test@127.0.0.1:2552] - Successfully shut down 05:40:34,760 AM [test-pekko.actor.default-dispatcher-11] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon. 05:40:34,761 AM [test-pekko.actor.default-dispatcher-11] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports. 05:40:35,784 AM [test-pekko.actor.default-dispatcher-11] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down.