Class UserRequestMessageOnFragment

java.lang.Object

com.iohao.net.server.logic.fragment.UserRequestMessageOnFragment

All Implemented Interfaces:

OnFragment, NetServerSettingAware

public class UserRequestMessageOnFragment
extends Object

Handles user request fragments and dispatches them to the logic execution pipeline.

Since:

25.1

Author:

渔民小镇

date:

2025-08-28

Field Summary

Fields

Modifier and Type	Field	Description
protected final UserRequestMessageDecoder	decoder

Constructor Summary

Constructors

Constructor	Description
UserRequestMessageOnFragment()

Method Summary

Modifier and Type	Method	Description
protected final void	commonProcess(Request message, CommunicationType communicationType)
protected void	extracted(UserRequestMessage message)
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.
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 UserRequestMessageDecoder decoder

Constructor Details

UserRequestMessageOnFragment

public UserRequestMessageOnFragment()

Method Details

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.

Parameters:

buffer - source buffer

offset - message offset

actingBlockLength - SBE acting block length

actingVersion - SBE acting version

header - Aeron fragment header

extracted

protected void extracted(UserRequestMessage message)

getTemplateId

public int getTemplateId()

Description copied from interface: OnFragment

Returns the SBE template id handled by this processor.

Returns:

SBE template id

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

commonProcess

protected final void commonProcess(Request message,
 CommunicationType communicationType)