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

Class PersistentQueue

java.lang.Object

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

All Implemented Interfaces:

java.lang.AutoCloseable

public class PersistentQueue
extends java.lang.Object
implements java.lang.AutoCloseable

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PersistentQueue.Subscriber

Method Summary

Modifier and Type	Method and Description
void	close()
static PersistentQueue	createFor(java.lang.String taskId)
void	put(io.vertx.core.json.JsonObject js)
ISubscriber	subscriber(int offset)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

createFor

public static PersistentQueue createFor(java.lang.String taskId)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

put

public void put(io.vertx.core.json.JsonObject js)

subscriber

public ISubscriber subscriber(int offset)

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable