kieker.tools.bridge.connector.tcp

Class TCPClientConnector

java.lang.Object

kieker.tools.bridge.connector.AbstractConnector

kieker.tools.bridge.connector.tcp.TCPClientConnector

All Implemented Interfaces:

IServiceConnector

public class TCPClientConnector
extends AbstractConnector

Connects to a remote record source.

Since:

1.8

Author:

Reiner Jung

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	HOSTNAME Property name for the host name of the record source.
static java.lang.String	PORT Property name for the port of the record source.

Fields inherited from class kieker.tools.bridge.connector.AbstractConnector

configuration, lookupEntityMap

Constructor Summary

Constructors

Constructor and Description
TCPClientConnector(Configuration configuration, java.util.concurrent.ConcurrentMap<java.lang.Integer,LookupEntity> lookupEntityMap) Create a TCPClientConnector.

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Closes the data stream and socket.
IMonitoringRecord	deserializeNextRecord() De-serialize an object reading from the input stream.
void	initialize() Create the connection to a remote service providing records.

Methods inherited from class java.lang.Object

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

Field Detail

HOSTNAME

public static final java.lang.String HOSTNAME

Property name for the host name of the record source.

PORT

public static final java.lang.String PORT

Property name for the port of the record source.

Constructor Detail

TCPClientConnector

public TCPClientConnector(Configuration configuration,
                  java.util.concurrent.ConcurrentMap<java.lang.Integer,LookupEntity> lookupEntityMap)

Create a TCPClientConnector.

Parameters:

configuration - Kieker configuration including setup for connectors

lookupEntityMap - IMonitoringRecord constructor and TYPES-array to id map

Method Detail

initialize

public void initialize()
                throws ConnectorDataTransmissionException

Create the connection to a remote service providing records.

Throws:

ConnectorDataTransmissionException - if the given host or IP cannot be found, or an IOException occurs

close

public void close()
           throws ConnectorDataTransmissionException

Closes the data stream and socket.

Throws:

ConnectorDataTransmissionException - if an IOException occurs during the close operation

deserializeNextRecord

public IMonitoringRecord deserializeNextRecord()
                                        throws ConnectorDataTransmissionException,
                                               ConnectorEndOfDataException

De-serialize an object reading from the input stream.

Returns:

the de-serialized IMonitoringRecord object or null if the stream was terminated by the client.

Throws:

ConnectorDataTransmissionException - when a record is received that ID is unknown or the deserialization fails

ConnectorEndOfDataException - when the other end hung up or the data stream ends of another reason