Interface OnFragment

All Known Implementing Classes:

BroadcastMulticastMessageOnFragment, BroadcastUserListMessageOnFragment, BroadcastUserMessageOnFragment, ConnectRequestMessageOnFragment, ConnectResponseMessageOnFragment, EmptyExternalResponseMessageOnFragment, EventBusMessageOnFragment, ExternalRequestMessageOnFragment, ExternalResponseMessageOnFragment, RequestMessageOnFragment, ResponseMessageOnFragment, SendMessageOnFragment, ServerOfflineMessageOnFragment, UserRequestMessageOnFragment, UserResponseMessageOnFragment

public interface OnFragment

Handles a decoded Aeron fragment for a specific SBE template id.

Since:

25.1

Author:

渔民小镇

date:

2025-08-25

Method Summary

Modifier and Type	Method	Description
int	getTemplateId()	Returns the SBE template id handled by this processor.
void	process(org.agrona.DirectBuffer buffer, int offset, int actingBlockLength, int actingVersion, io.aeron.logbuffer.Header header)	Processes a fragment payload that has already been routed by template id.

Method Details

process

void process(org.agrona.DirectBuffer buffer,
 int offset,
 int actingBlockLength,
 int actingVersion,
 io.aeron.logbuffer.Header header)

Processes a fragment payload that has already been routed by template id.

Parameters:

buffer - source buffer

offset - message offset

actingBlockLength - SBE acting block length

actingVersion - SBE acting version

header - Aeron fragment header

getTemplateId

int getTemplateId()

Returns the SBE template id handled by this processor.

Returns:

SBE template id