kieker.tools.bridge.connector.jms

Class JMSEmbeddedConnector

java.lang.Object

kieker.tools.bridge.connector.AbstractConnector

kieker.tools.bridge.connector.jms.JMSClientConnector

kieker.tools.bridge.connector.jms.JMSEmbeddedConnector

All Implemented Interfaces:

IServiceConnector

public class JMSEmbeddedConnector
extends JMSClientConnector

JMSClient with an embedded JMS server.

Since:

1.8

Author:

Reiner Jung

Field Summary

Fields

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.

Fields inherited from class kieker.tools.bridge.connector.jms.JMSClientConnector

FACTORY_LOOKUP_NAME, KIEKER_DATA_BRIDGE_READ_QUEUE, password, PASSWORD, URI, username, USERNAME

Fields inherited from class kieker.tools.bridge.connector.AbstractConnector

configuration, lookupEntityMap

Constructor Summary

Constructors

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.

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Close the JMS connection.
void	initialize() Initialize the JMS connection to read from a JMS queue.

Methods inherited from class kieker.tools.bridge.connector.jms.JMSClientConnector

deserializeNextRecord

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

PORT

public static final java.lang.String PORT

Property name for the configuration property for the port of the embedded JMS server.

Constructor Detail

JMSEmbeddedConnector

public JMSEmbeddedConnector(Configuration configuration,
                    java.util.concurrent.ConcurrentMap<java.lang.Integer,LookupEntity> lookupEntityMap)

Construct a new JMS service consumer and an embedded JMS service.

Parameters:

configuration - Kieker configuration including setup for connectors

lookupEntityMap - IMonitoringRecord constructor and TYPES-array to id map

Throws:

ConnectorDataTransmissionException

Method Detail

initialize

public void initialize()
                throws ConnectorDataTransmissionException

Description copied from class: JMSClientConnector

Initialize the JMS connection to read from a JMS queue.

Specified by:

initialize in interface IServiceConnector

Overrides:

initialize in class JMSClientConnector

Throws:

ConnectorDataTransmissionException - if any JMSException occurs

close

public void close()
           throws ConnectorDataTransmissionException

Description copied from class: JMSClientConnector

Close the JMS connection.

Specified by:

close in interface IServiceConnector

Overrides:

close in class JMSClientConnector

Throws:

ConnectorDataTransmissionException - if any JMSException occurs