Regression
org.eclipse.ditto.services.connectivity.messaging.rabbitmq.RabbitMQClientActorTest.sendConnectCommandWhenAlreadyConnected
Error Message
mockConnection.createChannel(); Wanted *at least* 2 times: -> at org.eclipse.ditto.services.connectivity.messaging.rabbitmq.RabbitMQClientActorTest$4.<init>(RabbitMQClientActorTest.java:177) But was 1 time: -> at com.newmotion.akka.rabbitmq.ConnectionActor$$anonfun$2.$anonfun$applyOrElse$4(ConnectionActor.scala:79)
Stacktrace
org.mockito.exceptions.verification.TooLittleActualInvocations: mockConnection.createChannel(); Wanted *at least* 2 times: -> at org.eclipse.ditto.services.connectivity.messaging.rabbitmq.RabbitMQClientActorTest$4.<init>(RabbitMQClientActorTest.java:177) But was 1 time: -> at com.newmotion.akka.rabbitmq.ConnectionActor$$anonfun$2.$anonfun$applyOrElse$4(ConnectionActor.scala:79) at org.eclipse.ditto.services.connectivity.messaging.rabbitmq.RabbitMQClientActorTest.sendConnectCommandWhenAlreadyConnected(RabbitMQClientActorTest.java:166)
Standard Output
11:05:23.136 [INFO ] [AkkaTestSystem-akka.actor.default-dispatcher-14] akka://AkkaTestSystem/user/$d o.e.d.s.c.m.r.RabbitMQClientActor - Transition: DISCONNECTING -> DISCONNECTED 11:05:23.136 [INFO ] [AkkaTestSystem-akka.actor.default-dispatcher-14] akka://AkkaTestSystem/user/$d o.e.d.s.c.m.r.RabbitMQClientActor - Did set up consumer channel: mockChannel 11:05:23.136 [INFO ] [AkkaTestSystem-akka.actor.default-dispatcher-14] akka://AkkaTestSystem/user/$d o.e.d.s.c.m.r.RabbitMQClientActor - Starting to consume queues... 11:05:23.137 [WARN ] [AkkaTestSystem-akka.actor.default-dispatcher-14] akka://AkkaTestSystem/user/$d o.e.d.s.c.m.r.RabbitMQClientActor - The MessageMappingProcessor was not available and therefore no consumers were started! 11:05:23.137 [INFO ] [AkkaTestSystem-akka.actor.default-dispatcher-14] akka.tcp://AkkaTestSystem@172.30.206.106:2552/user/$d/rmq-connection/consumer-channel c.n.a.r.ChannelActor - akka://AkkaTestSystem/user/$d/rmq-connection/consumer-channel connected 11:05:23.138 [INFO ] [AkkaTestSystem-akka.actor.default-dispatcher-14] akka.tcp://AkkaTestSystem@172.30.206.106:2552/user/$d/rmq-connection c.n.a.r.ConnectionActor - closing connection to amqp://null@null:0/null 11:05:23.151 [INFO ] [AkkaTestSystem-akka.actor.default-dispatcher-14] akka://AkkaTestSystem/user/$e o.e.d.s.c.m.r.RabbitMQClientActor - Transition: DISCONNECTED -> CONNECTING 11:05:23.153 [INFO ] [AkkaTestSystem-akka.actor.default-dispatcher-2] akka://AkkaTestSystem/user/$e o.e.d.s.c.m.r.RabbitMQClientActor - Established RMQ connection: mockConnection 11:05:23.154 [INFO ] [AkkaTestSystem-akka.actor.default-dispatcher-2] akka://AkkaTestSystem/user/$e o.e.d.s.c.m.r.RabbitMQClientActor - Configured for processing messages with the following MessageMapperRegistry: <DefaultMessageMapperRegistry [defaultMapper=WrappingMessageMapper [delegate=org.eclipse.ditto.services.connectivity.mapping.DittoMessageMapper@64822b28], mapper=null]> 11:05:23.156 [INFO ] [AkkaTestSystem-akka.actor.default-dispatcher-3] akka://AkkaTestSystem/user/$e o.e.d.s.c.m.r.RabbitMQClientActor - Received ClientConnected 11:05:23.156 [INFO ] [AkkaTestSystem-akka.actor.default-dispatcher-3] akka://AkkaTestSystem/user/$e o.e.d.s.c.m.r.RabbitMQClientActor - Transition: CONNECTING -> CONNECTED 11:05:23.157 [INFO ] [AkkaTestSystem-akka.actor.default-dispatcher-3] akka://AkkaTestSystem/user/$e o.e.d.s.c.m.r.RabbitMQClientActor - Transition: CONNECTED -> CONNECTING 11:05:23.157 [INFO ] [AkkaTestSystem-akka.actor.default-dispatcher-3] akka://AkkaTestSystem/user/$e o.e.d.s.c.m.r.RabbitMQClientActor - Triggering reconnection 11:05:23.157 [INFO ] [AkkaTestSystem-akka.actor.default-dispatcher-3] akka.tcp://AkkaTestSystem@172.30.206.106:2552/user/$e/rmq-connection c.n.a.r.ConnectionActor - akka://AkkaTestSystem/user/$e/rmq-connection connected to amqp://null@null:0/null 11:05:23.157 [INFO ] [AkkaTestSystem-akka.actor.default-dispatcher-3] akka://AkkaTestSystem/user/$e o.e.d.s.c.m.r.RabbitMQClientActor - Received ClientDisconnected 11:05:23.158 [INFO ] [AkkaTestSystem-akka.actor.default-dispatcher-18] akka://AkkaTestSystem/user/$e/rmqPublisherActor a.a.LocalActorRef - Message [com.newmotion.akka.rabbitmq.ChannelCreated] from Actor[akka://AkkaTestSystem/user/$e/rmq-connection#-482129350] to Actor[akka://AkkaTestSystem/user/$e/rmqPublisherActor#2012232749] 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'. 11:05:23.158 [INFO ] [AkkaTestSystem-akka.actor.default-dispatcher-18] akka://AkkaTestSystem/user/$e o.e.d.s.c.m.r.RabbitMQClientActor - Did set up publisher channel: mockChannel 11:05:23.159 [INFO ] [AkkaTestSystem-akka.actor.default-dispatcher-18] akka://AkkaTestSystem/user/$e o.e.d.s.c.m.r.RabbitMQClientActor - Status of connecting in doConnectClient: Success(channel created) 11:05:23.159 [INFO ] [AkkaTestSystem-akka.actor.default-dispatcher-18] akka.tcp://AkkaTestSystem@172.30.206.106:2552/user/$e/rmq-connection/publisher-channel c.n.a.r.ChannelActor - akka://AkkaTestSystem/user/$e/rmq-connection/publisher-channel connected 11:05:23.159 [INFO ] [AkkaTestSystem-akka.actor.default-dispatcher-18] akka.tcp://AkkaTestSystem@172.30.206.106:2552/user/$e/rmq-connection c.n.a.r.ConnectionActor - closing connection to amqp://null@null:0/null 11:05:23.159 [INFO ] [AkkaTestSystem-akka.actor.default-dispatcher-18] akka://AkkaTestSystem/user/$e/rmq-connection a.a.LocalActorRef - Message [com.newmotion.akka.rabbitmq.CreateChannel] from Actor[akka://AkkaTestSystem/user/$e#1871397177] to Actor[akka://AkkaTestSystem/user/$e/rmq-connection#-482129350] 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'. 11:05:23.679 [INFO ] [AkkaTestSystem-akka.actor.default-dispatcher-18] akka://AkkaTestSystem/user/$e o.e.d.s.c.m.r.RabbitMQClientActor - Established RMQ connection: mockConnection 11:05:23.680 [INFO ] [AkkaTestSystem-akka.actor.default-dispatcher-18] akka://AkkaTestSystem/user/$e o.e.d.s.c.m.r.RabbitMQClientActor - MessageMappingProcessor already instantiated, don't initialize again.. 11:05:23.680 [INFO ] [AkkaTestSystem-akka.actor.default-dispatcher-18] akka://AkkaTestSystem/user/$e o.e.d.s.c.m.r.RabbitMQClientActor - Received ClientConnected 11:05:23.680 [INFO ] [AkkaTestSystem-akka.actor.default-dispatcher-18] akka://AkkaTestSystem/user/$e o.e.d.s.c.m.r.RabbitMQClientActor - Transition: CONNECTING -> CONNECTED 11:05:23.682 [INFO ] [AkkaTestSystem-akka.actor.default-dispatcher-3] akka://AkkaTestSystem/user/$e o.e.d.s.c.m.r.RabbitMQClientActor - Did set up publisher channel: mockChannel 11:05:23.682 [INFO ] [AkkaTestSystem-akka.actor.default-dispatcher-3] akka.tcp://AkkaTestSystem@172.30.206.106:2552/user/$e/rmq-connection c.n.a.r.ConnectionActor - akka://AkkaTestSystem/user/$e/rmq-connection connected to amqp://null@null:0/null 11:05:23.682 [INFO ] [AkkaTestSystem-akka.actor.default-dispatcher-3] akka://AkkaTestSystem/user/$e o.e.d.s.c.m.r.RabbitMQClientActor - Reconnected successfully 11:05:23.682 [INFO ] [AkkaTestSystem-akka.actor.default-dispatcher-3] akka.tcp://AkkaTestSystem@172.30.206.106:2552/user/$e/rmq-connection/publisher-channel c.n.a.r.ChannelActor - akka://AkkaTestSystem/user/$e/rmq-connection/publisher-channel connected 11:05:23.683 [INFO ] [AkkaTestSystem-akka.actor.default-dispatcher-15] akka://AkkaTestSystem/user/$e o.e.d.s.c.m.r.RabbitMQClientActor - Did set up consumer channel: mockChannel 11:05:23.683 [INFO ] [AkkaTestSystem-akka.actor.default-dispatcher-15] akka://AkkaTestSystem/user/$e o.e.d.s.c.m.r.RabbitMQClientActor - Starting to consume queues... 11:05:23.685 [INFO ] [AkkaTestSystem-akka.actor.default-dispatcher-15] akka.tcp://AkkaTestSystem@172.30.206.106:2552/user/$e/rmq-connection/consumer-channel c.n.a.r.ChannelActor - akka://AkkaTestSystem/user/$e/rmq-connection/consumer-channel connected