Package com.espertech.esper.runtime.internal.kernel.service

Class EPServicesHA

java.lang.Object

com.espertech.esper.runtime.internal.kernel.service.EPServicesHA

public class EPServicesHA
extends Object

Constructor Summary

Constructors

Constructor	Description
EPServicesHA(com.espertech.esper.common.internal.context.module.RuntimeExtensionServices runtimeExtensionServices, DeploymentRecoveryService deploymentRecoveryService, ListenerRecoveryService listenerRecoveryService, StatementIdRecoveryService statementIdRecoveryService, Long currentTimeAsRecovered, Map<Integer,Long> currentTimeStageAsRecovered)

Method Summary

Modifier and Type	Method	Description
void	destroy()
Long	getCurrentTimeAsRecovered()
Map<Integer,Long>	getCurrentTimeStageAsRecovered()
DeploymentRecoveryService	getDeploymentRecoveryService()
ListenerRecoveryService	getListenerRecoveryService()
com.espertech.esper.common.internal.context.module.RuntimeExtensionServices	getRuntimeExtensionServices()
StatementIdRecoveryService	getStatementIdRecoveryService()

Methods inherited from class java.lang.Object

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

Constructor Details

EPServicesHA

public EPServicesHA(com.espertech.esper.common.internal.context.module.RuntimeExtensionServices runtimeExtensionServices,
 DeploymentRecoveryService deploymentRecoveryService,
 ListenerRecoveryService listenerRecoveryService,
 StatementIdRecoveryService statementIdRecoveryService,
 Long currentTimeAsRecovered,
 Map<Integer,Long> currentTimeStageAsRecovered)

Method Details

getRuntimeExtensionServices

public com.espertech.esper.common.internal.context.module.RuntimeExtensionServices getRuntimeExtensionServices()

getDeploymentRecoveryService

public DeploymentRecoveryService getDeploymentRecoveryService()

getListenerRecoveryService

public ListenerRecoveryService getListenerRecoveryService()

getStatementIdRecoveryService

public StatementIdRecoveryService getStatementIdRecoveryService()

getCurrentTimeAsRecovered

public Long getCurrentTimeAsRecovered()

destroy

public void destroy()

getCurrentTimeStageAsRecovered

public Map<Integer,Long> getCurrentTimeStageAsRecovered()