Class ConnectResponseMessageOnFragment

java.lang.Object

com.iohao.net.server.fragment.ConnectResponseMessageOnFragment

All Implemented Interfaces:

OnFragment, NetServerSettingAware

public class ConnectResponseMessageOnFragment
extends Object
implements OnFragment, NetServerSettingAware

Handles center connect-response fragments and registers newly discovered server connections.

Since:

25.1

Author:

渔民小镇

date:

2025-08-26

Field Summary

Fields

Modifier and Type	Field	Description
protected io.aeron.Aeron	aeron
protected ConnectionManager	connectionManager
protected final ConnectResponseMessageDecoder	decoder
protected FutureManager	futureManager
protected NetServerSetting	setting

Constructor Summary

Constructors

Constructor	Description
ConnectResponseMessageOnFragment()

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	setNetServerSetting(NetServerSetting setting)	Injects the runtime setting.

Methods inherited from class Object

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

Field Details

decoder

protected final ConnectResponseMessageDecoder decoder

aeron

protected io.aeron.Aeron aeron

connectionManager

protected ConnectionManager connectionManager

setting

protected NetServerSetting setting

futureManager

protected FutureManager futureManager

Constructor Details

ConnectResponseMessageOnFragment

public ConnectResponseMessageOnFragment()

Method Details

setNetServerSetting

public void setNetServerSetting(NetServerSetting setting)

Description copied from interface: NetServerSettingAware

Injects the runtime setting.

Specified by:

setNetServerSetting in interface NetServerSettingAware

Parameters:

setting - runtime setting

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