public class DomainServer extends java.lang.Object implements TcpAcceptCallback, MessageIO.Callback
MessageAgents
using the same
DomainServer. The DomainServer maintains a registry of all member
agents and keeps the agents informed of membership changes. No
subscription or message traffic passes through the domain server.
The domain server port defaults to 20374. Over-ride with property
atavism.msgsvr_port or command-line option -p
.
Command-line parameters:
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_PORT |
Constructor and Description |
---|
DomainServer(int port) |
Modifier and Type | Method and Description |
---|---|
void |
addPluginStartGroup(atavism.msgsys.DomainServer.PluginStartGroup startGroup) |
java.util.List<java.lang.String> |
getAgentNames() |
java.lang.String |
getWorldName() |
void |
handleMessageData(int length,
AOByteBuffer messageData,
AgentInfo agentInfo) |
static void |
main(java.lang.String[] args) |
void |
onTcpAccept(java.nio.channels.SocketChannel agentSocket) |
void |
setAgentNames(java.util.List<java.lang.String> names) |
void |
setWorldName(java.lang.String worldName) |
void |
start() |
public static final int DEFAULT_PORT
public static void main(java.lang.String[] args)
public void setAgentNames(java.util.List<java.lang.String> names)
public java.util.List<java.lang.String> getAgentNames()
public java.lang.String getWorldName()
public void setWorldName(java.lang.String worldName)
public void start()
public void onTcpAccept(java.nio.channels.SocketChannel agentSocket)
onTcpAccept
in interface TcpAcceptCallback
public void handleMessageData(int length, AOByteBuffer messageData, AgentInfo agentInfo)
handleMessageData
in interface MessageIO.Callback
public void addPluginStartGroup(atavism.msgsys.DomainServer.PluginStartGroup startGroup)