Class DefaultCommunicationAggregation
java.lang.Object
com.iohao.net.server.DefaultCommunicationAggregation
- All Implemented Interfaces:
BroadcastCommunication, CommunicationAggregation, EventBusMessageCommunication, ExternalCollectCommunication, ExternalCommunication, LogicCollectCommunication, LogicCommunication, PublisherCommunication, NetServerSettingAware
public class DefaultCommunicationAggregation
extends Object
implements CommunicationAggregation, NetServerSettingAware
DefaultCommunicationAggregation
- Since:
- 25.1
- Author:
- 渔民小镇
- date:
- 2025-09-07
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidbroadcast(BroadcastMulticastMessage message) voidbroadcast(BroadcastUserListMessage message) voidbroadcast(BroadcastUserMessage message) call(RequestMessage message) callCollect(RequestMessage message) callCollectFuture(RequestMessage message) callExternal(ExternalRequestMessage message) callExternalFuture(ExternalRequestMessage message) callFuture(RequestMessage message) voidfireRemote(EventBusMessage message) protected CompletableFuture<Response> ofErrorFuture(ErrorInformation errorInformation) voidpublishMessage(int serverId, Object message) voidpublishMessage(String name, Object message) voidpublishMessageByNetId(int netId, Object message) voidsend(SendMessage message) voidsetNetServerSetting(NetServerSetting setting) voidwriteMessage(UserResponseMessage message)
-
Constructor Details
-
DefaultCommunicationAggregation
public DefaultCommunicationAggregation()
-
-
Method Details
-
setNetServerSetting
- Specified by:
setNetServerSettingin interfaceNetServerSettingAware
-
publishMessageByNetId
- Specified by:
publishMessageByNetIdin interfacePublisherCommunication
-
publishMessage
- Specified by:
publishMessagein interfacePublisherCommunication
-
publishMessage
- Specified by:
publishMessagein interfacePublisherCommunication
-
writeMessage
- Specified by:
writeMessagein interfaceExternalCollectCommunication
-
broadcast
- Specified by:
broadcastin interfaceBroadcastCommunication
-
broadcast
- Specified by:
broadcastin interfaceBroadcastCommunication
-
broadcast
- Specified by:
broadcastin interfaceBroadcastCommunication
-
callExternal
- Specified by:
callExternalin interfaceExternalCommunication
-
callExternalFuture
- Specified by:
callExternalFuturein interfaceExternalCommunication
-
callCollectExternalFuture
public CompletableFuture<ResponseCollectExternal> callCollectExternalFuture(ExternalRequestMessage message) - Specified by:
callCollectExternalFuturein interfaceExternalCollectCommunication
-
callCollectExternal
- Specified by:
callCollectExternalin interfaceExternalCollectCommunication
-
bindingLogicServerFuture
public CompletableFuture<CommonResponse> bindingLogicServerFuture(BindingLogicServerMessage message) - Specified by:
bindingLogicServerFuturein interfaceExternalCollectCommunication
-
bindingLogicServer
- Specified by:
bindingLogicServerin interfaceExternalCollectCommunication
-
callFuture
- Specified by:
callFuturein interfaceLogicCommunication
-
call
- Specified by:
callin interfaceLogicCommunication
-
send
- Specified by:
sendin interfaceLogicCommunication
-
callCollectFuture
- Specified by:
callCollectFuturein interfaceLogicCollectCommunication
-
callCollect
- Specified by:
callCollectin interfaceLogicCollectCommunication
-
ofErrorFuture
-
fireRemote
- Specified by:
fireRemotein interfaceEventBusMessageCommunication
-