| org.obe.event.AbstractApplicationEventBroker org.obe.event.BasicApplicationEventBroker
BasicApplicationEventBroker | public class BasicApplicationEventBroker extends AbstractApplicationEventBroker (Code) | | Provides a basic, non-persistent application event broker service.
author: Adrian Price |
Inner Class :abstract protected class BasicEventSubscription implements EventSubscription | |
Inner Class :protected class BasicApplicationEventSubscription extends BasicEventSubscription implements ApplicationEventSubscription | |
Inner Class :protected class BasicTemporalEventSubscription extends BasicEventSubscription implements TemporalEventSubscription | |
Field Summary | |
final protected static Log | _logger |
Method Summary | |
protected ApplicationEventSubscription | createSubscription(String eventType, Object[] eventKeys, String predicate, Date effective, Date expiry, int count, String[] correlationKeys) | protected TemporalEventSubscription | createSubscription(String eventType, Date effective, Date expiry, int count, Duration interval, String calendar, boolean recoverable, String[] correlationKeys) | public synchronized void | exit() | protected Collection[] | findAllSubscriptions(String eventType) | protected Collection | findStoredEvents(String eventType, Object[] subscriptionKeys) | protected Collection | findSubscriptions(ApplicationEvent event, EventTypeMetaData metaData) | protected Collection | findSubscriptions(String eventType) | protected Log | getLogger() | public synchronized void | init() | protected void | storeEvent(ApplicationEvent event, EventTypeMetaData metaData) | public void | unsubscribe(String[] correlationKeys, boolean exact) |
_logger | final protected static Log _logger(Code) | | |
exit | public synchronized void exit()(Code) | | |
getLogger | protected Log getLogger()(Code) | | |
Fields inherited from org.obe.event.AbstractApplicationEventBroker | protected boolean _predicateWarningIssued(Code)(Java Doc)
|
Methods inherited from org.obe.event.AbstractApplicationEventBroker | final public void addApplicationEventListener(ApplicationEventListener listener)(Code)(Java Doc) public void createEventType(EventTypeMetaData eventType) throws RepositoryException(Code)(Java Doc) abstract protected ApplicationEventSubscription createSubscription(String eventType, Object[] eventKeys, String predicate, Date effective, Date expiry, int count, String[] correlationKeys) throws RepositoryException(Code)(Java Doc) abstract protected TemporalEventSubscription createSubscription(String eventType, Date effective, Date expiry, int count, Duration interval, String calendar, boolean recoverable, String[] correlationKeys) throws RepositoryException(Code)(Java Doc) public void deleteEventType(String eventType) throws RepositoryException(Code)(Java Doc) public EventTypeMetaData[] findEventTypeMetaData() throws RepositoryException(Code)(Java Doc) public EventTypeMetaData findEventTypeMetaData(String eventId) throws RepositoryException(Code)(Java Doc) abstract protected Collection findStoredEvents(String eventType, Object[] subscriptionKeys) throws RepositoryException(Code)(Java Doc) abstract protected Collection findSubscriptions(ApplicationEvent event, EventTypeMetaData metaData) throws RepositoryException(Code)(Java Doc) final public void fireApplicationEvent(ApplicationEvent event, String[] correlationKeys)(Code)(Java Doc) protected ContentHandler getContentHandler(String contentType)(Code)(Java Doc) protected String getContentType(Object data, Map attrs)(Code)(Java Doc) protected Evaluator getEvaluatorFor(EventTypeMetaData metaData) throws RepositoryException(Code)(Java Doc) public String getServiceName()(Code)(Java Doc) public synchronized void init() throws IOException, RepositoryException(Code)(Java Doc) public void publish(Object source, Map attrs) throws RepositoryException, EvaluatorException(Code)(Java Doc) final public void publish(ApplicationEvent event) throws RepositoryException, EvaluatorException(Code)(Java Doc) final protected void publish(ApplicationEvent event, EventTypeMetaData metaData, Evaluator evaluator, WorkflowContext ctx) throws RepositoryException, EvaluatorException(Code)(Java Doc) final public void removeApplicationEventListener(ApplicationEventListener listener)(Code)(Java Doc) abstract protected void storeEvent(ApplicationEvent event, EventTypeMetaData metaData) throws RepositoryException(Code)(Java Doc) final public TemporalEventSubscription subscribe(String eventType, Date effective, String[] correlationKeys) throws RepositoryException(Code)(Java Doc) final public ApplicationEventSubscription subscribe(String eventType, Object[] eventKeys, String predicate, Date effective, Date expiry, int count, String[] correlationKeys, WorkflowContext ctx) throws RepositoryException(Code)(Java Doc) final public TemporalEventSubscription subscribe(String eventType, Date effective, Date expiry, int count, Duration interval, String calendar, boolean recoverable, String[] correlationKeys) throws RepositoryException(Code)(Java Doc) public boolean supportsKeyBasedSubscriptions()(Code)(Java Doc) public void updateEventType(EventTypeMetaData eventType) throws RepositoryException(Code)(Java Doc)
|
|
|