teetime.stage.io

Class AbstractTcpReaderStage<T>

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.AbstractProducerStage<T>

teetime.stage.io.AbstractTcpReaderStage<T>

public abstract class AbstractTcpReaderStage<T>
extends AbstractProducerStage<T>

Field Summary

Fields inherited from class teetime.framework.AbstractProducerStage

outputPort

Fields inherited from class teetime.framework.AbstractStage

logger

Constructor Summary

Constructors

Constructor and Description
AbstractTcpReaderStage(int port, int bufferCapacity)

Method Summary

Modifier and Type	Method and Description
protected void	execute() Contains the logic of this stage and is invoked (possibly multiple times) by the framework.
protected abstract boolean	read(ByteBuffer buffer)

Methods inherited from class teetime.framework.AbstractProducerStage

getOutputPort, getTerminationStrategy

Methods inherited from class teetime.framework.AbstractStage

abort, addInputPortRemovedListener, addOutputPortRemovedListener, compareAndSetBeingExecuted, createInputPort, createInputPort, createInputPort, createInputPort, createOutputPort, createOutputPort, createOutputPort, createOutputPort, declareActive, declarePassive, executeByFramework, getCurrentState, getId, getInputPorts, getOutputPorts, getOwningThread, isActive, isBeingExecuted, isPaused, isProducer, isStateless, onSignal, onStarting, onTerminating, onValidating, removeDynamicPort, removeDynamicPort, setPaused, setStateless, shouldBeTerminated, signalAlreadyReceived, terminateStage, toString, workCompleted

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractTcpReaderStage

public AbstractTcpReaderStage(int port,
                              int bufferCapacity)

Method Detail

execute

protected void execute()

Description copied from class: AbstractStage

Contains the logic of this stage and is invoked (possibly multiple times) by the framework.

Specified by:

execute in class AbstractStage

read

protected abstract boolean read(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.