public class StreamPostStateProcessor extends Object implements PostStateProcessor
Modifier and Type | Field and Description |
---|---|
protected CountPreStateProcessor |
callbackPreStateProcessor |
protected boolean |
isEventReturned |
protected PreStateProcessor |
nextEveryStatePreProcessor |
protected Processor |
nextProcessor |
protected PreStateProcessor |
nextStatePreProcessor |
protected int |
stateId |
protected StreamPreStateProcessor |
thisStatePreProcessor |
Constructor and Description |
---|
StreamPostStateProcessor() |
Modifier and Type | Method and Description |
---|---|
void |
clearProcessedEvent() |
PreStateProcessor |
getNextEveryStatePreProcessor() |
Processor |
getNextProcessor()
Get next processor element in the processor chain.
|
PreStateProcessor |
getNextStatePreProcessor() |
int |
getStateId() |
PreStateProcessor |
getThisStatePreProcessor() |
boolean |
isEventReturned() |
void |
process(ComplexEventChunk complexEventChunk)
Process the handed StreamEvent
|
void |
process(List<ComplexEventChunk> complexEventChunks)
Process the handed StreamEvent
|
protected void |
process(StateEvent stateEvent,
ComplexEventChunk complexEventChunk) |
void |
setCallbackPreStateProcessor(CountPreStateProcessor callbackPreStateProcessor) |
void |
setNextEveryStatePreProcessor(PreStateProcessor nextEveryStatePreProcessor) |
void |
setNextProcessor(Processor nextProcessor)
Set next processor element in processor chain
|
void |
setNextStatePreProcessor(PreStateProcessor preStateProcessor) |
void |
setStateId(int stateId) |
void |
setThisStatePreProcessor(StreamPreStateProcessor preStateProcessor) |
void |
setToLast(Processor processor)
Set as the last element of the processor chain
|
protected PreStateProcessor nextStatePreProcessor
protected PreStateProcessor nextEveryStatePreProcessor
protected StreamPreStateProcessor thisStatePreProcessor
protected Processor nextProcessor
protected int stateId
protected CountPreStateProcessor callbackPreStateProcessor
protected boolean isEventReturned
public void process(ComplexEventChunk complexEventChunk)
public void process(List<ComplexEventChunk> complexEventChunks)
Processor
protected void process(StateEvent stateEvent, ComplexEventChunk complexEventChunk)
public boolean isEventReturned()
public void clearProcessedEvent()
public Processor getNextProcessor()
getNextProcessor
in interface Processor
public void setNextProcessor(Processor nextProcessor)
setNextProcessor
in interface Processor
nextProcessor
- Processor to be set as next element of processor chainpublic void setToLast(Processor processor)
public PreStateProcessor getNextStatePreProcessor()
public void setNextStatePreProcessor(PreStateProcessor preStateProcessor)
setNextStatePreProcessor
in interface PostStateProcessor
public PreStateProcessor getNextEveryStatePreProcessor()
public void setNextEveryStatePreProcessor(PreStateProcessor nextEveryStatePreProcessor)
setNextEveryStatePreProcessor
in interface PostStateProcessor
public PreStateProcessor getThisStatePreProcessor()
public void setThisStatePreProcessor(StreamPreStateProcessor preStateProcessor)
public int getStateId()
getStateId
in interface PostStateProcessor
public void setStateId(int stateId)
public void setCallbackPreStateProcessor(CountPreStateProcessor callbackPreStateProcessor)
setCallbackPreStateProcessor
in interface PostStateProcessor
Copyright © 2019. All rights reserved.