net.bluemind.core.task.service.internal.cq

Class PersistentQueue.Subscriber

java.lang.Object

net.bluemind.core.task.service.internal.cq.PersistentQueue.Subscriber

All Implemented Interfaces:

ISubscriber

Enclosing class:

PersistentQueue

public static class PersistentQueue.Subscriber
extends java.lang.Object
implements ISubscriber

Method Summary

Modifier and Type	Method and Description
void	fetchAll(java.util.function.Consumer<io.vertx.core.json.JsonObject> handler)
io.vertx.core.json.JsonObject	fetchOne()
java.lang.String	taskId()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

fetchAll

public void fetchAll(java.util.function.Consumer<io.vertx.core.json.JsonObject> handler)

Specified by:

fetchAll in interface ISubscriber

fetchOne

public io.vertx.core.json.JsonObject fetchOne()

Specified by:

fetchOne in interface ISubscriber

taskId

public java.lang.String taskId()

Specified by:

taskId in interface ISubscriber