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 |
---|---|
protected static java.lang.reflect.Method |
cpuMethod |
static int |
DEFAULT_PORT |
protected static int |
processorCount |
Constructor and Description |
---|
DomainServer(int port) |
Modifier and Type | Method and Description |
---|---|
void |
addPluginStartGroup(atavism.msgsys.DomainServer.PluginStartGroup startGroup) |
protected static long |
getProcessCpuTime(java.lang.reflect.Method cpuMethod,
java.lang.Object mxbean)
Common method to get the process CPU time.
|
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) |
static void |
runStatusReporting() |
void |
setWorldName(java.lang.String worldName) |
void |
start() |
public static final int DEFAULT_PORT
protected static java.lang.reflect.Method cpuMethod
protected static int processorCount
public static void main(java.lang.String[] args)
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)
public static void runStatusReporting()
protected static long getProcessCpuTime(java.lang.reflect.Method cpuMethod, java.lang.Object mxbean)
cpuMethod
- A Method object that returns the process CPU time.mxbean
- The JavaBean used to get the CPU time.