Examples
Specialized toolkits - release 4.3.1.0-prod20190605 > com.ibm.streamsx.messaging 5.4.1 > com.ibm.streamsx.messaging.jms > JMSSource > Examples
This example shows the use of multiple JMSSource operators with different parameter combinations.
composite Main {
graph
// JMSSource operator with the default etc/connections.xml(relative to the application directory)
// connections document
stream <int32 id, rstring fname, rstring lname>
MyPersonNamesStream = JMSSource()
{
param
connection : "amqConn";
access : "amqAccess";
}
// JMSSource operator with fully qualified name of connections.xml
stream <int32 id, rstring fname, rstring lname>
MyPersonNamesStream = JMSSource()
{
param
connectionDocument :"/home/streamsuser/connections/JMSconnections.xml";
connection : "amqConn";
access : "amqAccess";
}
// JMSSource operator with optional output error port specified
(stream <int32 id, rstring fname, rstring lname> MyPersonNamesStream ;
stream <rstring errorMessage> ErrorStream) = JMSSource()
{
param
connection : "amqConn";
access : "amqAccess";
}
// JMSSource operator with optional initDelay and reconnectionPolicy specified
stream <int32 id, rstring fname, rstring lname>
MyPersonNamesStream = JMSSource()
{
param
connection : "amqConn";
access : "amqAccess";
reconnectionPolicy : "NoRetry";
initDelay : 10;
}
// JMSSource Operator with optional period and reconnectionPolicy specified
stream <int32 id, rstring fname, rstring lname>
MyPersonNamesStream = JMSSource()
{
param
connection : "amqConn";
access : "amqAccess";
reconnectionPolicy : "InfiniteRetry";
period : 1.20;
}
// JMSSource operator with reconnectionPolicy specified as BoundedRetry
stream <int32 id, rstring fname, rstring lname>
MyPersonNamesStream = JMSSource()
{
param
connection : "amqConn";
access : "amqAccess";
reconnectionPolicy : "BoundedRetry";
reconnectionBound : 2;
period: 1.20;
}
}