Class PackageQueuedNotifier
- java.lang.Object
-
- org.apache.sling.distribution.journal.impl.publisher.PackageQueuedNotifier
-
- All Implemented Interfaces:
Closeable
,AutoCloseable
,QueuedCallback
public class PackageQueuedNotifier extends Object implements QueuedCallback, Closeable
-
-
Constructor Summary
Constructors Constructor Description PackageQueuedNotifier(org.osgi.service.event.EventAdmin eventAdmin)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
void
queued(List<org.apache.sling.distribution.journal.FullMessage<org.apache.sling.distribution.journal.messages.PackageMessage>> fullMessages)
CompletableFuture<Long>
registerWait(String packageId)
void
unRegisterWait(String packageId)
-
-
-
Method Detail
-
registerWait
public CompletableFuture<Long> registerWait(String packageId)
-
unRegisterWait
public void unRegisterWait(String packageId)
-
queued
public void queued(List<org.apache.sling.distribution.journal.FullMessage<org.apache.sling.distribution.journal.messages.PackageMessage>> fullMessages)
- Specified by:
queued
in interfaceQueuedCallback
-
close
public void close()
- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
-
-