org.openorb.notify.queue
Class EventQueueFactory

java.lang.Object
  |
  +--org.openorb.notify.queue.EventQueueFactory

public class EventQueueFactory

extends java.lang.Object

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

EventQueueFactory()

Method Summary

static FilterableEventQueue	createAdminQueue(java.lang.String id, PropertiesRepository props, boolean isEventsLogged, boolean isFiltersEvaluationLogged, org.apache.avalon.framework.logger.Logger logger)
static FilterableEventQueue	createConsumerProxyQueue(java.lang.String id, PropertiesRepository props, boolean isPerformance, boolean isEventsLogged, boolean isFiltersEvaluationLogged, org.apache.avalon.framework.logger.Logger logger)
static FilterableEventQueue	createSupplierProxyQueue(java.lang.String id, PropertiesRepository props, boolean isEventsLogged, boolean isFiltersEvaluationLogged, org.apache.avalon.framework.logger.Logger logger)

Methods inherited from class java.lang.Object

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

Constructor Detail

EventQueueFactory

public EventQueueFactory()

Method Detail

createAdminQueue

public static FilterableEventQueue createAdminQueue(java.lang.String id,
                                                    PropertiesRepository props,
                                                    boolean isEventsLogged,
                                                    boolean isFiltersEvaluationLogged,
                                                    org.apache.avalon.framework.logger.Logger logger)

createConsumerProxyQueue

public static FilterableEventQueue createConsumerProxyQueue(java.lang.String id,
                                                            PropertiesRepository props,
                                                            boolean isPerformance,
                                                            boolean isEventsLogged,
                                                            boolean isFiltersEvaluationLogged,
                                                            org.apache.avalon.framework.logger.Logger logger)

createSupplierProxyQueue

public static FilterableEventQueue createSupplierProxyQueue(java.lang.String id,
                                                            PropertiesRepository props,
                                                            boolean isEventsLogged,
                                                            boolean isFiltersEvaluationLogged,
                                                            org.apache.avalon.framework.logger.Logger logger)