public class JMSEmbeddedConnector extends JMSClientConnector
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
PORT
Property name for the configuration property for the port of the embedded JMS server.
|
FACTORY_LOOKUP_NAME, KIEKER_DATA_BRIDGE_READ_QUEUE, password, PASSWORD, URI, username, USERNAME
configuration, lookupEntityMap
Constructor and Description |
---|
JMSEmbeddedConnector(Configuration configuration,
java.util.concurrent.ConcurrentMap<java.lang.Integer,LookupEntity> lookupEntityMap)
Construct a new JMS service consumer and an embedded JMS service.
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Close the JMS connection.
|
void |
initialize()
Initialize the JMS connection to read from a JMS queue.
|
deserializeNextRecord
public static final java.lang.String PORT
public JMSEmbeddedConnector(Configuration configuration, java.util.concurrent.ConcurrentMap<java.lang.Integer,LookupEntity> lookupEntityMap)
configuration
- Kieker configuration including setup for connectorslookupEntityMap
- IMonitoringRecord constructor and TYPES-array to id mapConnectorDataTransmissionException
public void initialize() throws ConnectorDataTransmissionException
JMSClientConnector
initialize
in interface IServiceConnector
initialize
in class JMSClientConnector
ConnectorDataTransmissionException
- if any JMSException occurspublic void close() throws ConnectorDataTransmissionException
JMSClientConnector
close
in interface IServiceConnector
close
in class JMSClientConnector
ConnectorDataTransmissionException
- if any JMSException occursCopyright 2017 Kieker Project, http://kieker-monitoring.net