Class DefaultConnectionManager

java.lang.Object

com.iohao.net.server.connection.DefaultConnectionManager

All Implemented Interfaces:

CommonConnectionManager, ConnectionManager

public final class DefaultConnectionManager
extends Object
implements ConnectionManager

DefaultConnectionManager

Since:

25.1

Author:

渔民小镇

date:

2025-09-06

Constructor Summary

Constructors

Constructor	Description
DefaultConnectionManager(ConnectionManagerParameter parameter)

Method Summary

Modifier and Type	Method	Description
void	addConnection(ConnectionItem connection)
void	awaitConnect()
boolean	containsNetId(int netId)
io.aeron.Publication	getPublicationByNetId(int netId)
int	poll(io.aeron.logbuffer.FragmentHandler fragmentHandler)
void	publishMessage(int serverId, Object message)
void	publishMessage(String pubName, Object message)
void	publishMessageByNetId(int netId, Object message)
void	publishMessageToCenter(Object message)

Methods inherited from class Object

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

Constructor Details

DefaultConnectionManager

public DefaultConnectionManager(ConnectionManagerParameter parameter)

Method Details

containsNetId

public boolean containsNetId(int netId)

Specified by:

containsNetId in interface CommonConnectionManager

awaitConnect

public void awaitConnect()

Specified by:

awaitConnect in interface ConnectionManager

getPublicationByNetId

public io.aeron.Publication getPublicationByNetId(int netId)

Specified by:

getPublicationByNetId in interface CommonConnectionManager

publishMessageToCenter

public void publishMessageToCenter(Object message)

Specified by:

publishMessageToCenter in interface ConnectionManager

publishMessage

public void publishMessage(int serverId,
 Object message)

Specified by:

publishMessage in interface ConnectionManager

publishMessage

public void publishMessage(String pubName,
 Object message)

Specified by:

publishMessage in interface CommonConnectionManager

publishMessageByNetId

public void publishMessageByNetId(int netId,
 Object message)

Specified by:

publishMessageByNetId in interface ConnectionManager

addConnection

public void addConnection(ConnectionItem connection)

Specified by:

addConnection in interface ConnectionManager

poll

public int poll(io.aeron.logbuffer.FragmentHandler fragmentHandler)

Specified by:

poll in interface CommonConnectionManager