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.