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

Constructor	Description
DefaultCommunicationAggregation()

Method Summary

Modifier and Type	Method	Description
CommonResponse	bindingLogicServer(BindingLogicServerMessage message)
CompletableFuture<CommonResponse>	bindingLogicServerFuture(BindingLogicServerMessage message)
void	broadcast(BroadcastMulticastMessage message)
void	broadcast(BroadcastUserListMessage message)
void	broadcast(BroadcastUserMessage message)
Response	call(RequestMessage message)
ResponseCollect	callCollect(RequestMessage message)
ResponseCollectExternal	callCollectExternal(ExternalRequestMessage message)
CompletableFuture<ResponseCollectExternal>	callCollectExternalFuture(ExternalRequestMessage message)
CompletableFuture<ResponseCollect>	callCollectFuture(RequestMessage message)
ExternalResponse	callExternal(ExternalRequestMessage message)
CompletableFuture<ExternalResponse>	callExternalFuture(ExternalRequestMessage message)
CompletableFuture<Response>	callFuture(RequestMessage message)
void	fireRemote(EventBusMessage message)
protected CompletableFuture<Response>	ofErrorFuture(ErrorInformation errorInformation)
void	publishMessage(int serverId, Object message)
void	publishMessage(String name, Object message)
void	publishMessageByNetId(int netId, Object message)
void	send(SendMessage message)
void	setNetServerSetting(NetServerSetting setting)
void	writeMessage(UserResponseMessage message)

Methods inherited from class Object

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

Constructor Details

DefaultCommunicationAggregation

public DefaultCommunicationAggregation()

Method Details

setNetServerSetting

public void setNetServerSetting(NetServerSetting setting)

Specified by:

setNetServerSetting in interface NetServerSettingAware

publishMessageByNetId

public void publishMessageByNetId(int netId,
 Object message)

Specified by:

publishMessageByNetId in interface PublisherCommunication

publishMessage

public void publishMessage(int serverId,
 Object message)

Specified by:

publishMessage in interface PublisherCommunication

publishMessage

public void publishMessage(String name,
 Object message)

Specified by:

publishMessage in interface PublisherCommunication

writeMessage

public void writeMessage(UserResponseMessage message)

Specified by:

writeMessage in interface ExternalCollectCommunication

broadcast

public void broadcast(BroadcastUserMessage message)

Specified by:

broadcast in interface BroadcastCommunication

broadcast

public void broadcast(BroadcastUserListMessage message)

Specified by:

broadcast in interface BroadcastCommunication

broadcast

public void broadcast(BroadcastMulticastMessage message)

Specified by:

broadcast in interface BroadcastCommunication

callExternal

public ExternalResponse callExternal(ExternalRequestMessage message)

Specified by:

callExternal in interface ExternalCommunication

callExternalFuture

public CompletableFuture<ExternalResponse> callExternalFuture(ExternalRequestMessage message)

Specified by:

callExternalFuture in interface ExternalCommunication

callCollectExternalFuture

public CompletableFuture<ResponseCollectExternal> callCollectExternalFuture(ExternalRequestMessage message)

Specified by:

callCollectExternalFuture in interface ExternalCollectCommunication

callCollectExternal

public ResponseCollectExternal callCollectExternal(ExternalRequestMessage message)

Specified by:

callCollectExternal in interface ExternalCollectCommunication

bindingLogicServerFuture

public CompletableFuture<CommonResponse> bindingLogicServerFuture(BindingLogicServerMessage message)

Specified by:

bindingLogicServerFuture in interface ExternalCollectCommunication

bindingLogicServer

public CommonResponse bindingLogicServer(BindingLogicServerMessage message)

Specified by:

bindingLogicServer in interface ExternalCollectCommunication

callFuture

public CompletableFuture<Response> callFuture(RequestMessage message)

Specified by:

callFuture in interface LogicCommunication

call

public Response call(RequestMessage message)

Specified by:

call in interface LogicCommunication

send

public void send(SendMessage message)

Specified by:

send in interface LogicCommunication

callCollectFuture

public CompletableFuture<ResponseCollect> callCollectFuture(RequestMessage message)

Specified by:

callCollectFuture in interface LogicCollectCommunication

callCollect

public ResponseCollect callCollect(RequestMessage message)

Specified by:

callCollect in interface LogicCollectCommunication

ofErrorFuture

protected CompletableFuture<Response> ofErrorFuture(ErrorInformation errorInformation)

fireRemote

public void fireRemote(EventBusMessage message)

Specified by:

fireRemote in interface EventBusMessageCommunication