|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface IQueueEnqueue
Queue enqueing semantics
Method Summary | |
---|---|
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 |
Method Detail |
---|
void enqueue(Event event) throws QueueException
event
- the Event to enqueue
QueueException
- thrown if event cannot be enqueuedvoid enqueue(Event[] events) throws QueueException
events
- the Events to enqueue
QueueException
- 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 enqueue
QueueException
- 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 to
void setEnqueueProcessor(IEnqueueProcessor processor)
processor
- the IEnqueueProcessor for this queue. Should not be null.IEnqueueProcessor getEnqueueProcessor()
setEnqueueProcessor(IEnqueueProcessor)
. Returns null if no
enqueue processor previously assigned
setEnqueueProcessor(IEnqueueProcessor)
int size()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |