public class ResultDeliveryStrategyTypeArr extends Object implements ResultDeliveryStrategy
Modifier and Type | Field and Description |
---|---|
protected Class |
componentType |
protected net.sf.cglib.reflect.FastMethod |
fastMethod |
protected EPStatement |
statement |
protected Object |
subscriber |
Constructor and Description |
---|
ResultDeliveryStrategyTypeArr(EPStatement statement,
Object subscriber,
Method method,
Class componentType,
EngineImportService engineImportService)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
protected Object |
convert(EventBean[] events) |
void |
execute(UniformPair<EventBean[]> result)
Execute the dispatch.
|
protected final EPStatement statement
protected final Object subscriber
protected final net.sf.cglib.reflect.FastMethod fastMethod
protected final Class componentType
public ResultDeliveryStrategyTypeArr(EPStatement statement, Object subscriber, Method method, Class componentType, EngineImportService engineImportService)
subscriber
- is the receiver to method invocationsmethod
- is the method to deliver tostatement
- statementcomponentType
- component typeengineImportService
- engine importspublic void execute(UniformPair<EventBean[]> result)
ResultDeliveryStrategy
execute
in interface ResultDeliveryStrategy
result
- is the insert and remove stream to indicate