remove obsolete unit test, functionality was removed

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
eclipse-ditto · Jan 26, 2022 · 3453419 · 3453419
1 parent 9c0e120
commit 3453419
Showing 1 changed file with 0 additions and 36 deletions.
diff --git a/...st/java/org/eclipse/ditto/thingsearch/service/updater/actors/BackgroundSyncActorTest.java b/...st/java/org/eclipse/ditto/thingsearch/service/updater/actors/BackgroundSyncActorTest.java
@@ -195,42 +195,6 @@ public void resettingHealthEventsAfterSyncStreamFailureClearsErrors() {
 
     }
 
-//    @Test
-//    public void providesHealthWarningWhenSameThingIsSynchronizedTwice() {
-//        final Metadata indexedThingMetadata = Metadata.of(THING_ID, 2, null, null, null);
-//        final long persistedRevision = indexedThingMetadata.getThingRevision() + 1;
-//
-//        new TestKit(actorSystem) {{
-//            whenSearchPersistenceHasIndexedThings(List.of(indexedThingMetadata));
-//            whenTimestampPersistenceProvidesTaggedTimestamp();
-//
-//            final ActorRef underTest = thenCreateBackgroundSyncActor(this);
-//
-//            // first synchronization stream
-//            expectSyncActorToStartStreaming(pubSub);
-//            thenRespondWithPersistedThingsStream(pubSub, List.of(createStreamedSnapshot(THING_ID, persistedRevision)));
-//            expectSyncActorToRequestThingUpdatesInSearch(thingsUpdater,
-//                    List.of(UpdateThing.of(THING_ID, true, false, UpdateReason.BACKGROUND_SYNC, HEADERS)));
-//
-//            // second synchronization stream
-//            whenSearchPersistenceHasIndexedThings(List.of(indexedThingMetadata));
-//            expectSyncActorToStartStreaming(pubSub, backgroundSyncConfig.getIdleTimeout());
-//            thenRespondWithPersistedThingsStream(pubSub, List.of(createStreamedSnapshot(THING_ID, persistedRevision)));
-//            expectSyncActorToRequestThingUpdatesInSearch(thingsUpdater,
-//                    List.of(UpdateThing.of(THING_ID, true, false, UpdateReason.BACKGROUND_SYNC, HEADERS)));
-//
-//            // expect health to have events for both runs
-//            syncActorShouldHaveHealth(underTest, this, StatusInfo.Status.UP, List.of(StatusDetailMessage.Level.WARN),
-//                    detailMessages -> {
-//                        final String events = detailMessages.stream()
-//                                .map(StatusDetailMessage::getMessage)
-//                                .map(JsonValue::toString)
-//                                .collect(Collectors.joining());
-//                        assertThat(events).contains(indexedThingMetadata.invalidateCaches(true, false).toString());
-//                    });
-//        }};
-//    }
-
     @Test
     public void noHealthWarningAfterSuccessfulStream() {
         final Metadata indexedThingMetadata = Metadata.of(THING_ID, 2, null, null, null);