public class SequenceStreamPacker extends SingleStreamPacker
Modifier and Type | Field and Description |
---|---|
protected SequenceState |
nextState |
protected SequenceState |
state |
protected SequenceSingleStreamReceiver |
streamReceiver |
prevStreamElement, queryProjector
Constructor and Description |
---|
SequenceStreamPacker(SequenceState state) |
Modifier and Type | Method and Description |
---|---|
protected void |
passToStreamReceivers(StateEvent eventBundle) |
void |
process(ComplexEvent complexEvent) |
protected void |
sendEvent(AtomicEvent atomicEvent) |
protected void |
setEventState(StateEvent eventBundle) |
void |
setStreamReceiver(SequenceSingleStreamReceiver streamReceiver) |
setNext, setPrevious
protected SequenceSingleStreamReceiver streamReceiver
protected SequenceState state
protected SequenceState nextState
public SequenceStreamPacker(SequenceState state)
public void setStreamReceiver(SequenceSingleStreamReceiver streamReceiver)
public void process(ComplexEvent complexEvent)
process
in interface StreamProcessor
process
in class SingleStreamPacker
protected void setEventState(StateEvent eventBundle)
protected void sendEvent(AtomicEvent atomicEvent)
protected void passToStreamReceivers(StateEvent eventBundle)
Copyright © 2012. All Rights Reserved.