public class DatabaseEventManager extends AbstractNurseryService implements EventManager, RemoteExpireService
GenericService.StartCommand, GenericService.StopCommand
Modifier and Type | Field and Description |
---|---|
static String |
CLASS_VERSION
Deprecated.
The version of this class.
|
mLogger, state
EVENT_TYPE_PARAMETER, eventSource, STAGED
Constructor and Description |
---|
DatabaseEventManager()
Deprecated.
Default constructor
|
Modifier and Type | Method and Description |
---|---|
void |
expire(String pNurseryName,
Object pIdentifier)
Deprecated.
|
neo.xredsys.content.ContentManager |
getContentManager()
Deprecated.
|
int |
getDatabasePollInterval()
Deprecated.
|
CompositeHitCollector |
getEventsAcceptedCollector()
Deprecated.
|
CompositeHitCollector |
getEventsHandledCollector()
Deprecated.
|
List<neo.xredsys.api.DatabaseEventManager.Listener> |
getListeners()
Deprecated.
|
CompositeHitCollector |
getLocalEventSourcesCollector()
Deprecated.
|
int |
getLocalQueueSize()
Deprecated.
|
CompositeHitCollector |
getRemoteEventSourceCollector()
Deprecated.
|
CompositeHitCollector |
getRemoteExpireCollector()
Deprecated.
|
int |
getRemoteQueueSize()
Deprecated.
|
int |
getRemoteReadQueueSize()
Deprecated.
|
String |
getServerName()
Deprecated.
|
int |
getShutdownTimeout()
Deprecated.
|
HitCollector |
getTimeInRemoteQueueCollector()
Deprecated.
|
void |
postEvent(IOEvent pEvent)
Deprecated.
Posts an event.
|
void |
postEvent(IOEvent pEvent,
boolean pDistributeLocally,
boolean pDistributeRemotely)
Deprecated.
Posts an event.
|
void |
registerListener(IOEventListener pListener,
IOEventFilter pFilter)
Deprecated.
Registers an event listener.
|
protected RemoteExpireCache |
resolveName(String comp)
Deprecated.
|
void |
setContentManager(neo.xredsys.content.ContentManager pContentManager)
Deprecated.
|
void |
setDatabasePollInterval(int pPollIntervalInSeconds)
Deprecated.
|
void |
setEventsAcceptedCollector(CompositeHitCollector pCollector)
Deprecated.
|
void |
setEventsHandledCollector(CompositeHitCollector pCollector)
Deprecated.
|
void |
setLocalEventSourcesCollector(CompositeHitCollector pLocalEventSources)
Deprecated.
|
void |
setRemoteEventSourceCollector(CompositeHitCollector pRemoteEventSource)
Deprecated.
|
void |
setRemoteExpireCollector(CompositeHitCollector pCollector)
Deprecated.
|
void |
setShutdownTimeout(int pTimeoutInSeconds)
Deprecated.
|
void |
setTimeInRemoteQueueCollector(HitCollector pCollector)
Deprecated.
|
protected void |
startService()
Deprecated.
Is called by
AbstractNurseryService.doStartService() when the NurseryService is being started. |
protected void |
stopService()
Deprecated.
Is called by
AbstractNurseryService.doStopService() when the service is being shut down. |
void |
unregisterListener(IOEventListener pListener)
Deprecated.
Unregisters an event listener.
|
doStartService, doStopService, stopIdleService
assertServiceRunning, getServiceDescription, getServiceMessage, getServiceState, isServiceEnabled, isServiceFailed, isServiceIdle, isServiceRunning, isServiceShutdownFailed, isServiceStopped, setServiceDescription, setServiceEnabled, start, stop, validateIsTrue, validateNotNull
public static final String CLASS_VERSION
public DatabaseEventManager()
public void setEventsHandledCollector(CompositeHitCollector pCollector)
public CompositeHitCollector getEventsHandledCollector()
public void setEventsAcceptedCollector(CompositeHitCollector pCollector)
public CompositeHitCollector getEventsAcceptedCollector()
public void setTimeInRemoteQueueCollector(HitCollector pCollector)
public HitCollector getTimeInRemoteQueueCollector()
public void setRemoteExpireCollector(CompositeHitCollector pCollector)
public CompositeHitCollector getRemoteExpireCollector()
public void setContentManager(neo.xredsys.content.ContentManager pContentManager)
public neo.xredsys.content.ContentManager getContentManager()
public void setDatabasePollInterval(int pPollIntervalInSeconds)
public int getDatabasePollInterval()
public final List<neo.xredsys.api.DatabaseEventManager.Listener> getListeners()
public void registerListener(IOEventListener pListener, IOEventFilter pFilter) throws IllegalArgumentException
EventManager
registerListener
in interface EventManager
pListener
- the listener to registerpFilter
- removes unwanted eventsIllegalArgumentException
- if listener is nullIOEventFilter
,
IOEventListener
public void unregisterListener(IOEventListener pListener) throws IllegalArgumentException
EventManager
unregisterListener
in interface EventManager
pListener
- the listener to unregisterIllegalArgumentException
- if listener is nullIOEventFilter
public final void postEvent(IOEvent pEvent)
EventManager
postEvent
in interface EventManager
pEvent
- the event to postpublic final void postEvent(IOEvent pEvent, boolean pDistributeLocally, boolean pDistributeRemotely)
EventManager
postEvent
in interface EventManager
pEvent
- the event to postpDistributeLocally
- indicates whether or not this event should be distributed locallypDistributeRemotely
- indicates whether or not this event should be distributed remotelypublic String getServerName()
public int getLocalQueueSize()
public int getRemoteQueueSize()
public int getRemoteReadQueueSize()
public void setShutdownTimeout(int pTimeoutInSeconds)
public int getShutdownTimeout()
public void setLocalEventSourcesCollector(CompositeHitCollector pLocalEventSources)
pLocalEventSources
- the localEventSources to setpublic CompositeHitCollector getLocalEventSourcesCollector()
public void setRemoteEventSourceCollector(CompositeHitCollector pRemoteEventSource)
pRemoteEventSource
- the remoteEventSource to setpublic CompositeHitCollector getRemoteEventSourceCollector()
protected final void startService() throws IllegalStateException, IllegalArgumentException, Exception
AbstractNurseryService
Is called by AbstractNurseryService.doStartService()
when the NurseryService
is being started. Exceptions thrown by this
method are logged by AbstractNurseryService.doStartService()
.
Subclasses must implement this method to bootstrap the service.
startService
in class AbstractNurseryService
IllegalStateException
- when this service is in the wrong state for startup. Used to signal to AbstractNurseryService.doStartService()
that it is OK to try to starting
this service
later. GenericService.isServiceRunning()
returns false
and GenericService.isServiceIdle()
returns true
.IllegalArgumentException
- when the configuration of the service
is invalid. GenericService.isServiceRunning()
will return false
and GenericService.isServiceFailed()
will return true
.Exception
- when something goes wrong during startup. GenericService.isServiceRunning()
will return false
and GenericService.isServiceFailed()
will return true
.AbstractNurseryService.doStartService()
protected final void stopService() throws IllegalStateException, Exception
AbstractNurseryService
Is called by AbstractNurseryService.doStopService()
when the service
is being shut down. Exceptions thrown by this
method are logged by AbstractNurseryService.doStopService()
.
Subclasses must implement this method to shut down the service.
stopService
in class AbstractNurseryService
IllegalStateException
- when this service is in the wrong state for shutdown. Used to signal to AbstractNurseryService.doStopService()
that
it is OK to try stopping this service
later. GenericService.isServiceRunning()
returns true
.Exception
- when something goes during shutdown. GenericService.isServiceRunning()
returns false
and
GenericService.isServiceShutdownFailed()
returns true
.AbstractNurseryService.doStopService()
public void expire(String pNurseryName, Object pIdentifier)
expire
in interface RemoteExpireService
protected RemoteExpireCache resolveName(String comp)
© 1998- 2021 Escenic AS