org.openorb.notify.queue
Class LoggedConsumerProxyQueue
java.lang.Object
|
+--org.openorb.notify.queue.DefaultEventQueue
|
+--org.openorb.notify.queue.ConsumerProxyQueue
|
+--org.openorb.notify.queue.LoggedConsumerProxyQueue
- All Implemented Interfaces:
- EventQueue, FilterableEventQueue
- public class LoggedConsumerProxyQueue
- extends ConsumerProxyQueue
An event queue is an object into which events are pushed and pulled.
Pushing an event is adding an event to this queue, pulling an event
is retrieving an event from this queue.
Events in the queue can be either Untyped, Structured, StructuredSequence
and Type events.
The filtrable event queue adds support for filters and is able to decide
if an event must be enqueued or discarded.
The persistent event queue adds support for persistence. Upon receiving an
event, it will be saved persistently until the event channel aggregate it has
been received by all consumers.
- Author:
- Olivier Modica
|
Constructor Summary |
LoggedConsumerProxyQueue(java.lang.String id,
int orderPolicy,
boolean isPersistent,
short priority,
long deadline,
boolean isPerformance,
boolean isEventsLogged,
boolean isFiltersEvaluationLogged,
org.apache.avalon.framework.logger.Logger logger)
Constructor with specified order policy |
| Methods inherited from class org.openorb.notify.queue.ConsumerProxyQueue |
addFilter, filterAndPushEvent, filterAndPushEvent, filterAndPushEvent, persistAndPushEvent, persistAndPushEvent, persistAndPushEvent, pullEvent, pushEvent, removeAllFilters, removeFilter, updateFilter |
| Methods inherited from class java.lang.Object |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
LoggedConsumerProxyQueue
public LoggedConsumerProxyQueue(java.lang.String id,
int orderPolicy,
boolean isPersistent,
short priority,
long deadline,
boolean isPerformance,
boolean isEventsLogged,
boolean isFiltersEvaluationLogged,
org.apache.avalon.framework.logger.Logger logger)
- Constructor with specified order policy