atavism.server.network

Class ClientTCPMessageIO

java.lang.Object

atavism.msgsys.MessageIO

atavism.server.network.ClientTCPMessageIO

All Implemented Interfaces:

MessageIO.Callback, TcpAcceptCallback, java.lang.Runnable

public class ClientTCPMessageIO
extends MessageIO
implements TcpAcceptCallback, MessageIO.Callback

Nested Class Summary

Nested classes/interfaces inherited from class atavism.msgsys.MessageIO

MessageIO.Callback

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ClientTCPMessageIO()
protected	ClientTCPMessageIO(java.net.InetSocketAddress bindAddress, ClientConnection.MessageCallback messageCallback, ClientConnection.AcceptCallback acceptCallback)
protected	ClientTCPMessageIO(int messageLengthByteCount)
protected	ClientTCPMessageIO(int messageLengthByteCount, java.net.InetSocketAddress bindAddress, ClientConnection.MessageCallback messageCallback, ClientConnection.AcceptCallback acceptCallback)

Method Summary

Modifier and Type	Method and Description
void	acceptConnection(ClientConnection con) The default implmentation of ClientConnection.AcceptCallback
int	getListenerPort()
void	handleMessageData(int length, AOByteBuffer buf, AgentInfo agentInfo)
void	onTcpAccept(java.nio.channels.SocketChannel agentSocket)
void	openListener(java.net.InetSocketAddress bindAddress)
static ClientTCPMessageIO	setup()
static ClientTCPMessageIO	setup(java.net.InetSocketAddress bindAddress, ClientConnection.MessageCallback messageCallback, ClientConnection.AcceptCallback acceptCallback)
static ClientTCPMessageIO	setup(java.lang.Integer port, ClientConnection.MessageCallback messageCallback)
static ClientTCPMessageIO	setup(java.lang.Integer port, ClientConnection.MessageCallback messageCallback, ClientConnection.AcceptCallback acceptCallback)
static ClientTCPMessageIO	setup(int messageLengthByteCount, java.net.InetSocketAddress bindAddress, ClientConnection.MessageCallback messageCallback, ClientConnection.AcceptCallback acceptCallback)
static ClientTCPMessageIO	setup(int messageLengthByteCount, java.lang.Integer port, ClientConnection.MessageCallback messageCallback, ClientConnection.AcceptCallback acceptCallback)
protected void	startListener(java.net.InetSocketAddress bindAddress)

Methods inherited from class atavism.msgsys.MessageIO

addAgent, addToOutput, addToOutputWithLength, getMessageLengthByteCount, initialize, outputReady, removeAgent, run, setMessageLengthByteCount, start, start

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientTCPMessageIO

protected ClientTCPMessageIO()

ClientTCPMessageIO

protected ClientTCPMessageIO(int messageLengthByteCount)

ClientTCPMessageIO

protected ClientTCPMessageIO(java.net.InetSocketAddress bindAddress,
                             ClientConnection.MessageCallback messageCallback,
                             ClientConnection.AcceptCallback acceptCallback)

ClientTCPMessageIO

protected ClientTCPMessageIO(int messageLengthByteCount,
                             java.net.InetSocketAddress bindAddress,
                             ClientConnection.MessageCallback messageCallback,
                             ClientConnection.AcceptCallback acceptCallback)

Method Detail

setup

public static ClientTCPMessageIO setup()

setup

public static ClientTCPMessageIO setup(java.net.InetSocketAddress bindAddress,
                                       ClientConnection.MessageCallback messageCallback,
                                       ClientConnection.AcceptCallback acceptCallback)

setup

public static ClientTCPMessageIO setup(int messageLengthByteCount,
                                       java.net.InetSocketAddress bindAddress,
                                       ClientConnection.MessageCallback messageCallback,
                                       ClientConnection.AcceptCallback acceptCallback)

setup

public static ClientTCPMessageIO setup(java.lang.Integer port,
                                       ClientConnection.MessageCallback messageCallback)

setup

public static ClientTCPMessageIO setup(java.lang.Integer port,
                                       ClientConnection.MessageCallback messageCallback,
                                       ClientConnection.AcceptCallback acceptCallback)

setup

public static ClientTCPMessageIO setup(int messageLengthByteCount,
                                       java.lang.Integer port,
                                       ClientConnection.MessageCallback messageCallback,
                                       ClientConnection.AcceptCallback acceptCallback)

handleMessageData

public void handleMessageData(int length,
                              AOByteBuffer buf,
                              AgentInfo agentInfo)

Specified by:

handleMessageData in interface MessageIO.Callback

startListener

protected void startListener(java.net.InetSocketAddress bindAddress)

getListenerPort

public int getListenerPort()

openListener

public void openListener(java.net.InetSocketAddress bindAddress)
                  throws java.io.IOException

Throws:

java.io.IOException

onTcpAccept

public void onTcpAccept(java.nio.channels.SocketChannel agentSocket)

Specified by:

onTcpAccept in interface TcpAcceptCallback

acceptConnection

public void acceptConnection(ClientConnection con)

The default implmentation of ClientConnection.AcceptCallback