Skip to content

Passed

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

Took 0.47 sec.

Standard Output

15:06:13.370 [INFO ] [PekkoTestSystem-pekko.actor.default-dispatcher-14] o.e.d.c.s.m.a.AmqpClientActor - ServiceUnbind State=<CONNECTED> unsubscribing from pubsub and stopping consumers
15:06:13.417 [INFO ] [PekkoTestSystem-pekko.actor.default-dispatcher-8] o.e.d.i.u.p.a.AckUpdater - Scheduling cluster state sync at <PT8M56.859S> interval (min=<PT5M>)
15:06:13.417 [INFO ] [PekkoTestSystem-pekko.actor.default-dispatcher-8] o.e.d.i.u.p.a.AckUpdater - Got <CurrentClusterState(TreeSet(), Set(), Set(
...[truncated 11875 chars]...
tion-6345a928-3377-4cb2-bcd1-abb24f3619e9, ditto-auth-context={"type":"pre-authenticated-connection","subjects":["source:subject"]}, correlation-id=cid, reply-to=replies, content-type=application/json, ditto-entity-id=thing:ditto:thing, ditto-inbound-payload-mapper=default}]
15:06:13.843 [INFO ] [PekkoTestSystem-pekko.actor.default-dispatcher-8] o.e.d.e.s.a.AcknowledgementAggregatorActor - Starting to wait for all requested acknowledgements <[twin-persisted]> for a maximum duration of <PT1M5S>.