io.aeron.logbuffer

Interface ControlledFragmentHandler

All Known Implementing Classes:

ControlledFragmentAssembler, ImageControlledFragmentAssembler

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface ControlledFragmentHandler

Handler for reading data that is coming from a log buffer. The frame will either contain a whole message or a fragment of a message to be reassembled. Messages are fragmented if greater than the frame for MTU in length.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	ControlledFragmentHandler.Action

Method Summary

Modifier and Type	Method and Description
ControlledFragmentHandler.Action	onFragment(org.agrona.DirectBuffer buffer, int offset, int length, Header header) Callback for handling fragments of data being read from a log.

Method Detail

onFragment

ControlledFragmentHandler.Action onFragment(org.agrona.DirectBuffer buffer,
                                            int offset,
                                            int length,
                                            Header header)

Callback for handling fragments of data being read from a log.

Parameters:

buffer - containing the data.

offset - at which the data begins.

length - of the data in bytes.

header - representing the meta data for the data.

Returns:

The action to be taken with regard to the stream position after the callback.