Modifier and Type | Method and Description |
---|---|
void |
ServiceContainer.run()
Main loop of the Kieker bridge.
|
void |
ServiceContainer.shutdown()
Safely end bridge loop.
|
Modifier and Type | Method and Description |
---|---|
protected void |
CLIServerMain.shutdown()
Hook for the shutdown thread so it can access the container's shutdown
routine.
|
Modifier and Type | Method and Description |
---|---|
void |
IServiceConnector.close()
Called to close the previously initialize record source.
|
static java.util.concurrent.ConcurrentMap<java.lang.Integer,LookupEntity> |
ServiceConnectorFactory.createLookupEntityMap(java.util.concurrent.ConcurrentMap<java.lang.Integer,java.lang.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.
|
Modifier and Type | Method and Description |
---|---|
void |
HTTPConnector.close() |
IMonitoringRecord |
HTTPConnector.deserializeNextRecord() |
void |
HTTPConnector.initialize() |
Modifier and Type | Method and Description |
---|---|
void |
JMSEmbeddedConnector.close() |
void |
JMSClientConnector.close()
Close the JMS connection.
|
IMonitoringRecord |
JMSClientConnector.deserializeNextRecord()
Fetch a text or binary message from the JMS queue and use the correct
deserializer for the received message.
|
void |
JMSEmbeddedConnector.initialize() |
void |
JMSClientConnector.initialize()
Initialize the JMS connection to read from a JMS queue.
|
Modifier and Type | Method and Description |
---|---|
void |
TCPMultiServerConnector.close()
Stop all service threads to handle TCP communication and empty the record queue.
|
void |
TCPSingleServerConnector.close()
Close the server connection.
|
void |
TCPClientConnector.close()
Closes the data stream and socket.
|
IMonitoringRecord |
TCPMultiServerConnector.deserializeNextRecord()
Implements the deserializeNextRecord interface.
|
IMonitoringRecord |
TCPSingleServerConnector.deserializeNextRecord()
De-serialize an object reading from the input stream.
|
IMonitoringRecord |
TCPClientConnector.deserializeNextRecord()
De-serialize an object reading from the input stream.
|
void |
TCPMultiServerConnector.initialize()
Initializes internal queues and an executor pool for communication.
|
void |
TCPSingleServerConnector.initialize()
Initializes a server socket and data stream for a single connection.
|
void |
TCPClientConnector.initialize()
Create the connection to a remote service providing records.
|
Copyright 2017 Kieker Project, http://kieker-monitoring.net