Striim 3.9.4 / 3.9.5 documentation

JMSReader

Reads data using the JMS API 1.1.

See Supported reader-parser combinations) for parsing options.

property

type

default value

notes

compressiontype

java.lang.String

Set to gzip when the input is in gzip format. Otherwise, leave blank.

ConnectionFactoryName

java.lang.String

the name of the ConnectionFactory containing the queue or topic

crashOnUnsupportedMessageType

java.lang.Boolean

True

With the default value of True, when JMSReader encounters a message of an unsupported type, the application will crash. Set to False to ignore such messages.

Ctx

java.lang.String

the JNDI initial context factory name

durableSubscriberName

java.lang.String

Leave blank to create a nondurable subscription. Specify a subscriber name to create a durable subscription.

Password

com.webaction. security.Password

see Encrypted passwords

Provider

java.lang.String

the path to the JNDI binding

QueueName

java.lang.String

leave blank if Topic is specified

Topic

java.lang.String

leave blank if QueueName is specified

UserName

java.lang.String

a messaging system user with the necessary permissions

The output type is WAevent except when using JSONParser.

The following example is for ActiveMQ:

CREATE SOURCE AMQSource USING JMSReader (
  ConnectionFactoryName:'jms/TestConnectionFactory'
  Ctx:'org.apache.activemq.jndi.ActiveMQInitialContextFactory',
  Provider:'tcp://192.168.123.200:61616',
  QueueName:'jms/TestJMSQueue',
  UserName:'striim',
  Password:'******'
) ...

Note that JMSReader's properties must accurately reflect your configuration. See Using JMSReader with IBM WebSphere MQ for a detailed discussion.