[sling-org-apache-sling-distribution-journal] branch master updated: SLING-10254 - Test the side effect instead of the queue states

[tmaret]

This is an automated email from the ASF dual-hosted git repository.

tmaret pushed a commit to branch master
in repository 
https://gitbox.apache.org/repos/asf/sling-org-apache-sling-distribution-journal.git


The following commit(s) were added to refs/heads/master by this push:
     new 787e79f  SLING-10254 - Test the side effect instead of the queue states
787e79f is described below

commit 787e79f07a4a165eda5d95a17aafe490f1aea906
Author: tmaret <tma...@adobe.com>
AuthorDate: Tue Mar 23 13:24:02 2021 +0100

    SLING-10254 - Test the side effect instead of the queue states
---
 .../journal/impl/subscriber/SubscriberTest.java           | 15 +++------------
 1 file changed, 3 insertions(+), 12 deletions(-)

diff --git 
a/src/test/java/org/apache/sling/distribution/journal/impl/subscriber/SubscriberTest.java
 
b/src/test/java/org/apache/sling/distribution/journal/impl/subscriber/SubscriberTest.java
index df3ce53..9273da3 100644
--- 
a/src/test/java/org/apache/sling/distribution/journal/impl/subscriber/SubscriberTest.java
+++ 
b/src/test/java/org/apache/sling/distribution/journal/impl/subscriber/SubscriberTest.java
@@ -289,26 +289,17 @@ public class SubscriberTest {
     }
 
     @Test
-    public void testReceiveDelete() throws DistributionException, 
LoginException, PersistenceException {
+    public void testReceiveDelete() throws LoginException, 
PersistenceException {
         assumeNoPrecondition();
         initSubscriber();
         waitSubscriber(IDLE);
-
-        final Semaphore sem = new Semaphore(0);
-        whenInstallPackage()
-            .thenAnswer(new WaitFor(sem));
-
         createResource("/test");
-        MessageInfo info = createInfo(0l);
+        MessageInfo info = createInfo(0L);
         PackageMessage message = BASIC_DEL_PACKAGE;
         packageHandler.handle(info, message);
-        
-        waitSubscriber(RUNNING);
-        sem.release();
-        
         waitSubscriber(IDLE);
+        await().atMost(30, SECONDS).until(() -> getResource("/test") == null);
         verifyNoStatusMessageSent();
-        assertThat(getResource("/test"), nullValue());
     }
 
     /**