com.espertech.esper.core.service

Class ResultDeliveryStrategyImpl

java.lang.Object

com.espertech.esper.core.service.ResultDeliveryStrategyImpl

All Implemented Interfaces:

ResultDeliveryStrategy

public class ResultDeliveryStrategyImpl
extends Object
implements ResultDeliveryStrategy

A result delivery strategy that uses a matching "update" method and optional start, end, and updateRStream methods, to deliver column-wise to parameters of the update method.

Constructor Summary

Constructors

Constructor and Description
ResultDeliveryStrategyImpl(EPStatement statement, Object subscriber, DeliveryConvertor deliveryConvertor, Method method, Method startMethod, Method endMethod, Method rStreamMethod, EngineImportService engineImportService) Ctor.

Method Summary

Modifier and Type	Method and Description
void	execute(UniformPair<EventBean[]> result) Execute the dispatch.
protected static void	handle(String statementName, org.slf4j.Logger logger, InvocationTargetException e, Object[] parameters, Object subscriber, net.sf.cglib.reflect.FastMethod 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, net.sf.cglib.reflect.FastMethod method) Handle the exception, displaying a nice message and converting to EPException.

Methods inherited from class java.lang.Object

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

Constructor Detail

ResultDeliveryStrategyImpl

public ResultDeliveryStrategyImpl(EPStatement statement,
                                  Object subscriber,
                                  DeliveryConvertor deliveryConvertor,
                                  Method method,
                                  Method startMethod,
                                  Method endMethod,
                                  Method rStreamMethod,
                                  EngineImportService engineImportService)

Ctor.

Parameters:

subscriber - is the subscriber receiving method invocations

deliveryConvertor - for converting individual rows

method - to deliver the insert stream to

startMethod - to call to indicate when delivery starts, or null if no such indication is required

endMethod - to call to indicate when delivery ends, or null if no such indication is required

rStreamMethod - to deliver the remove stream to, or null if no such indication is required

statement - statement

engineImportService - engine imports

Method Detail

execute

public void execute(UniformPair<EventBean[]> result)

Description copied from interface: ResultDeliveryStrategy

Execute the dispatch.

Specified by:

execute in interface ResultDeliveryStrategy

Parameters:

result - is the insert and remove stream to indicate

handle

protected static void handle(String statementName,
                             org.slf4j.Logger logger,
                             InvocationTargetException e,
                             Object[] parameters,
                             Object subscriber,
                             net.sf.cglib.reflect.FastMethod method)

Handle the exception, displaying a nice message and converting to EPException.

Parameters:

logger - is the logger to use for error logging

e - is the exception

parameters - the method parameters

subscriber - the object to deliver to

method - the method to call

statementName - statement name

Throws:

EPException - converted from the passed invocation exception

handleThrowable

protected static void handleThrowable(org.slf4j.Logger logger,
                                      Throwable t,
                                      Object[] parameters,
                                      Object subscriber,
                                      net.sf.cglib.reflect.FastMethod method)

Handle the exception, displaying a nice message and converting to EPException.

Parameters:

logger - is the logger to use for error logging

t - is the throwable

parameters - the method parameters

subscriber - the object to deliver to

method - the method to call

Throws:

EPException - converted from the passed invocation exception