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 for TCP connections.
MultipleConnectionTcpSourceCompositeStage(int inputPort, int capacity, ITraceMetadataRewriter rewriter) Create a composite reader stage for TCP connections .

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 for TCP connections.

Parameters:

configuration - configuration parameters

Throws:

ConfigurationException - on configuration errors during instantiation

MultipleConnectionTcpSourceCompositeStage

public MultipleConnectionTcpSourceCompositeStage(int inputPort,
                                                 int capacity,
                                                 ITraceMetadataRewriter rewriter)

Create a composite reader stage for TCP connections .

Parameters:

inputPort - the input port to listen to

capacity - internal ready buffer size, the buffer size must be at least as big as the largest incoming event

rewriter - trace record metadata rewriter, (necessary when multiple sources send traces).

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