public class AgentChannelManager
extends org.agilewiki.jactor.lpc.JLPCActor
Modifier and Type | Field and Description |
---|---|
ConcurrentHashMap<String,Interpreter> |
interpreters |
protected HashMap<String,Server> |
localServers |
int |
maxPacketSize |
Node |
node |
Constructor and Description |
---|
AgentChannelManager() |
acceptEvent, acceptRequest, getActorType, getAncestor, getExceptionHandler, getFactory, getMailbox, getMailboxFactory, getMatch, getParent, hasDataItem, haveEvents, initialize, initialize, initialize, initialize, initialize, requirements, responseFrom, send, send, sendEvent, setExceptionHandler, setInitialBufferCapacity
public Node node
public int maxPacketSize
public ConcurrentHashMap<String,Interpreter> interpreters
public void received(AgentChannel agentChannel)
public void sent(String address)
public long bytesRead()
public long bytesWritten()
public AgentChannel getAgentChannel(String address) throws Exception
Exception
public void startKeepAlive(long readTimeout, long keepaliveTimeout) throws Exception
Exception
public boolean subscribeServerNameNotifications(ServerNameListener serverNameListener) throws Exception
Exception
public boolean unsubscribeServerNameNotifications(ServerNameListener serverNameListener)
public String agentChannelManagerAddress() throws Exception
Exception
protected void shipAgentEventToAll(AgentJid agent) throws Exception
Exception
public org.agilewiki.jactor.lpc.JLPCActor unregisterServer(String name) throws Exception
Exception
public boolean registerServer(String name, Server server) throws Exception
Exception
public void addRemoteServerName(String address, String name) throws Exception
Exception
public void removeRemoteServerName(String address, String name) throws Exception
Exception
public void agentChannel(String address, org.agilewiki.jactor.RP rp) throws Exception
Exception
public void agentChannel(InetSocketAddress inetSocketAddress, org.agilewiki.jactor.RP rp) throws Exception
Exception
public void openServerSocket(InetSocketAddress inetSocketAddress) throws Exception
Exception
public void acceptSocket(SocketChannel socketChannel) throws Exception
Exception
public void setClientPort(AgentChannel agentChannel, int port) throws Exception
Exception
public void close()
public void agentChannelClosed(AgentChannel agentChannel, org.agilewiki.jactor.RP rp) throws Exception
Exception
Copyright © 2013. All Rights Reserved.