public class MultipleConnectionTcpSourceCompositeStage extends teetime.framework.CompositeStage implements ISourceCompositeStage
MultipleConnectionTcpSourceStage
via a configuration object.
Configuration parameters are:
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
SOURCE_PORT |
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
.
|
Modifier and Type | Method and Description |
---|---|
teetime.framework.OutputPort<IMonitoringRecord> |
getOutputPort()
get the output port of a source composite stage.
|
public MultipleConnectionTcpSourceCompositeStage(Configuration configuration) throws ConfigurationException
configuration
- configuration parametersConfigurationException
- on configuration errors during instantiationpublic MultipleConnectionTcpSourceCompositeStage(int inputPort, int capacity, ITraceMetadataRewriter rewriter)
inputPort
- the input port to listen tocapacity
- internal ready buffer size, the buffer size must be at least as big as the largest incoming eventrewriter
- trace record metadata rewriter, (necessary when multiple sources send traces).public teetime.framework.OutputPort<IMonitoringRecord> getOutputPort()
ISourceCompositeStage
getOutputPort
in interface ISourceCompositeStage
Copyright 2021 Kieker Project, http://kieker-monitoring.net