atavism.msgsys

Class MessageIO

java.lang.Object

atavism.msgsys.MessageIO

All Implemented Interfaces:

java.lang.Runnable

Direct Known Subclasses:

ClientTCPMessageIO

public class MessageIO
extends java.lang.Object
implements java.lang.Runnable

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	MessageIO.Callback

Constructor Summary

Constructors

Constructor and Description
MessageIO()
MessageIO(int messageLengthByteCount)
MessageIO(MessageIO.Callback callback)

Method Summary

Modifier and Type	Method and Description
void	addAgent(AgentInfo agentInfo)
void	addToOutput(AOByteBuffer buf, AgentInfo agentInfo)
void	addToOutputWithLength(AOByteBuffer buf, AgentInfo agentInfo)
int	getMessageLengthByteCount()
protected void	initialize(MessageIO.Callback callback)
void	outputReady()
void	removeAgent(AgentInfo agentInfo)
void	run()
void	setMessageLengthByteCount(int messageLengthByteCount)
void	start()
void	start(java.lang.String threadName)

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageIO

public MessageIO()

MessageIO

public MessageIO(int messageLengthByteCount)

MessageIO

public MessageIO(MessageIO.Callback callback)

Method Detail

initialize

protected void initialize(MessageIO.Callback callback)

start

public void start()

start

public void start(java.lang.String threadName)

addAgent

public void addAgent(AgentInfo agentInfo)

removeAgent

public void removeAgent(AgentInfo agentInfo)

outputReady

public void outputReady()

addToOutputWithLength

public void addToOutputWithLength(AOByteBuffer buf,
                                  AgentInfo agentInfo)

addToOutput

public void addToOutput(AOByteBuffer buf,
                        AgentInfo agentInfo)

run

public void run()

Specified by:

run in interface java.lang.Runnable

getMessageLengthByteCount

public int getMessageLengthByteCount()

setMessageLengthByteCount

public void setMessageLengthByteCount(int messageLengthByteCount)