kieker.analysis.tt.reader.tcp.dualsocket

Class DualSocketTcpReaderStage

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.AbstractProducerStage<IMonitoringRecord>

kieker.analysis.tt.reader.tcp.dualsocket.DualSocketTcpReaderStage

Deprecated.

Since 1.13. Use SingleSocketTcpReaderStage instead. This DualSocketTcpReaderStage will be kept for research purposes.

@Deprecated
public final class DualSocketTcpReaderStage
extends teetime.framework.AbstractProducerStage<IMonitoringRecord>

This is a reader which reads the records from two TCP ports.

Since:

1.14

Author:

Jan Waller, Nils Christian Ehmke, 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
DualSocketTcpReaderStage() Deprecated. Default constructor with port1=10133, bufferCapacity=65535, and port2=10134.
DualSocketTcpReaderStage(int port1, int bufferCapacity, int port2) Deprecated.

Method Summary

Modifier and Type	Method and Description
protected void	execute() Deprecated.
int	getPort1() Deprecated.
int	getPort2() Deprecated.
void	onStarting() Deprecated.
void	onTerminating() Deprecated.

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, 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

DualSocketTcpReaderStage

public DualSocketTcpReaderStage()

Deprecated.

Default constructor with port1=10133, bufferCapacity=65535, and port2=10134.

DualSocketTcpReaderStage

public DualSocketTcpReaderStage(int port1,
                                int bufferCapacity,
                                int port2)

Deprecated.

Parameters:

port1 - used to accept IMonitoringRecords

port2 - used to accept StringRecords

bufferCapacity - capacity of the receiving buffer

Method Detail

onStarting

public void onStarting()

Deprecated.

Overrides:

onStarting in class teetime.framework.AbstractStage

execute

protected void execute()

Deprecated.

Specified by:

execute in class teetime.framework.AbstractStage

onTerminating

public void onTerminating()

Deprecated.

Overrides:

onTerminating in class teetime.framework.AbstractStage

getPort1

public int getPort1()

Deprecated.

getPort2

public int getPort2()

Deprecated.