Qpid JMS output event adapter can be used to publish events having map, XML, JSON, and text formats via jms transport.
...
Install Qpid JMS Broker and Qpid JMS Client.
- Add the following Qpid JMS-specific JAR files to
<PRODUCT_HOME>/repository/components/lib/directory.<ACTIVEMQ_HOME>/lib/geronimo-jms_1.1_spec-1.0.jar<QPID-CLIENT_HOME>/lib/qpid-client-xxx.jar<QPID-CLIENT_HOME>/lib/qpid-common-xxx.jar
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 Qpid 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/default?brokerlist='tcp://localhost:5672'topic.topicMap = topicMaptopic.topicJSON = topicJSONStart Qpid Broker , and then start the product.
...
Adapter Property | Possible Values | Default | Description |
|---|---|---|---|
| JNDI Initial Context Factory Class | org.apache.qpid.jndi.PropertiesFileInitialContextFactory | JNDI initial context factory class. The class must implement the java.naming.spi.InitialContextFactory interface. | |
| JNDI Provider URL | repository/conf/jndi.properties | 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 Name | TopicConnectionFactory | The JNDI name of the connection factory. | |
| Destination Type | topic/queue | topic | Define the sort order for messages that arrive on a specific destination. |
| Destination | topicMap | CEP send messages by publishing to a topic or a queue. |
...
Adapter Property | Possible Values | Default | Description |
|---|---|---|---|
| Header | A valid header name: header value pair eg header_name1:header_value1,header_name2:header_value2 | Define Transport Headers |