org.agilewiki.jasocket.agentSocket

Class AgentSocket

java.lang.Object

org.agilewiki.jactor.lpc.JLPCActor

org.agilewiki.jasocket.agentSocket.AgentSocket

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

public class AgentSocket
extends org.agilewiki.jactor.lpc.JLPCActor
implements ExceptionProcessor

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
long	bytesRead
long	bytesWritten

Constructor Summary

Constructors

Constructor and Description
AgentSocket()

Method Summary

Methods

Modifier and Type	Method and Description
void	clientOpen(InetSocketAddress inetSocketAddress, int maxPacketSize)
void	close()
String	getRemoteAddress()
String	getRemoteHostAddress()
void	processException(Exception exception)
protected void	receiveByteBuffer(ByteBuffer byteBuffer)
void	serverOpen(SocketChannel socketChannel, int maxPacketSize)
void	setAgentChannel(AgentChannel agentChannel)
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

bytesRead

public long bytesRead

bytesWritten

public long bytesWritten

Constructor Detail

AgentSocket

public AgentSocket()

Method Detail

setAgentChannel

public void setAgentChannel(AgentChannel agentChannel)

receiveByteBuffer

protected void receiveByteBuffer(ByteBuffer byteBuffer)
                          throws Exception

Throws:

Exception

processException

public void processException(Exception exception)

Specified by:

processException in interface ExceptionProcessor

clientOpen

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

Throws:

Exception

serverOpen

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

Throws:

Exception

getRemoteAddress

public String getRemoteAddress()
                        throws Exception

Throws:

Exception

getRemoteHostAddress

public String getRemoteHostAddress()
                            throws Exception

Throws:

Exception

writeBytes

public void writeBytes(byte[] bytes)
                throws Exception

Throws:

Exception

close

public void close()