public class QueueEnqueueImpl extends java.lang.Object implements IQueueEnqueue
Constructor and Description |
---|
QueueEnqueueImpl(SimpleFIFOQueue impl) |
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
IQueueEnqueue.enqueue_prepare(Event[]) |
void |
enqueue_commit(java.lang.Object enqueue_key)
Commit a set of Event instances previously prepared via
IQueueEnqueue.enqueue_prepare(Event[]) |
boolean |
enqueue_lossy(Event element)
Enqueue the given event with lossy enqueuing.
|
java.lang.Object |
enqueue_prepare(Event[] elements)
Prepare an enqueue of a set of Event instances.
|
void |
enqueue(Event element)
Enqueue a given Event onto the underlying queue
|
void |
enqueue(Event[] elements)
Enqueue a set of events Event onto the underlying queue
|
IEnqueueProcessor |
getEnqueueProcessor()
Get enqueue processor for this queue.
|
void |
setEnqueueProcessor(IEnqueueProcessor pred)
Set enqueue processor for this queue.
|
int |
size()
Return size of contents in queue
|
public QueueEnqueueImpl(SimpleFIFOQueue impl)
public void enqueue(Event element) throws QueueException
IQueueEnqueue
enqueue
in interface IQueueEnqueue
element
- QueueException
- not thrown by this implementation.public void enqueue(Event[] elements) throws QueueException
IQueueEnqueue
enqueue
in interface IQueueEnqueue
elements
- the Events to enqueueQueueException
- thrown if events cannot be enqueuedpublic java.lang.Object enqueue_prepare(Event[] elements) throws QueueException
IQueueEnqueue
IQueueEnqueue.enqueue_commit(Object)
, or to abort the prepared
enqueue transaction IQueueEnqueue.enqueue_abort(Object)
enqueue_prepare
in interface IQueueEnqueue
elements
- QueueException
- not thrown by this implementation.public void enqueue_commit(java.lang.Object enqueue_key)
IQueueEnqueue
IQueueEnqueue.enqueue_prepare(Event[])
enqueue_commit
in interface IQueueEnqueue
enqueue_key
- the transaction key previously returned from the call to
IQueueEnqueue.enqueue_prepare(Event[])
public void enqueue_abort(java.lang.Object enqueue_key)
IQueueEnqueue
IQueueEnqueue.enqueue_prepare(Event[])
enqueue_abort
in interface IQueueEnqueue
enqueue_key
- the transaction key previously returned from the call to
IQueueEnqueue.enqueue_prepare(Event[])
public boolean enqueue_lossy(Event element)
IQueueEnqueue
enqueue_lossy
in interface IQueueEnqueue
element
- the event topublic void setEnqueueProcessor(IEnqueueProcessor pred)
IQueueEnqueue
setEnqueueProcessor
in interface IQueueEnqueue
pred
- the IEnqueueProcessor for this queue. Should not be null.public IEnqueueProcessor getEnqueueProcessor()
IQueueEnqueue
IQueueEnqueue.setEnqueueProcessor(IEnqueueProcessor)
. Returns null if no
enqueue processor previously assignedgetEnqueueProcessor
in interface IQueueEnqueue
IQueueEnqueue.setEnqueueProcessor(IEnqueueProcessor)
public int size()
IQueueEnqueue
size
in interface IQueueEnqueue