atavism.msgsys
Class DomainServer

java.lang.Object
  atavism.msgsys.DomainServer

All Implemented Interfaces:

MessageIO.Callback, TcpAcceptCallback

public class DomainServer
extends java.lang.Object
implements TcpAcceptCallback, MessageIO.Callback

Message system domain server. A message domain is a set of communicating 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:

-a <agent-name>
Specify the names of all agents in the domain. Repeat the option for each agent.

-p <port>
Domain server port number.

Field Summary

static int

DEFAULT_PORT

Constructor Summary

DomainServer(int port)

Method Summary

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()

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_PORT

public static final int DEFAULT_PORT

See Also:

Constant Field Values

Constructor Detail

DomainServer

public DomainServer(int port)

Method Detail

main

public static void main(java.lang.String[] args)

setAgentNames

public void setAgentNames(java.util.List<java.lang.String> names)

getAgentNames

public java.util.List<java.lang.String> getAgentNames()

getWorldName

public java.lang.String getWorldName()

setWorldName

public void setWorldName(java.lang.String worldName)

start

public void start()

onTcpAccept

public void onTcpAccept(java.nio.channels.SocketChannel agentSocket)

Specified by:

onTcpAccept in interface TcpAcceptCallback

handleMessageData

public void handleMessageData(int length,
                              AOByteBuffer messageData,
                              AgentInfo agentInfo)

Specified by:

handleMessageData in interface MessageIO.Callback

addPluginStartGroup

public void addPluginStartGroup(atavism.msgsys.DomainServer.PluginStartGroup startGroup)