public class ResultDeliveryStrategyImpl extends Object implements ResultDeliveryStrategy
Constructor and Description |
---|
ResultDeliveryStrategyImpl(EPStatement statement,
Object subscriber,
DeliveryConvertor deliveryConvertor,
Method method,
Method startMethod,
Method endMethod,
Method rStreamMethod,
com.espertech.esper.common.internal.settings.ClasspathImportService classpathImportService)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
void |
execute(com.espertech.esper.common.internal.collection.UniformPair<com.espertech.esper.common.client.EventBean[]> result)
Execute the dispatch.
|
protected static void |
handle(String statementName,
org.slf4j.Logger logger,
ReflectiveOperationException e,
Object[] parameters,
Object subscriber,
Method method)
Handle the exception, displaying a nice message and converting to
EPException . |
protected static void |
handleThrowable(org.slf4j.Logger logger,
Throwable t,
Object[] parameters,
Object subscriber,
Method method)
Handle the exception, displaying a nice message and converting to
EPException . |
public ResultDeliveryStrategyImpl(EPStatement statement, Object subscriber, DeliveryConvertor deliveryConvertor, Method method, Method startMethod, Method endMethod, Method rStreamMethod, com.espertech.esper.common.internal.settings.ClasspathImportService classpathImportService)
subscriber
- is the subscriber receiving method invocationsdeliveryConvertor
- for converting individual rowsmethod
- to deliver the insert stream tostartMethod
- to call to indicate when delivery starts, or null if no such indication is requiredendMethod
- to call to indicate when delivery ends, or null if no such indication is requiredrStreamMethod
- to deliver the remove stream to, or null if no such indication is requiredstatement
- statementclasspathImportService
- runtime importspublic void execute(com.espertech.esper.common.internal.collection.UniformPair<com.espertech.esper.common.client.EventBean[]> result)
ResultDeliveryStrategy
execute
in interface ResultDeliveryStrategy
result
- is the insert and remove stream to indicateprotected static void handle(String statementName, org.slf4j.Logger logger, ReflectiveOperationException e, Object[] parameters, Object subscriber, Method method)
EPException
.logger
- is the logger to use for error logginge
- is the exceptionparameters
- the method parameterssubscriber
- the object to deliver tomethod
- the method to callstatementName
- statement namecom.espertech.esper.common.client.EPException
- converted from the passed invocation exceptionprotected static void handleThrowable(org.slf4j.Logger logger, Throwable t, Object[] parameters, Object subscriber, Method method)
EPException
.logger
- is the logger to use for error loggingt
- is the throwableparameters
- the method parameterssubscriber
- the object to deliver tomethod
- the method to callcom.espertech.esper.common.client.EPException
- converted from the passed invocation exceptionCopyright © 2005–2018. All rights reserved.