public interface IQueueEnqueue
| Modifier and Type | Method and Description |
|---|---|
void |
enqueue_abort(Object enqueue_key)
Abort the commit of a set of Event instances previously prepared via
enqueue_prepare(Event[]) |
void |
enqueue_commit(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.
|
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 enqueuedObject 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(Object enqueue_key)
enqueue_prepare(Event[])enqueue_key - the transaction key previously returned from the call to
enqueue_prepare(Event[])void enqueue_abort(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()
Copyright © 2004–2020 Eclipse Foundation. All rights reserved.