To use the queue data source connector with a JMS queue server, you must install the message queue client and set
the library path in an environment variable on your Streams server. This procedure is not necessary if you use an AMQP queue server.
Procedure
-
Obtain the client for your message queue server.
-
Install the message queue client one every machine where HCL®
InfoSphere Streams is installed.
See the documentation for your queue server for full instructions on installing the client.
-
On all machines where Streams is running, edit the Streams .bashrc file
for the streamsadmin user as follows.
The .bashrc file is typically located in home directory for streamsadmin
user.
-
Set the
JAVA_HOME
environment variable to use Streams Packaged Java. For
example:
export JAVA_HOME=/home/streamsadmin/InfoSphereStreams/java
-
Set additional environment variables, as follows.
- WebSphere MQ
Set the STREAMS_MESSAGING_WMQ_HOME
environment variable to the
path where you installed the client library. For example:
export STREAMS_MESSAGING_WMQ_HOME="/opt/mqm"
- ActiveMQ
Set the STREAMS_MESSAGING_AMQ_HOME
environment variable to the
location where Apache ActiveMQ is installed. For example:
export STREAMS_MESSAGING_AMQ_HOME="/home/streamsuser/ApacheActiveMQ"
-
Restart the Streams instance.