org.agilewiki.jasocket.agentChannel

Class AgentChannel

java.lang.Object

org.agilewiki.jactor.lpc.JLPCActor

org.agilewiki.jasocket.agentChannel.AgentChannel

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, ExceptionProcessor, SocketProtocol

public class AgentChannel
extends org.agilewiki.jactor.lpc.JLPCActor
implements SocketProtocol

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<Long,AgentJid>	agents
String	remoteAddress

Constructor Summary

Constructors

Constructor and Description
AgentChannel()

Method Summary

Methods

Modifier and Type	Method and Description
AgentChannelManager	agentChannelManager()
long	bytesRead()
long	bytesWritten()
void	closeChannel()
protected void	gotEvent(AgentJid agentJid)
protected void	gotRsp(Long requestId, org.agilewiki.jid.Jid jid)
boolean	isClient()
void	open(InetSocketAddress inetSocketAddress, int maxPacketSize)
void	processException(Exception exception)
void	receiveBytes(byte[] bytes)
void	received()
String	remoteAddress()
int	remotePort()
void	sent()
void	serverOpen(SocketChannel socketChannel, int maxPacketSize)
void	setClientPort(int port)
void	shipAgent(AgentJid agent, org.agilewiki.jactor.RP rp)
void	writeBytes(byte[] bytes)

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

Methods inherited from interface org.agilewiki.jactor.lpc.TargetActor

setExceptionHandler

Methods inherited from interface org.agilewiki.jactor.Actor

acceptEvent, acceptRequest, getActorType, getAncestor, getFactory, getMailbox, getMatch, getParent, hasDataItem, setInitialBufferCapacity

Field Detail

remoteAddress

public String remoteAddress

agents

public ConcurrentHashMap<Long,AgentJid> agents

Constructor Detail

AgentChannel

public AgentChannel()

Method Detail

bytesRead

public long bytesRead()

bytesWritten

public long bytesWritten()

agentChannelManager

public AgentChannelManager agentChannelManager()

received

public void received()

sent

public void sent()

isClient

public boolean isClient()

remoteAddress

public String remoteAddress()

remotePort

public int remotePort()

writeBytes

public void writeBytes(byte[] bytes)
                throws Exception

Throws:

Exception

processException

public void processException(Exception exception)
                      throws Exception

Specified by:

processException in interface ExceptionProcessor

Throws:

Exception

open

public void open(InetSocketAddress inetSocketAddress,
        int maxPacketSize)
          throws Exception

Throws:

Exception

serverOpen

public void serverOpen(SocketChannel socketChannel,
              int maxPacketSize)
                throws Exception

Throws:

Exception

setClientPort

public void setClientPort(int port)
                   throws Exception

Throws:

Exception

closeChannel

public void closeChannel()

gotEvent

protected void gotEvent(AgentJid agentJid)
                 throws Exception

Throws:

Exception

receiveBytes

public void receiveBytes(byte[] bytes)
                  throws Exception

Specified by:

receiveBytes in interface SocketProtocol

Throws:

Exception

gotRsp

protected void gotRsp(Long requestId,
          org.agilewiki.jid.Jid jid)
               throws Exception

Throws:

Exception

shipAgent

public void shipAgent(AgentJid agent,
             org.agilewiki.jactor.RP rp)
               throws Exception

Throws:

Exception