|
||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.openorb.notify.queue.DefaultEventQueue
org.openorb.notify.queue.AdminQueue
public class AdminQueue
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.
Constructor Summary | |
---|---|
AdminQueue(java.lang.String id,
int orderPolicy,
boolean isPersistent,
org.apache.avalon.framework.logger.Logger logger)
Constructor with specified order policy |
Method Summary | |
---|---|
boolean |
addFilter(Filter filter)
Add a filter to the event queue filter list |
boolean |
filterAndPushEvent(org.omg.CORBA.Any event)
Filter and push an event into the queue |
boolean |
filterAndPushEvent(Property[] event)
Filter and push a typed event into the queue |
boolean |
filterAndPushEvent(StructuredEvent event)
Filter and push a structured event into the queue |
java.lang.Object |
pullEvent()
Pull an event from the queue |
boolean |
pushEvent(java.lang.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 |
void |
setFiltersEvaluationLogged(boolean filtersEvaluationLogged)
|
boolean |
updateFilter(Filter filter)
Update a filter to the event queue filter list |
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 |
---|
public AdminQueue(java.lang.String id, int orderPolicy, boolean isPersistent, org.apache.avalon.framework.logger.Logger logger)
Method Detail |
---|
public boolean pushEvent(java.lang.Object event)
pushEvent
in interface EventQueue
pushEvent
in class DefaultEventQueue
public java.lang.Object pullEvent()
pullEvent
in interface EventQueue
pullEvent
in class DefaultEventQueue
public boolean filterAndPushEvent(org.omg.CORBA.Any event)
public boolean filterAndPushEvent(StructuredEvent event)
public boolean filterAndPushEvent(Property[] event)
public boolean addFilter(Filter filter)
addFilter
in interface FilterableEventQueue
public boolean updateFilter(Filter filter)
updateFilter
in interface FilterableEventQueue
public boolean removeFilter(Filter filter)
removeFilter
in interface FilterableEventQueue
public void removeAllFilters()
removeAllFilters
in interface FilterableEventQueue
public void setFiltersEvaluationLogged(boolean filtersEvaluationLogged)
|
||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |