Skip to content

Passed

org.eclipse.ditto.connectivity.service.messaging.amqp.AmqpClientActorTest.testConsumeMessageForSourcesWithSameAddress

Took 0.36 sec.

Standard Output

14:05:05.101 [INFO ] [PekkoTestSystem-pekko.actor.default-dispatcher-14] o.e.d.c.s.m.a.AmqpClientActor - ServiceUnbind State=<CONNECTED> unsubscribing from pubsub and stopping consumers
14:05:05.139 [INFO ] [PekkoTestSystem-pekko.actor.default-dispatcher-11] o.e.d.i.u.p.a.AckUpdater - Scheduling cluster state sync at <PT5M28.823S> interval (min=<PT5M>)
14:05:05.139 [INFO ] [PekkoTestSystem-pekko.actor.default-dispatcher-6] o.e.d.i.u.p.a.AckUpdater - Got <CurrentClusterState(TreeSet(), Set(), Set
...[truncated 12100 chars]...
tto:thing, ditto-inbound-payload-mapper=default}]
14:05:05.462 [INFO ] [PekkoTestSystem-pekko.actor.default-dispatcher-11] o.e.d.e.s.a.AcknowledgementAggregatorActor - Starting to wait for all requested acknowledgements <[twin-persisted]> for a maximum duration of <PT1M5S>.
14:05:05.462 [INFO ] [PekkoTestSystem-pekko.actor.default-dispatcher-12] o.e.d.e.s.a.AcknowledgementAggregatorActor - Starting to wait for all requested acknowledgements <[twin-persisted]> for a maximum duration of <PT1M5S>.