Uses of Interface
org.agrona.concurrent.MessageHandler
Packages that use MessageHandler
Package
Description
Data structure for broadcasting messages from one source to many receivers via shared memory.
IPC ring buffers for messaging via shared memory.
-
Uses of MessageHandler in org.agrona.concurrent.broadcast
Methods in org.agrona.concurrent.broadcast with parameters of type MessageHandlerModifier and TypeMethodDescriptionintCopyBroadcastReceiver.receive(MessageHandler handler) Receive one message from the broadcast buffer. -
Uses of MessageHandler in org.agrona.concurrent.ringbuffer
Methods in org.agrona.concurrent.ringbuffer with parameters of type MessageHandlerModifier and TypeMethodDescriptionintManyToOneRingBuffer.read(MessageHandler handler) Read as many messages as are available to the end of the ring buffer.intManyToOneRingBuffer.read(MessageHandler handler, int messageCountLimit) Read as many messages as are available to end of the ring buffer to up a supplied maximum.intOneToOneRingBuffer.read(MessageHandler handler) Read as many messages as are available to the end of the ring buffer.intOneToOneRingBuffer.read(MessageHandler handler, int messageCountLimit) Read as many messages as are available to end of the ring buffer to up a supplied maximum.intRingBuffer.read(MessageHandler handler) Read as many messages as are available to the end of the ring buffer.intRingBuffer.read(MessageHandler handler, int messageCountLimit) Read as many messages as are available to end of the ring buffer to up a supplied maximum.