Uses of Interface
org.agrona.concurrent.ControlledMessageHandler
Packages that use ControlledMessageHandler
Package
Description
IPC ring buffers for messaging via shared memory.
-
Uses of ControlledMessageHandler in org.agrona.concurrent.ringbuffer
Methods in org.agrona.concurrent.ringbuffer with parameters of type ControlledMessageHandlerModifier and TypeMethodDescriptionint
ManyToOneRingBuffer.controlledRead
(ControlledMessageHandler handler) Read as many messages as are available to the end of the ring buffer with the handler able to control progress.int
ManyToOneRingBuffer.controlledRead
(ControlledMessageHandler handler, int messageCountLimit) Read messages up to a limit of available to the end of the ring buffer with the handler able to control progress.int
OneToOneRingBuffer.controlledRead
(ControlledMessageHandler handler) Read as many messages as are available to the end of the ring buffer with the handler able to control progress.int
OneToOneRingBuffer.controlledRead
(ControlledMessageHandler handler, int messageCountLimit) Read messages up to a limit of available to the end of the ring buffer with the handler able to control progress.int
RingBuffer.controlledRead
(ControlledMessageHandler handler) Read as many messages as are available to the end of the ring buffer with the handler able to control progress.int
RingBuffer.controlledRead
(ControlledMessageHandler handler, int messageCountLimit) Read messages up to a limit of available to the end of the ring buffer with the handler able to control progress.