Package org.agrona.concurrent
Interface ControlledMessageHandler
- Functional Interface:
- This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
Callback interface for processing of messages that are read from a buffer.
-
Nested Class Summary
Nested ClassesModifier and TypeInterfaceDescriptionstatic enum
Action to be taken on return fromonMessage(int, MutableDirectBuffer, int, int)
. -
Method Summary
Modifier and TypeMethodDescriptiononMessage
(int msgTypeId, MutableDirectBuffer buffer, int index, int length) Called for the processing of each message read from a buffer in turn.
-
Method Details
-
onMessage
ControlledMessageHandler.Action onMessage(int msgTypeId, MutableDirectBuffer buffer, int index, int length) Called for the processing of each message read from a buffer in turn.- Parameters:
msgTypeId
- type of the encoded message.buffer
- containing the encoded message.index
- at which the encoded message begins.length
- in bytes of the encoded message.- Returns:
ControlledMessageHandler.Action
to be taken to control how the read progresses.
-