kieker.tools.source

Class MultipleConnectionTcpSourceCompositeStage

java.lang.Object

teetime.framework.CompositeStage

kieker.tools.source.MultipleConnectionTcpSourceCompositeStage

All Implemented Interfaces:

ISourceCompositeStage

public class MultipleConnectionTcpSourceCompositeStage
extends teetime.framework.CompositeStage
implements ISourceCompositeStage

Multiple TCP input composite stage. This wrapper composite stage allows to configure the MultipleConnectionTcpSourceStage via a configuration object. Configuration parameters are:

port

port where the service is listening on

capacity

capacity of the receiving buffer

recordRewriter

the record rewriter used to rewrite trace ids

All names are prefixed with kieker.tools.source.MultipleConnectionTcpSourceCompositeStage.

Since:

1.15

Author:

Reiner Jung

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	SOURCE_PORT

Fields inherited from class teetime.framework.CompositeStage

DEFAULT_PIPE_CAPACITY

Constructor Summary

Constructors

Constructor and Description
MultipleConnectionTcpSourceCompositeStage(Configuration configuration) Create a composite reader stage.

Method Summary

Modifier and Type	Method and Description
teetime.framework.OutputPort<IMonitoringRecord>	getOutputPort() get the output port of a source composite stage.

Methods inherited from class teetime.framework.CompositeStage

connectPorts, connectPorts, createInputPort, createOutputPort

Methods inherited from class java.lang.Object

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

Field Detail

SOURCE_PORT

public static final java.lang.String SOURCE_PORT

Constructor Detail

MultipleConnectionTcpSourceCompositeStage

public MultipleConnectionTcpSourceCompositeStage(Configuration configuration)
                                          throws ConfigurationException

Create a composite reader stage.

Parameters:

configuration - configuration parameters

Throws:

ConfigurationException - on configuration errors during instantiation

Method Detail

getOutputPort

public teetime.framework.OutputPort<IMonitoringRecord> getOutputPort()

Description copied from interface: ISourceCompositeStage

get the output port of a source composite stage.

Specified by:

getOutputPort in interface ISourceCompositeStage

Returns:

the proper output port