public class EventManager
extends java.lang.Object
| Constructor and Description |
|---|
EventManager(LogUtils logUtils,
BaseEventStore eventStore,
WorkManager workManager,
ResourceAdapter ra)
Constructor for Event manager.
|
| Modifier and Type | Method and Description |
|---|---|
void |
addEndpointFactory(MessageEndpointFactory endpointFactory,
ActivationSpec activationSpec)
Activate a new endpoint.
|
java.util.ArrayList |
getBiDiContexts() |
java.util.Map |
getFailedEvents() |
Record |
getObjectForEvent(Event event,
BaseEventStore eventStore)
Retrieve the full event from the event store.
|
boolean |
getStopPollingOnError() |
java.lang.reflect.Method |
getTargetMethod(MessageEndpointFactory messageEndpointFactory,
ActivationSpec activationSpec,
Event event,
InboundInteractionSpec iSpec)
Returns the target method that would/will be used by method
#deliverEventto deliver event to an endpoint
derived from the given ActivationSpec instance and factory. |
boolean |
isCalendarEnabled() |
boolean |
isShutDown() |
void |
logEvent(java.lang.String eventStatus,
java.lang.String adapterFlow,
java.lang.String adapterCorrelId,
java.lang.Integer pollQuantity,
java.lang.Integer status,
java.lang.String[] typeFilters,
java.lang.String adapterId,
java.lang.Object failureReason) |
void |
pollForEvents(int pollQuantity)
Polls the configured EventStore instance for new events and delivers any
events found to interested endpoints.
|
void |
removeEndpointFactory(MessageEndpointFactory messageEndpointFactory) |
void |
setBiDiContexts(BaseActivationSpec activationSpec) |
void |
setCalendarEnabled(boolean calendarEnabled) |
void |
setFailedEvents(java.util.Map failedEvents) |
void |
setStopPollingOnError(boolean stopPollingOnError) |
void |
shutDown()
Shut down the event manager.
|
public EventManager(LogUtils logUtils, BaseEventStore eventStore, WorkManager workManager, ResourceAdapter ra) throws ResourceException
logUtils - The LogUtils to set.eventStore - Event store specific to the EIS.workManager - ra - ResourceExceptionpublic boolean isCalendarEnabled()
public void setCalendarEnabled(boolean calendarEnabled)
public java.lang.reflect.Method getTargetMethod(MessageEndpointFactory messageEndpointFactory,
ActivationSpec activationSpec,
Event event,
InboundInteractionSpec iSpec)
throws ResourceException
#deliverEventto deliver event to an endpoint
derived from the given ActivationSpec instance and factory.ResourceExceptioncom.ibm.j2ca.extension.eventmanagement.internal.EventManager#getTargetMethod(javax.resource.spi.endpoint.MessageEndpointFactory,
javax.resource.spi.ActivationSpec,
com.ibm.j2ca.extension.eventmanagement.Event)public void addEndpointFactory(MessageEndpointFactory endpointFactory,
ActivationSpec activationSpec)
throws ResourceException
endpointFactory - activationSpec - ResourceExceptionpublic void pollForEvents(int pollQuantity)
throws ResourceException,
CommException
pollQuantity - the maximum number of events to deliverResourceExceptionCommExceptionpublic boolean isShutDown()
True if this event manager has been shut down (or is in the process of shutting down) or false otherwise.public void removeEndpointFactory(MessageEndpointFactory messageEndpointFactory)
messageEndpointFactory - public void shutDown()
throws ResourceException
ResourceExceptionpublic Record getObjectForEvent(Event event, BaseEventStore eventStore) throws ResourceException
event - this is the eventResourceExceptionpublic void setStopPollingOnError(boolean stopPollingOnError)
stopPollingOnError - Indicate whether polling should stop on error.public boolean getStopPollingOnError()
public void setBiDiContexts(BaseActivationSpec activationSpec)
public java.util.ArrayList getBiDiContexts()
public java.util.Map getFailedEvents()
public void setFailedEvents(java.util.Map failedEvents)
public void logEvent(java.lang.String eventStatus,
java.lang.String adapterFlow,
java.lang.String adapterCorrelId,
java.lang.Integer pollQuantity,
java.lang.Integer status,
java.lang.String[] typeFilters,
java.lang.String adapterId,
java.lang.Object failureReason)