org.openorb.notify.queue

Class ConsumerProxyQueue

public class ConsumerProxyQueue extends DefaultEventQueue implements FilterableEventQueue

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 filterable 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
	ConsumerProxyQueue(String id, int orderPolicy, boolean isPersistent, short priority, long deadline, boolean isPerformance, Logger logger) Constructor with specified order policy

Method Summary
boolean	addFilter(Filter filter) Add a filter to the event queue filter list
boolean	persistAndPushEvent(Any event) Filter and push an event into the queue
boolean	persistAndPushEvent(StructuredEvent event) Persist and push a structured event into the queue
boolean	persistAndPushEvent(Property[] event) Persist and push a typed event into the queue
Object	pullEvent() Pull an event from the queue
boolean	pushEvent(Object event) Filter and push the event
void	removeAllFilters() Remove all filters from the event queue filter list
boolean	removeFilter(Filter filter) Remove a filter from the event queue filter list
boolean	updateFilter(Filter filter) Update a filter to the event queue filter list

Class ConsumerProxyQueue

Constructor Detail

ConsumerProxyQueue

Method Detail

addFilter

persistAndPushEvent

persistAndPushEvent

persistAndPushEvent

pullEvent

pushEvent

removeAllFilters

removeFilter

updateFilter