org.openorb.notify.queue
public class ConsumerProxyQueue extends DefaultEventQueue implements FilterableEventQueue
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 |