| Package | Description |
|---|---|
| kieker.tools.bridge.connector | |
| kieker.tools.bridge.connector.http | |
| kieker.tools.bridge.connector.jms | |
| kieker.tools.bridge.connector.tcp |
| Modifier and Type | Field and Description |
|---|---|
protected java.util.concurrent.ConcurrentMap<java.lang.Integer,LookupEntity> |
AbstractConnector.lookupEntityMap
Map containing record ids and the assigned constructor and field type list.
|
| Modifier and Type | Method and Description |
|---|---|
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.
|
| Constructor and Description |
|---|
AbstractConnector(Configuration configuration,
java.util.concurrent.ConcurrentMap<java.lang.Integer,LookupEntity> lookupEntityMap)
AbstractTCPService constructor.
|
| Constructor and Description |
|---|
HTTPConnector(Configuration configuration,
java.util.concurrent.ConcurrentMap<java.lang.Integer,LookupEntity> lookupEntityMap) |
| Constructor and Description |
|---|
JMSClientConnector(Configuration configuration,
java.util.concurrent.ConcurrentMap<java.lang.Integer,LookupEntity> lookupEntityMap)
Create a JMSClientConnector.
|
JMSEmbeddedConnector(Configuration configuration,
java.util.concurrent.ConcurrentMap<java.lang.Integer,LookupEntity> lookupEntityMap)
Construct a new JMS service consumer and an embedded JMS service.
|
| Constructor and Description |
|---|
TCPClientConnector(Configuration configuration,
java.util.concurrent.ConcurrentMap<java.lang.Integer,LookupEntity> lookupEntityMap)
Create a TCPClientConnector.
|
TCPMultiServerConnectionRunnable(java.net.Socket socket,
java.util.concurrent.ConcurrentMap<java.lang.Integer,LookupEntity> lookupEntityMap,
java.util.concurrent.BlockingQueue<IMonitoringRecord> recordQueue)
Create a service thread.
|
TCPMultiServerConnector(Configuration configuration,
java.util.concurrent.ConcurrentMap<java.lang.Integer,LookupEntity> lookupEntityMap)
Create a TCPMultiServerConnector.
|
TCPMultiServerPortListenerRunnable(int port,
java.util.concurrent.BlockingQueue<IMonitoringRecord> recordQueue,
java.util.concurrent.ConcurrentMap<java.lang.Integer,LookupEntity> lookupEntityMap,
java.util.concurrent.ExecutorService executor)
Create a listener for the incoming port of the multi server.
|
TCPSingleServerConnector(Configuration configuration,
java.util.concurrent.ConcurrentMap<java.lang.Integer,LookupEntity> lookupEntityMap)
Create a TCPSingleServerConnector.
|
Copyright 2017 Kieker Project, http://kieker-monitoring.net