org.openorb.notify.queue
public class SupplierProxyQueue extends DefaultEventQueue implements FilterableEventQueue
Constructor Summary | |
---|---|
SupplierProxyQueue(String id, int orderPolicy, boolean isPersistent, Logger logger)
Constructor with specified order policy |
Method Summary | |
---|---|
boolean | addFilter(Filter filter)
Add a filter to the event queue filter list |
boolean | filterAndPushEvent(Any event)
Filter and push an event into the queue |
boolean | filterAndPushEvent(StructuredEvent event)
Filter and push a structured event into the queue |
boolean | filterAndPushEvent(Property[] event)
Filter 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 |