org.agilewiki.jasocket.cluster

Class AgentChannelManager

java.lang.Object

org.agilewiki.jactor.lpc.JLPCActor

org.agilewiki.jasocket.cluster.AgentChannelManager

All Implemented Interfaces:

org.agilewiki.jactor.Actor, org.agilewiki.jactor.apc.APCRequestSource, org.agilewiki.jactor.apc.RequestProcessor, org.agilewiki.jactor.lpc.RequestSource, org.agilewiki.jactor.lpc.TargetActor

public class AgentChannelManager
extends org.agilewiki.jactor.lpc.JLPCActor

Nested Class Summary

Nested classes/interfaces inherited from class org.agilewiki.jactor.lpc.JLPCActor

org.agilewiki.jactor.lpc.JLPCActor.SMBuilder

Field Summary

Fields

Modifier and Type	Field and Description
ConcurrentHashMap<String,Interpreter>	interpreters
protected HashMap<String,Server>	localServers
int	maxPacketSize
Node	node

Constructor Summary

Constructors

Constructor and Description
AgentChannelManager()

Method Summary

Methods

Modifier and Type	Method and Description
void	acceptSocket(SocketChannel socketChannel)
void	addRemoteServerName(String address, String name)
void	agentChannel(InetSocketAddress inetSocketAddress, org.agilewiki.jactor.RP rp)
void	agentChannel(String address, org.agilewiki.jactor.RP rp)
void	agentChannelClosed(AgentChannel agentChannel, org.agilewiki.jactor.RP rp)
String	agentChannelManagerAddress()
int	agentChannelManagerPort()
long	bytesRead()
long	bytesWritten()
TreeSet<String>	channels()
void	close()
AgentChannel	getAgentChannel(String address)
Server	getLocalServer(String name)
TreeMap<String,Server>	getLocalServers()
boolean	isLocalAddress(String address)
List<String>	locateServer(String name)
void	openServerSocket(InetSocketAddress inetSocketAddress)
void	openServerSocket(int port)
void	readTimeout()
void	received(AgentChannel agentChannel)
boolean	registerServer(String name, Server server)
void	removeRemoteServerName(String address, String name)
void	sent(String address)
TreeSet<String>	serverNames()
void	setClientPort(AgentChannel agentChannel, int port)
protected void	shipAgentEventToAll(AgentJid agent)
void	startKeepAlive(long readTimeout, long keepaliveTimeout)
boolean	subscribeServerNameNotifications(ServerNameListener serverNameListener)
org.agilewiki.jactor.lpc.JLPCActor	unregisterServer(String name)
boolean	unsubscribeServerNameNotifications(ServerNameListener serverNameListener)
void	writeTimeout()

Methods inherited from class org.agilewiki.jactor.lpc.JLPCActor

acceptEvent, acceptRequest, getActorType, getAncestor, getExceptionHandler, getFactory, getMailbox, getMailboxFactory, getMatch, getParent, hasDataItem, haveEvents, initialize, initialize, initialize, initialize, initialize, requirements, responseFrom, send, send, sendEvent, setExceptionHandler, setInitialBufferCapacity

Methods inherited from class java.lang.Object

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

Field Detail

node

public Node node

maxPacketSize

public int maxPacketSize

localServers

protected HashMap<String,Server> localServers

interpreters

public ConcurrentHashMap<String,Interpreter> interpreters

Constructor Detail

AgentChannelManager

public AgentChannelManager()

Method Detail

received

public void received(AgentChannel agentChannel)

sent

public void sent(String address)

channels

public TreeSet<String> channels()

bytesRead

public long bytesRead()

bytesWritten

public long bytesWritten()

getAgentChannel

public AgentChannel getAgentChannel(String address)
                             throws Exception

Throws:

Exception

readTimeout

public void readTimeout()
                 throws Exception

Throws:

Exception

writeTimeout

public void writeTimeout()
                  throws Exception

Throws:

Exception

startKeepAlive

public void startKeepAlive(long readTimeout,
                  long keepaliveTimeout)
                    throws Exception

Throws:

Exception

serverNames

public TreeSet<String> serverNames()

locateServer

public List<String> locateServer(String name)

subscribeServerNameNotifications

public boolean subscribeServerNameNotifications(ServerNameListener serverNameListener)
                                         throws Exception

Throws:

Exception

unsubscribeServerNameNotifications

public boolean unsubscribeServerNameNotifications(ServerNameListener serverNameListener)

agentChannelManagerAddress

public String agentChannelManagerAddress()
                                  throws Exception

Throws:

Exception

agentChannelManagerPort

public int agentChannelManagerPort()
                            throws Exception

Throws:

Exception

isLocalAddress

public boolean isLocalAddress(String address)
                       throws Exception

Throws:

Exception

getLocalServer

public Server getLocalServer(String name)

getLocalServers

public TreeMap<String,Server> getLocalServers()

shipAgentEventToAll

protected void shipAgentEventToAll(AgentJid agent)
                            throws Exception

Throws:

Exception

unregisterServer

public org.agilewiki.jactor.lpc.JLPCActor unregisterServer(String name)
                                                    throws Exception

Throws:

Exception

registerServer

public boolean registerServer(String name,
                     Server server)
                       throws Exception

Throws:

Exception

addRemoteServerName

public void addRemoteServerName(String address,
                       String name)
                         throws Exception

Throws:

Exception

removeRemoteServerName

public void removeRemoteServerName(String address,
                          String name)
                            throws Exception

Throws:

Exception

agentChannel

public void agentChannel(String address,
                org.agilewiki.jactor.RP rp)
                  throws Exception

Throws:

Exception

agentChannel

public void agentChannel(InetSocketAddress inetSocketAddress,
                org.agilewiki.jactor.RP rp)
                  throws Exception

Throws:

Exception

openServerSocket

public void openServerSocket(int port)
                      throws Exception

Throws:

Exception

openServerSocket

public void openServerSocket(InetSocketAddress inetSocketAddress)
                      throws Exception

Throws:

Exception

acceptSocket

public void acceptSocket(SocketChannel socketChannel)
                  throws Exception

Throws:

Exception

setClientPort

public void setClientPort(AgentChannel agentChannel,
                 int port)
                   throws Exception

Throws:

Exception

close

public void close()

agentChannelClosed

public void agentChannelClosed(AgentChannel agentChannel,
                      org.agilewiki.jactor.RP rp)
                        throws Exception

Throws:

Exception