The IBMStreams/streamsx.messaging toolkit project is an open source Streams toolkit project focused on the development of operators and functions that extend IBM InfoSphere Streams ability to interact with messaging systems.
After release v5.4.2 the complete toolkit is deprecated. Please, use the following alternatives to communicate with various message queues:
| Message Queue | New Toolkit |
|---|---|
| JMS | streamsx.jms |
| Kafka | streamsx.kafka |
| MQTT | streamsx.mqtt |
| RabbitMQ | streamsx.rabbitmq |
| XMS | no toolkit planned yet |
Messaging Toolkit v5.1 is offically released to support InfoSphere Streams v4.2:
This toolkit contains support for:
- Kafka
- RabbitMQ
- JMS
- MQTT
- XMS
Check out our SPLDOC here:
- http://ibmstreams.github.io/streamsx.messaging/com.ibm.streamsx.messaging/doc/spldoc/html/index.html
To get started with working with this toolkit:
- https://github.com/IBMStreams/streamsx.messaging/wiki/Getting-Started-with-Toolkit-Development
- Kafka Operators Getting Started Guide
- JMS Operators Getting Started Guide
- The messages and the NLS for toolkits
To learn more about Streams: