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