kieker.analysisteetime.plugin.reader.tcp.singlesocket

Class SingleSocketTcpReaderStage

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.AbstractProducerStage<IMonitoringRecord>

kieker.analysisteetime.plugin.reader.tcp.singlesocket.SingleSocketTcpReaderStage

All Implemented Interfaces:

IRecordReceivedListener

public final class SingleSocketTcpReaderStage
extends teetime.framework.AbstractProducerStage<IMonitoringRecord>
implements IRecordReceivedListener

This is a reader which reads the records from a TCP port.

Since:

1.14

Author:

Christian Wulf

Field Summary

Fields inherited from class teetime.framework.AbstractProducerStage

outputPort

Fields inherited from class teetime.framework.AbstractStage

logger

Constructor Summary

Constructors

Constructor and Description
SingleSocketTcpReaderStage() Default constructor with port1=10133 and bufferCapacity=65535.
SingleSocketTcpReaderStage(int port, int bufferCapacity)

Method Summary

Modifier and Type	Method and Description
protected void	execute()
int	getPort()
void	onRecordReceived(IMonitoringRecord record)

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

SingleSocketTcpReaderStage

public SingleSocketTcpReaderStage()

Default constructor with port1=10133 and bufferCapacity=65535.

SingleSocketTcpReaderStage

public SingleSocketTcpReaderStage(int port,
                                  int bufferCapacity)

Parameters:

port - used to accept IMonitoringRecords and string registry entries.

bufferCapacity - capacity of the receiving buffer

Method Detail

execute

protected void execute()

Specified by:

execute in class teetime.framework.AbstractStage

onRecordReceived

public void onRecordReceived(IMonitoringRecord record)

Specified by:

onRecordReceived in interface IRecordReceivedListener

getPort

public int getPort()