This is an automated email from the ASF dual-hosted git repository. tmaret pushed a commit to branch SLING-9546-1 in repository https://gitbox.apache.org/repos/asf/sling-org-apache-sling-distribution-journal.git
commit 06e208c2f524ffa3651ba0dfdc9a5c402d6ef40d Author: tmaret <[email protected]> AuthorDate: Wed Jun 24 11:44:25 2020 +0200 SLING-9546 - fix timing issue in SubscriberTest.testReceiveDelete test --- .../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());
