Uses of Class
kieker.tools.bridge.connector.ConnectorDataTransmissionException

Packages that use ConnectorDataTransmissionException

kieker.tools.bridge
kieker.tools.bridge.connector
kieker.tools.bridge.connector.jms
kieker.tools.bridge.connector.tcp

Uses of ConnectorDataTransmissionException in kieker.tools.bridge

Methods in kieker.tools.bridge that throw ConnectorDataTransmissionException

void	ServiceContainer.run() Main loop of the Kieker bridge.
void	ServiceContainer.shutdown() Safely end bridge loop.

Uses of ConnectorDataTransmissionException in kieker.tools.bridge.connector

Methods in kieker.tools.bridge.connector that throw ConnectorDataTransmissionException

void	IServiceConnector.close() Called to close the previously initialize record source.
static ConcurrentMap<Integer,LookupEntity>	ServiceConnectorFactory.createLookupEntityMap(ConcurrentMap<Integer,Class<? extends IMonitoringRecord>> recordMap) Calculates the lookup table from the record map.
IMonitoringRecord	IServiceConnector.deserializeNextRecord() The deserialize method reads source data and returns an IMonitoringRecord.
void	IServiceConnector.initialize() Called to initialize the channel to read record information.

Uses of ConnectorDataTransmissionException in kieker.tools.bridge.connector.jms

Methods in kieker.tools.bridge.connector.jms that throw ConnectorDataTransmissionException

void	JMSClientConnector.close() Close the JMS connection.
void	JMSEmbeddedConnector.close()
IMonitoringRecord	JMSClientConnector.deserializeNextRecord() Fetch a text or binary message from the JMS queue and use the correct deserializer for the received message.
void	JMSClientConnector.initialize() Initialize the JMS connection to read from a JMS queue.
void	JMSEmbeddedConnector.initialize()

Uses of ConnectorDataTransmissionException in kieker.tools.bridge.connector.tcp

Methods in kieker.tools.bridge.connector.tcp that throw ConnectorDataTransmissionException

void	TCPMultiServerConnector.close() Stop all service threads to handle TCP communication and empty the record queue.
void	TCPClientConnector.close() Closes the data stream and socket.
void	TCPSingleServerConnector.close() Close the server connection.
IMonitoringRecord	TCPMultiServerConnector.deserializeNextRecord() Implements the deserializeNextRecord interface.
IMonitoringRecord	TCPClientConnector.deserializeNextRecord() De-serialize an object reading from the input stream.
IMonitoringRecord	TCPSingleServerConnector.deserializeNextRecord() De-serialize an object reading from the input stream.
void	TCPMultiServerConnector.initialize() Initializes internal queues and an executor pool for communication.
void	TCPClientConnector.initialize() Create the connection to a remote service providing records.
void	TCPSingleServerConnector.initialize() Initializes a server socket and data stream for a single connection.