#537 fixed test

Signed-off-by: krj1imb <johannes.schneider@bosch-si.com>
eclipse-ditto · Oct 30, 2019 · 6688606 · 6688606
1 parent fe436e5
commit 6688606
Showing 1 changed file with 7 additions and 7 deletions.
diff --git a/...java/org/eclipse/ditto/services/utils/persistence/mongo/streaming/MongoReadJournalIT.java b/...java/org/eclipse/ditto/services/utils/persistence/mongo/streaming/MongoReadJournalIT.java
@@ -119,7 +119,7 @@ public void getEmptyStream() {
     @Test
     public void streamJournals() {
         insert("test_journal", new Document().append("pid", "pid1").append("to", 1L));
-        insert("test_journal@ns2", new Document().append("pid", "pid2").append("to", 2L));
+        insert("test_journal", new Document().append("pid", "pid2").append("to", 2L));
         final List<PidWithSeqNr> pids =
                 readJournal.getPidWithSeqNrsByInterval(Instant.EPOCH, Instant.now().plusSeconds(500L))
                         .runWith(Sink.seq(), materializer)
@@ -132,7 +132,7 @@ public void streamJournals() {
     @Test
     public void streamSnapshotStores() {
         insert("test_snaps", new Document().append("pid", "pid3").append("sn", 3L));
-        insert("test_snaps@ns2", new Document().append("pid", "pid4").append("sn", 4L));
+        insert("test_snaps", new Document().append("pid", "pid4").append("sn", 4L));
         final List<PidWithSeqNr> pids =
                 readJournal.getPidWithSeqNrsByInterval(Instant.EPOCH, Instant.now().plusSeconds(500L))
                         .runWith(Sink.seq(), materializer)
@@ -144,12 +144,12 @@ public void streamSnapshotStores() {
 
     @Test
     public void extractJournalPidsFromEventsAndNotSnapshots() {
-        insert("test_journal@ns2", new Document().append("pid", "pid3").append("to", 2L));
-        insert("test_journal@ns2", new Document().append("pid", "pid4").append("to", 2L));
+        insert("test_journal", new Document().append("pid", "pid3").append("to", 2L));
+        insert("test_journal", new Document().append("pid", "pid4").append("to", 2L));
         insert("test_journal", new Document().append("pid", "pid1").append("to", 1L));
         insert("test_journal", new Document().append("pid", "pid2").append("to", 1L));
         insert("test_snaps", new Document().append("pid", "pid5").append("sn", 3L));
-        insert("test_snaps@ns2", new Document().append("pid", "pid6").append("sn", 4L));
+        insert("test_snaps", new Document().append("pid", "pid6").append("sn", 4L));
 
         final List<String> pids =
                 readJournal.getJournalPids(2, Duration.ZERO, materializer)
@@ -163,8 +163,8 @@ public void extractJournalPidsFromEventsAndNotSnapshots() {
     public void extractJournalPidsAboveALowerBound() {
         insert("test_journal", new Document().append("pid", "pid1").append("to", 1L));
         insert("test_journal", new Document().append("pid", "pid2").append("to", 1L));
-        insert("test_journal@ns2", new Document().append("pid", "pid3").append("to", 2L));
-        insert("test_journal@ns2", new Document().append("pid", "pid4").append("to", 2L));
+        insert("test_journal", new Document().append("pid", "pid3").append("to", 2L));
+        insert("test_journal", new Document().append("pid", "pid4").append("to", 2L));
 
         final List<String> pids =
                 readJournal.getJournalPidsAbove("pid2", 2, Duration.ZERO, materializer)