com.espertech.esper.core.service

Class ExceptionHandlingService

java.lang.Object

com.espertech.esper.core.service.ExceptionHandlingService

public class ExceptionHandlingService
extends Object

Constructor Summary

Constructors

Constructor and Description
ExceptionHandlingService(String engineURI, List<ExceptionHandler> exceptionHandlers, List<ConditionHandler> conditionHandlers)

Method Summary

Modifier and Type	Method and Description
String	getEngineURI()
void	handleCondition(BaseCondition condition, EPStatementHandle handle)
void	handleException(RuntimeException ex, EPStatementAgentInstanceHandle handle, ExceptionHandlerExceptionType type, EventBean optionalCurrentEvent)
void	handleException(RuntimeException ex, String statementName, String epl, ExceptionHandlerExceptionType type, EventBean optionalCurrentEvent)
void	handleInboundPoolException(String engineURI, Throwable exception, Object event)

Methods inherited from class java.lang.Object

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

Constructor Detail

ExceptionHandlingService

public ExceptionHandlingService(String engineURI,
                                List<ExceptionHandler> exceptionHandlers,
                                List<ConditionHandler> conditionHandlers)

Method Detail

handleCondition

public void handleCondition(BaseCondition condition,
                            EPStatementHandle handle)

handleException

public void handleException(RuntimeException ex,
                            EPStatementAgentInstanceHandle handle,
                            ExceptionHandlerExceptionType type,
                            EventBean optionalCurrentEvent)

getEngineURI

public String getEngineURI()

handleException

public void handleException(RuntimeException ex,
                            String statementName,
                            String epl,
                            ExceptionHandlerExceptionType type,
                            EventBean optionalCurrentEvent)

handleInboundPoolException

public void handleInboundPoolException(String engineURI,
                                       Throwable exception,
                                       Object event)