teetime.util.stage.io.network

Class AbstractTcpReader

java.lang.Object

teetime.util.stage.io.network.AbstractTcpReader

All Implemented Interfaces:

Runnable

public abstract class AbstractTcpReader
extends Object
implements Runnable

Field Summary

Fields

Modifier and Type	Field and Description
protected org.slf4j.Logger	logger

Constructor Summary

Constructors

Constructor and Description
AbstractTcpReader(int port, int bufferCapacity, org.slf4j.Logger logger)

Method Summary

Modifier and Type	Method and Description
int	getPort()
protected abstract boolean	onBufferReceived(ByteBuffer buffer)
void	run()
void	terminate()

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected final org.slf4j.Logger logger

Constructor Detail

AbstractTcpReader

public AbstractTcpReader(int port,
                         int bufferCapacity,
                         org.slf4j.Logger logger)

Method Detail

run

public final void run()

Specified by:

run in interface Runnable

onBufferReceived

protected abstract boolean onBufferReceived(ByteBuffer buffer)

Parameters:

buffer - to be read from

Returns:

• true when there were enough bytes to perform the read operation
• false otherwise. In this case, the buffer is reset, compacted, and filled with new content.

terminate

public void terminate()

getPort

public int getPort()