Developing and running applications that use the MQTT Toolkit
To create applications that use the MQTT Toolkit, you must configure the SPL compiler to be aware of the location of the toolkit.
Before you begin
- Configure the product environment variables by entering the following command:
<source product-installation-root-directory>/7.2.0.0/bin/streamsprofile.sh
About this task
After the location of the toolkit is communicated to the compiler, the SPL artifacts that are specified in the toolkit can be used by an application. The application can include a use directive to bring the necessary namespaces into scope. Alternatively, you can fully qualify the operators that are provided by toolkit with their namespaces as prefixes.
Procedure
- Review the list of restrictions for the Streams specialized toolkits in the product documentation.
- Develop your application. To avoid the need to fully qualify the operators, add a use directive in your application.
- For example, you can add the following clause in your SPL source file:
You can also specify a use clause for individual operators by replacing the asterisk (*) with the operator name. For example:use com.teracloud.streams.mqtt::*;
use com.teracloud.streams.mqtt::MQTTSink;
- For example, you can add the following clause in your SPL source file:
- Configure the SPL compiler to find the toolkit root directory. Use one of the following methods:
- Set the STREAMS_SPLPATH environment variable to the root directory of a toolkit or multiple toolkits (with : as a separator). For example:
export STREAMS_SPLPATH=$STREAMS_INSTALL/toolkits/com.teracloud.streams.mqtt
- Specify the -t or --spl-path command parameter when you run the sc command. For example:
where MyMain is the name of the SPL main composite.sc -t $STREAMS_INSTALL/toolkits/com.teracloud.streams.mqtt -M MyMain
Note: These command parameters override the STREAMS_SPLPATH environment variable.
- Set the STREAMS_SPLPATH environment variable to the root directory of a toolkit or multiple toolkits (with : as a separator). For example:
- Build your application using the sc command.
- Run the application.
- You can launch the application in stand-alone mode using the standalone program located in the output directory.
- You can submit the application in a distributed environment, as a job, to a running Streams instance using the streamtool submitjob command or Streams Console.