|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.espertech.esper.core.ResultDeliveryStrategyImpl
public class ResultDeliveryStrategyImpl
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 | |
---|---|
ResultDeliveryStrategyImpl(Object subscriber,
DeliveryConvertor deliveryConvertor,
Method method,
Method startMethod,
Method endMethod,
Method rStreamMethod)
Ctor. |
Method Summary | |
---|---|
void |
execute(UniformPair<EventBean[]> result)
Execute the dispatch. |
protected static void |
handle(org.apache.commons.logging.Log logger,
InvocationTargetException e,
Object[] params,
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 |
---|
public ResultDeliveryStrategyImpl(Object subscriber, DeliveryConvertor deliveryConvertor, Method method, Method startMethod, Method endMethod, Method rStreamMethod)
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 requiredMethod Detail |
---|
public void execute(UniformPair<EventBean[]> result)
ResultDeliveryStrategy
execute
in interface ResultDeliveryStrategy
result
- is the insert and remove stream to indicateprotected static void handle(org.apache.commons.logging.Log logger, InvocationTargetException e, Object[] params, Object subscriber, net.sf.cglib.reflect.FastMethod method) throws EPException
EPException
.
logger
- is the logger to use for error logginge
- is the exceptionparams
- the method parameterssubscriber
- the object to deliver tomethod
- the method to call
EPException
- converted from the passed invocation exception
|
© 2007 EsperTech Inc. All rights reserved. Visit us at espertech.com |
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |