Class ConnectRequestMessageOnFragment

java.lang.Object

com.iohao.net.center.fragment.ConnectRequestMessageOnFragment

All Implemented Interfaces:

CenterServerSettingAware, OnFragment

public class ConnectRequestMessageOnFragment
extends Object
implements OnFragment, CenterServerSettingAware

Handles center-side connect-request fragments and synchronizes peer server discovery.

Since:

25.1

Author:

渔民小镇

date:

2025-08-25

Field Summary

Fields

Modifier and Type	Field	Description
protected io.aeron.Aeron	aeron
protected CenterConnectionManager	connectionManager
protected final ConnectRequestMessageDecoder	decoder

Constructor Summary

Constructors

Constructor	Description
ConnectRequestMessageOnFragment()

Method Summary

Modifier and Type	Method	Description
int	getTemplateId()	Returns the SBE template id handled by this processor.
protected io.aeron.Publication	ofPublication(ServerMessage message)
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.
void	setCenterServerSetting(CenterServerSetting setting)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

decoder

protected final ConnectRequestMessageDecoder decoder

connectionManager

protected CenterConnectionManager connectionManager

aeron

protected io.aeron.Aeron aeron

Constructor Details

ConnectRequestMessageOnFragment

public ConnectRequestMessageOnFragment()

Method Details

setCenterServerSetting

public void setCenterServerSetting(CenterServerSetting setting)

Specified by:

setCenterServerSetting in interface CenterServerSettingAware

process

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

Description copied from interface: OnFragment

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

Specified by:

process in interface OnFragment

Parameters:

buffer - source buffer

offset - message offset

actingBlockLength - SBE acting block length

actingVersion - SBE acting version

header - Aeron fragment header

ofPublication

protected io.aeron.Publication ofPublication(ServerMessage message)

getTemplateId

public int getTemplateId()

Description copied from interface: OnFragment

Returns the SBE template id handled by this processor.

Specified by:

getTemplateId in interface OnFragment

Returns:

SBE template id