multiverse.msgsys
Class DomainServer

java.lang.Object
  multiverse.msgsys.DomainServer

All Implemented Interfaces:

MessageIO.Callback, multiverse.server.network.TcpAcceptCallback

public class DomainServer
extends java.lang.Object
implements multiverse.server.network.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 multiverse.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.

Constructor Summary

DomainServer(int port)

Method Summary

void	addPluginStartGroup(multiverse.msgsys.DomainServer.PluginStartGroup startGroup)
java.util.List<java.lang.String>	getAgentNames()
java.lang.String	getWorldName()
void	handleMessageData(int length, multiverse.server.network.MVByteBuffer 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

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 multiverse.server.network.TcpAcceptCallback

handleMessageData

public void handleMessageData(int length,
                              multiverse.server.network.MVByteBuffer messageData,
                              AgentInfo agentInfo)

Specified by:

handleMessageData in interface MessageIO.Callback

addPluginStartGroup

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