public class AgentSocket extends org.agilewiki.jactor.lpc.JLPCActor implements ExceptionProcessor
Modifier and Type | Field and Description |
---|---|
long |
bytesRead |
long |
bytesWritten |
Constructor and Description |
---|
AgentSocket() |
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) |
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 void setAgentChannel(AgentChannel agentChannel)
protected void receiveByteBuffer(ByteBuffer byteBuffer) throws Exception
Exception
public void processException(Exception exception)
processException
in interface ExceptionProcessor
public void clientOpen(InetSocketAddress inetSocketAddress, int maxPacketSize) throws Exception
Exception
public void serverOpen(SocketChannel socketChannel, int maxPacketSize) throws Exception
Exception
public void close()
Copyright © 2013. All Rights Reserved.