Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

ActiveMQ JMS output event adapter can be used to publish events having map, XML, JSON, and text formats via jms transport.

...

  1. Install Apache ActiveMQ JMS

    Icon

    This guide uses ActiveMQ versions 5.7.0 or below. If you want to use a later version, for instructions on the necessary changes to the configuration steps, go to Apache ActiveMQ Documentation.

  2. Add the following ActiveMQ JMS-specific JAR files to  <PRODUCT_HOME>/repository/components/lib/ directory. 
    • <ACTIVEMQ_HOME>/lib/activemq-core-xxx.jar  
    • <ACTIVEMQ_HOME>/lib/geronimo-j2ee-management_1.1_spec-1.0.1.jar
  3. Refer the <PRODUCT_HOME>/repository/conf/jndi.properties file to register a connection factory. For example, if the connection factory JNDI name is "TopicConnectionFactory", it will point the default ActiveMQ host to localhost and port to 5672 as shown below. Furthermore, add the topics to be sent to the ActiveMQ broker in the format: topic.{topicName} = {topicName}

    connectionfactory.TopicConnectionFactory=amqp://admin:admin@clientid/test?brokerlist='tcp://localhost:5672'

    topic.topicMap = topicMap
    topic.topicText = topicText

  4. Start ActiveMQ, and then start the product.

...

Adapter Property
Possible Values
Default
Description
JNDI Initial Context Factory Classorg.apache.activemq.jndi.ActiveMQInitialContextFactory JNDI initial context factory class. The class must implement the java.naming.spi.InitialContextFactory interface.
JNDI Provider URLtcp://localhost:61616 URL of the JNDI provider.
Username

A valid username for the JMS connection

 Set a username for the JMS connection.
Password

A valid password for the JMS connection

 Set a password for the JMS connection.
Connection Factory JNDI NameTopicConnectionFactory The JNDI name of the connection factory.
Destination Type

topic/queue

topic

Define the sort order for messages that arrive on a specific destination.
DestinationtopicMap CEP send messages by publishing to a topic or a queue.

...

Adapter PropertyPossible ValuesDefaultDescription
Header

A valid header name: header value pair

eg header_name1:header_value1,header_name2:header_value2

 Define Transport Headers