kieker.tools.bridge.connector.tcp

Class TCPSingleServerConnector

java.lang.Object

kieker.tools.bridge.connector.AbstractConnector

kieker.tools.bridge.connector.tcp.TCPSingleServerConnector

All Implemented Interfaces:

IServiceConnector

public class TCPSingleServerConnector
extends AbstractConnector

TCP server connector supporting one client. All operations provided by this connector must run in the same thread.

Since:

1.8

Author:

Reiner Jung

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	PORT Constant holding the name of the port configuration property.

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

configuration, lookupEntityMap

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Close the server connection.
IMonitoringRecord	deserializeNextRecord() De-serialize an object reading from the input stream.
void	initialize() Initializes a server socket and data stream for a single connection.

Methods inherited from class java.lang.Object

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

Field Detail

PORT

public static final java.lang.String PORT

Constant holding the name of the port configuration property.

Constructor Detail

TCPSingleServerConnector

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

Create a TCPSingleServerConnector.

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

Initializes a server socket and data stream for a single connection.

Throws:

ConnectorDataTransmissionException - it the socket could not be established

close

public void close()
           throws ConnectorDataTransmissionException

Close the server connection.

Throws:

ConnectorDataTransmissionException - if the closing fails

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 - if an unknown id is received which cannot be mapped to an IMonitoringRecord

ConnectorEndOfDataException - if the end of the data stream is reached