Package 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	Description
static final String	SOURCE_PORT

Fields inherited from class teetime.framework.CompositeStage

DEFAULT_PIPE_CAPACITY

Constructor Summary

Constructors

Constructor	Description
MultipleConnectionTcpSourceCompositeStage(int inputPort, int capacity, ITraceMetadataRewriter rewriter)	Create a composite reader stage for TCP connections .
MultipleConnectionTcpSourceCompositeStage(Configuration configuration)	Deprecated.

Method Summary

Modifier and Type	Method	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 Details

SOURCE_PORT

public static final String SOURCE_PORT

Constructor Details

MultipleConnectionTcpSourceCompositeStage

@Deprecated
public MultipleConnectionTcpSourceCompositeStage(Configuration configuration)
                                          throws ConfigurationException

Deprecated.

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 Details

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