org.openorb.notify.queue
Class LoggedSupplierProxyQueue

java.lang.Object
  |
  +--org.openorb.notify.queue.DefaultEventQueue
        |
        +--org.openorb.notify.queue.SupplierProxyQueue
              |
              +--org.openorb.notify.queue.LoggedSupplierProxyQueue

All Implemented Interfaces:

EventQueue, FilterableEventQueue

public class LoggedSupplierProxyQueue

extends SupplierProxyQueue

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. The SupplierPersistentEventQueue differs from the PersistentEventQueue as upon the pull operation it returns an event object Structure, Any, Types ) and not a Pid.

Author:

Olivier Modica

Constructor Summary

LoggedSupplierProxyQueue(java.lang.String id, int orderPolicy, boolean isPersistent, boolean isEventsLogged, boolean isFiltersEvaluationLogged, org.apache.avalon.framework.logger.Logger logger)
Constructor with specified order policy

Methods inherited from class org.openorb.notify.queue.SupplierProxyQueue

addFilter, filterAndPushEvent, filterAndPushEvent, filterAndPushEvent, pullEvent, pushEvent, removeAllFilters, removeFilter, updateFilter

Methods inherited from class org.openorb.notify.queue.DefaultEventQueue

getQueueSize, isEmpty, pushEvent, setOrderPolicy

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.openorb.notify.queue.EventQueue

getQueueSize, isEmpty, pushEvent, setOrderPolicy

Constructor Detail

LoggedSupplierProxyQueue

public LoggedSupplierProxyQueue(java.lang.String id,
                                int orderPolicy,
                                boolean isPersistent,
                                boolean isEventsLogged,
                                boolean isFiltersEvaluationLogged,
                                org.apache.avalon.framework.logger.Logger logger)

Constructor with specified order policy