Class ServerOfflineMessageOnFragment
java.lang.Object
com.iohao.net.server.fragment.ServerOfflineMessageOnFragment
- All Implemented Interfaces:
OnFragment, NetServerSettingAware
public final class ServerOfflineMessageOnFragment
extends Object
implements OnFragment, NetServerSettingAware
Handles server-offline notifications and triggers peer offline cleanup.
- Since:
- 25.1
- Author:
- 渔民小镇
- date:
- 2025-09-26
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionintReturns the SBE template id handled by this processor.voidprocess(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.voidsetNetServerSetting(NetServerSetting setting) Injects the runtime setting.
-
Constructor Details
-
ServerOfflineMessageOnFragment
public ServerOfflineMessageOnFragment()
-
-
Method Details
-
setNetServerSetting
Description copied from interface:NetServerSettingAwareInjects the runtime setting.- Specified by:
setNetServerSettingin interfaceNetServerSettingAware- 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:OnFragmentProcesses a fragment payload that has already been routed by template id.- Specified by:
processin interfaceOnFragment- Parameters:
buffer- source bufferoffset- message offsetactingBlockLength- SBE acting block lengthactingVersion- SBE acting versionheader- Aeron fragment header
-
getTemplateId
public int getTemplateId()Description copied from interface:OnFragmentReturns the SBE template id handled by this processor.- Specified by:
getTemplateIdin interfaceOnFragment- Returns:
- SBE template id
-