fixed ConnectionIdsRetrievalActorTest

Signed-off-by: Thomas Jäckle <thomas.jaeckle@beyonnex.io>
eclipse-ditto · Oct 9, 2023 · f3ed2ea · f3ed2ea
1 parent 97a42da
commit f3ed2ea
Showing 1 changed file with 9 additions and 10 deletions.
diff --git a/...ava/org/eclipse/ditto/connectivity/service/messaging/ConnectionIdsRetrievalActorTest.java b/...ava/org/eclipse/ditto/connectivity/service/messaging/ConnectionIdsRetrievalActorTest.java
@@ -24,28 +24,27 @@
 import java.util.UUID;
 import java.util.concurrent.TimeUnit;
 
+import org.apache.pekko.actor.ActorRef;
+import org.apache.pekko.actor.ActorSystem;
+import org.apache.pekko.actor.Props;
+import org.apache.pekko.stream.javadsl.Source;
+import org.apache.pekko.testkit.javadsl.TestKit;
 import org.bson.Document;
 import org.eclipse.ditto.base.model.headers.DittoHeaders;
 import org.eclipse.ditto.connectivity.model.ConnectivityInternalErrorException;
-import org.eclipse.ditto.connectivity.service.config.ConnectionIdsRetrievalConfig;
-import org.eclipse.ditto.connectivity.service.messaging.persistence.ConnectionPersistenceActor;
-import org.eclipse.ditto.internal.utils.persistence.mongo.streaming.MongoReadJournal;
 import org.eclipse.ditto.connectivity.model.signals.commands.ConnectivityErrorResponse;
 import org.eclipse.ditto.connectivity.model.signals.commands.query.RetrieveAllConnectionIds;
 import org.eclipse.ditto.connectivity.model.signals.commands.query.RetrieveAllConnectionIdsResponse;
 import org.eclipse.ditto.connectivity.model.signals.events.ConnectionCreated;
 import org.eclipse.ditto.connectivity.model.signals.events.ConnectionDeleted;
+import org.eclipse.ditto.connectivity.service.config.ConnectionIdsRetrievalConfig;
+import org.eclipse.ditto.connectivity.service.messaging.persistence.ConnectionPersistenceActor;
+import org.eclipse.ditto.internal.utils.persistence.mongo.streaming.MongoReadJournal;
 import org.junit.AfterClass;
 import org.junit.Before;
 import org.junit.BeforeClass;
 import org.junit.Test;
 
-import org.apache.pekko.actor.ActorRef;
-import org.apache.pekko.actor.ActorSystem;
-import org.apache.pekko.actor.Props;
-import org.apache.pekko.stream.javadsl.Source;
-import org.apache.pekko.testkit.javadsl.TestKit;
-
 /**
  * Tests {@link ConnectionIdsRetrievalActor}.
  */
@@ -125,7 +124,7 @@ public void internalErrorShouldResultInErrorResponse() {
     }
 
     private static Document doc(final String id) {
-        return new Document("_id", pid(id));
+        return new Document("_id", pid(id)).append(MongoReadJournal.LIFECYCLE, "ACTIVE");
     }
 
     private static String pid(final String id) {