* Return a reference to the IEventProcessor.Sequence being used by this IEventProcessor */
| 90 | * Return a reference to the IEventProcessor.Sequence being used by this IEventProcessor |
| 91 | */ |
| 92 | std::shared_ptr< ISequence > sequence() const override |
| 93 | { |
| 94 | return m_sequence; |
| 95 | } |
| 96 | |
| 97 | /** |
| 98 | * Signal that this IEventProcessor should stop when it has finished consuming at the next clean break. It will call ISequenceBarrier::alert() to notify the thread to check status. |