| java.lang.Object
 org.obe.engine.repository.AbstractRepository
org.obe.event.AbstractApplicationEventBroker
All known Subclasses: org.obe.server.j2ee.service.EJBApplicationEventBroker, org.obe.event.BasicApplicationEventBroker,
| AbstractApplicationEventBroker | | abstract public class AbstractApplicationEventBroker extends AbstractRepository implements ApplicationEventBroker(Code) | | Abstract event broker that stores its event definitions in XML. Subclasses
provide matching services event and subscription storage.
author:
Adrian Price |
| Method Summary | |
| final public void | addApplicationEventListener(ApplicationEventListener listener)
| | public void | createEventType(EventTypeMetaData eventType)
| | abstract protected ApplicationEventSubscription | createSubscription(String eventType, Object[] eventKeys, String predicate, Date effective, Date expiry, int count, String[] correlationKeys)
| | abstract protected TemporalEventSubscription | createSubscription(String eventType, Date effective, Date expiry, int count, Duration interval, String calendar, boolean recoverable, String[] correlationKeys)
| | public void | deleteEventType(String eventType)
| | public EventTypeMetaData[] | findEventTypeMetaData()
| | public EventTypeMetaData | findEventTypeMetaData(String eventId)
| | abstract protected Collection | findStoredEvents(String eventType, Object[] subscriptionKeys)
Locates matching stored events.
Parameters:
eventType - The event type.
Parameters:
subscriptionKeys - The event keys supplied with the subscription. | | abstract protected Collection | findSubscriptions(ApplicationEvent event, EventTypeMetaData metaData)
Finds application event subscriptions that match on event type and, for
key-based subscriptions, event keys. | | final public void | fireApplicationEvent(ApplicationEvent event, String[] correlationKeys)
| | protected ContentHandler | getContentHandler(String contentType)
| | protected String | getContentType(Object data, Map attrs)
| | protected Evaluator | getEvaluatorFor(EventTypeMetaData metaData)
| | public String | getServiceName()
| | public synchronized void | init()
| | public void | publish(Object source, Map attrs)
| | final public void | publish(ApplicationEvent event)
| | final protected void | publish(ApplicationEvent event, EventTypeMetaData metaData, Evaluator evaluator, WorkflowContext ctx)
| | final public void | removeApplicationEventListener(ApplicationEventListener listener)
| | abstract protected void | storeEvent(ApplicationEvent event, EventTypeMetaData metaData)
Stores an event for later consumption. | | final public TemporalEventSubscription | subscribe(String eventType, Date effective, String[] correlationKeys)
| | final public ApplicationEventSubscription | subscribe(String eventType, Object[] eventKeys, String predicate, Date effective, Date expiry, int count, String[] correlationKeys, WorkflowContext ctx)
| | final public TemporalEventSubscription | subscribe(String eventType, Date effective, Date expiry, int count, Duration interval, String calendar, boolean recoverable, String[] correlationKeys)
| | public boolean | supportsKeyBasedSubscriptions()
| | public void | updateEventType(EventTypeMetaData eventType)
|
| _predicateWarningIssued | | protected boolean _predicateWarningIssued(Code) | | |
| findSubscriptions | | abstract protected Collection findSubscriptions(ApplicationEvent event, EventTypeMetaData metaData) throws RepositoryException(Code) | | Finds application event subscriptions that match on event type and, for
key-based subscriptions, event keys. Conditions defined on the
subscription will be evaluated by the caller since the callee does not
have sufficient information to do this.
Parameters:
event - The event for which matching subscriptions are to be found.
Parameters:
metaData - Metadata for this event. A collection of matching EventSubscription.
throws:
RepositoryException - |
| supportsKeyBasedSubscriptions | | public boolean supportsKeyBasedSubscriptions()(Code) | | |
| Methods inherited from org.obe.engine.repository.AbstractRepository | protected synchronized void clear()(Code)(Java Doc)
protected void createEntry(AbstractMetaData metaData) throws RepositoryException(Code)(Java Doc)
protected synchronized Entry createEntry(String key, AbstractMetaData metaData, Object instance) throws RepositoryException(Code)(Java Doc)
protected synchronized void deleteEntry(String key) throws RepositoryException(Code)(Java Doc)
public synchronized void exit()(Code)(Java Doc)
protected Entry[] findEntries()(Code)(Java Doc)
protected Entry findEntry(String key, boolean throwException) throws RepositoryException(Code)(Java Doc)
protected Object findInstance(String key, boolean throwException) throws RepositoryException(Code)(Java Doc)
protected synchronized AbstractMetaData[] findMetaData()(Code)(Java Doc)
protected AbstractMetaData findMetaData(String key, boolean throwException) throws RepositoryException(Code)(Java Doc)
protected AbstractMetaData findObjectType(String className) throws RepositoryException(Code)(Java Doc)
protected AbstractMetaData[] findObjectTypes()(Code)(Java Doc)
protected String getConfigurationFileName()(Code)(Java Doc)
protected static Log getLog(Class clazz)(Code)(Java Doc)
abstract protected Log getLogger()(Code)(Java Doc)
final public ServiceManager getServiceManager()(Code)(Java Doc)
public synchronized void init() throws IOException, RepositoryException(Code)(Java Doc)
public synchronized boolean isInitialized()(Code)(Java Doc)
protected synchronized void load() throws RepositoryException, IOException(Code)(Java Doc)
protected void registerObjectType(AbstractMetaData objectType) throws ObjectAlreadyExistsException(Code)(Java Doc)
public synchronized void store()(Code)(Java Doc)
protected Entry updateEntry(String key, AbstractMetaData metaData) throws RepositoryException(Code)(Java Doc)
protected synchronized Entry updateEntry(String key, AbstractMetaData metaData, Object implementation) throws RepositoryException(Code)(Java Doc)
|
|
|