com.ibm.j2ca.extension.eventmanagement.internal

Class EventManager

java.lang.Object

com.ibm.j2ca.extension.eventmanagement.internal.EventManager

Direct Known Subclasses:

LegacyEventManager

public class EventManager
extends java.lang.Object

EventManager This is the main controller class for the EventManager component. This provides the main entry point "pollForEvents" that allows the adapter to poll the EIS. It also maintains links to the EDTConnectionPool and the WorkController.

Constructor Summary

Constructors

Constructor and Description
EventManager(LogUtils logUtils, BaseEventStore eventStore, WorkManager workManager, ResourceAdapter ra) Constructor for Event manager.

Method Summary

Methods

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.

Methods inherited from class java.lang.Object

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

Constructor Detail

EventManager

public EventManager(LogUtils logUtils,
            BaseEventStore eventStore,
            WorkManager workManager,
            ResourceAdapter ra)
             throws ResourceException

Constructor for Event manager.

Parameters:

logUtils - The LogUtils to set.

eventStore - Event store specific to the EIS.

workManager -

ra -

Throws:

ResourceException

Method Detail

isCalendarEnabled

public boolean isCalendarEnabled()

setCalendarEnabled

public void setCalendarEnabled(boolean calendarEnabled)

getTargetMethod

public java.lang.reflect.Method getTargetMethod(MessageEndpointFactory messageEndpointFactory,
                                       ActivationSpec activationSpec,
                                       Event event,
                                       InboundInteractionSpec iSpec)
                                         throws ResourceException

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.

Throws:

ResourceException

See Also:

com.ibm.j2ca.extension.eventmanagement.internal.EventManager#getTargetMethod(javax.resource.spi.endpoint.MessageEndpointFactory, javax.resource.spi.ActivationSpec, com.ibm.j2ca.extension.eventmanagement.Event)

addEndpointFactory

public void addEndpointFactory(MessageEndpointFactory endpointFactory,
                      ActivationSpec activationSpec)
                        throws ResourceException

Activate a new endpoint. These parameters should be passed in from the ResourceAdapter's endpointActivation method.

Parameters:

endpointFactory -

activationSpec -

Throws:

ResourceException

pollForEvents

public void pollForEvents(int pollQuantity)
                   throws ResourceException,
                          CommException

Polls the configured EventStore instance for new events and delivers any events found to interested endpoints.

Parameters:

pollQuantity - the maximum number of events to deliver

Throws:

ResourceException

CommException

isShutDown

public boolean isShutDown()

Returns:

True if this event manager has been shut down (or is in the process of shutting down) or false otherwise.

removeEndpointFactory

public void removeEndpointFactory(MessageEndpointFactory messageEndpointFactory)

Parameters:

messageEndpointFactory -

shutDown

public void shutDown()
              throws ResourceException

Shut down the event manager. This closes all the connections to the EDT. This method can be called multiple times, but may not do anything useful on subsequent calls.

Throws:

ResourceException

getObjectForEvent

public Record getObjectForEvent(Event event,
                       BaseEventStore eventStore)
                         throws ResourceException

Retrieve the full event from the event store.

Parameters:

event - this is the event

Returns:

the full object/SDO representation of the object in the EIS.

Throws:

ResourceException

setStopPollingOnError

public void setStopPollingOnError(boolean stopPollingOnError)

Parameters:

stopPollingOnError - Indicate whether polling should stop on error.

getStopPollingOnError

public boolean getStopPollingOnError()

setBiDiContexts

public void setBiDiContexts(BaseActivationSpec activationSpec)

getBiDiContexts

public java.util.ArrayList getBiDiContexts()

getFailedEvents

public java.util.Map getFailedEvents()

setFailedEvents

public void setFailedEvents(java.util.Map failedEvents)

logEvent

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)