public interface IQueueEnqueue
Modifier and Type | Method and Description |
---|---|
void |
enqueue_abort(java.lang.Object enqueue_key)
Abort the commit of a set of Event instances previously prepared via
enqueue_prepare(Event[]) |
void |
enqueue_commit(java.lang.Object enqueue_key)
Commit a set of Event instances previously prepared via
enqueue_prepare(Event[]) |
boolean |
enqueue_lossy(Event event)
Enqueue the given event with lossy enqueuing.
|
java.lang.Object |
enqueue_prepare(Event[] events)
Prepare an enqueue of a set of Event instances.
|
void |
enqueue(Event event)
Enqueue a given Event onto the underlying queue
|
void |
enqueue(Event[] events)
Enqueue a set of events Event onto the underlying queue
|
IEnqueueProcessor |
getEnqueueProcessor()
Get enqueue processor for this queue.
|
void |
setEnqueueProcessor(IEnqueueProcessor processor)
Set enqueue processor for this queue.
|
int |
size()
Return size of contents in queue
|
void enqueue(Event event) throws QueueException
event
- the Event to enqueueQueueException
- thrown if event cannot be enqueuedvoid enqueue(Event[] events) throws QueueException
events
- the Events to enqueueQueueException
- thrown if events cannot be enqueuedjava.lang.Object enqueue_prepare(Event[] events) throws QueueException
enqueue_commit(Object)
, or to abort the prepared
enqueue transaction enqueue_abort(Object)
events
- the events to enqueueQueueException
- if preparation for enqueue cannot occurvoid enqueue_commit(java.lang.Object enqueue_key)
enqueue_prepare(Event[])
enqueue_key
- the transaction key previously returned from the call to
enqueue_prepare(Event[])
void enqueue_abort(java.lang.Object enqueue_key)
enqueue_prepare(Event[])
enqueue_key
- the transaction key previously returned from the call to
enqueue_prepare(Event[])
boolean enqueue_lossy(Event event)
event
- the event tovoid setEnqueueProcessor(IEnqueueProcessor processor)
processor
- the IEnqueueProcessor for this queue. Should not be null.IEnqueueProcessor getEnqueueProcessor()
setEnqueueProcessor(IEnqueueProcessor)
. Returns null if no
enqueue processor previously assignedsetEnqueueProcessor(IEnqueueProcessor)
int size()