public class QueueEnqueueImpl extends Object implements IQueueEnqueue
| Constructor and Description |
|---|
QueueEnqueueImpl(SimpleFIFOQueue impl) |
| Modifier and Type | Method and Description |
|---|---|
void |
enqueue_abort(Object enqueue_key)
Abort the commit of a set of Event instances previously prepared via
IQueueEnqueue.enqueue_prepare(Event[]) |
void |
enqueue_commit(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.
|
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
IQueueEnqueueenqueue in interface IQueueEnqueueelement - QueueException - not thrown by this implementation.public void enqueue(Event[] elements) throws QueueException
IQueueEnqueueenqueue in interface IQueueEnqueueelements - the Events to enqueueQueueException - thrown if events cannot be enqueuedpublic Object enqueue_prepare(Event[] elements) throws QueueException
IQueueEnqueueIQueueEnqueue.enqueue_commit(Object), or to abort the prepared
enqueue transaction IQueueEnqueue.enqueue_abort(Object)enqueue_prepare in interface IQueueEnqueueelements - QueueException - not thrown by this implementation.public void enqueue_commit(Object enqueue_key)
IQueueEnqueueIQueueEnqueue.enqueue_prepare(Event[])enqueue_commit in interface IQueueEnqueueenqueue_key - the transaction key previously returned from the call to
IQueueEnqueue.enqueue_prepare(Event[])public void enqueue_abort(Object enqueue_key)
IQueueEnqueueIQueueEnqueue.enqueue_prepare(Event[])enqueue_abort in interface IQueueEnqueueenqueue_key - the transaction key previously returned from the call to
IQueueEnqueue.enqueue_prepare(Event[])public boolean enqueue_lossy(Event element)
IQueueEnqueueenqueue_lossy in interface IQueueEnqueueelement - the event topublic void setEnqueueProcessor(IEnqueueProcessor pred)
IQueueEnqueuesetEnqueueProcessor in interface IQueueEnqueuepred - the IEnqueueProcessor for this queue. Should not be null.public IEnqueueProcessor getEnqueueProcessor()
IQueueEnqueueIQueueEnqueue.setEnqueueProcessor(IEnqueueProcessor). Returns null if no
enqueue processor previously assignedgetEnqueueProcessor in interface IQueueEnqueueIQueueEnqueue.setEnqueueProcessor(IEnqueueProcessor)public int size()
IQueueEnqueuesize in interface IQueueEnqueueCopyright © 2004–2020 Eclipse Foundation. All rights reserved.