JMS

Available when using an authoring Data Collector version 4.0.0 or later.

To create a JMS connection, the Java Messaging Services (JMS) stage library, streamsets-datacollector-jms-lib, must be installed on the selected authoring Data Collector.

For a description of the JMS connection properties, see JMS Connection Properties.

After you create a JMS connection, you can use the connection in the following stages:


Engine	Stages
Data Collector 4.0.0 or later	JMS Consumer origin JMS Producer destination

JMS Connection Properties

When creating a JMS connection, configure the following properties on the JMS tab:


JMS Property	Description
JMS Initial Context Factory	JMS initial context factory. For example, for Apache ActiveMQ you might use: `org.apache.activemq.jndi.ActiveMQInitialContextFactory`. Or for Oracle Weblogic, you might use: `weblogic.jndi.WLInitialContextFactory`.
JNDI Connection Factory	JNDI connection factory. For example, for ActiveMQ, you might use: `ConnectionFactory`. For Weblogic, you might use: `jms/ConnectionFactory`.
JMS Provider URL	URL for the JMS provider. For example, for ActiveMQ, you might use: `tcp://localhost:<portno>`. For Weblogic, you might use: `t3/localhost:<portno>`.

Configure the following properties on the Credentials tab:


Credentials Property	Description
Use Credentials	Enables using JMS credentials.
Username	JMS user name.
Password	JMS password. Tip: To secure sensitive information, you can use credential stores or runtime resources.
Additional Security Properties	Additional JMS or JNDI security properties to use. For example, you might add the `java.naming.security.principal` and `java.naming.security.credentials` properties. To add properties, click Add and define the JMS or JNDI property name and value. When you add a property, enter the exact property name and value. The stage does not validate the property names or values. You can use credential functions to retrieve sensitive information from supported credential stores. Note: If a JMS stage defines the same property as an additional configuration property on the JMS tab, the additional security properties defined here take precedence.