[sling-org-apache-sling-distribution-journal] branch master updated: SLING-9546 - fix timing issue in SubscriberTest.testReceiveDelete test (#44)

[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 cd2ba50  SLING-9546 - fix timing issue in 
SubscriberTest.testReceiveDelete test (#44)
cd2ba50 is described below

commit cd2ba50b94c3745fcfba09003f2835da41e487c8
Author: Timothee Maret <tma...@apache.org>
AuthorDate: Wed Jun 24 11:52:57 2020 +0200

    SLING-9546 - fix timing issue in SubscriberTest.testReceiveDelete test (#44)
---
 .../sling/distribution/journal/impl/subscriber/SubscriberTest.java  | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

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 d21c41a..ba955d2 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
@@ -247,9 +247,13 @@ public class SubscriberTest {
         MessageInfo info = new TestMessageInfo("", 1, 0, 0);
 
         PackageMessage message = BASIC_DEL_PACKAGE;
-
+        final Semaphore sem = new Semaphore(0);
+        when(packageBuilder.installPackage(Mockito.any(ResourceResolver.class),
+                Mockito.any(ByteArrayInputStream.class))
+        ).thenAnswer(new WaitFor(sem));
         packageHandler.handle(info, message);
         waitSubscriber(RUNNING);
+        sem.release();
         waitSubscriber(IDLE);
         try (ResourceResolver resolver = 
resolverFactory.getServiceResourceResolver(null)) {
             assertThat(resolver.getResource("/test"), nullValue());