diff --git a/README.md b/README.md index 85289af..479572b 100644 --- a/README.md +++ b/README.md @@ -2,6 +2,19 @@ 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](https://github.com/IBMStreams/streamsx.jms) | +| Kafka | [streamsx.kafka](https://github.com/IBMStreams/streamsx.kafka) | +| MQTT | [streamsx.mqtt](https://github.com/IBMStreams/streamsx.mqtt) | +| RabbitMQ | [streamsx.rabbitmq](https://github.com/IBMStreams/streamsx.rabbitmq) | +| XMS | no toolkit planned yet | + +--- + Messaging Toolkit v5.1 is offically released to support InfoSphere Streams v4.2: * https://github.com/IBMStreams/streamsx.messaging/releases @@ -29,12 +42,3 @@ To learn more about Streams: * [Introduction to Streams Quick Start Edition](http://ibmstreams.github.io/streamsx.documentation/docs/4.1/qse-intro/) * [Streams Getting Started Guide](http://ibmstreams.github.io/streamsx.documentation/docs/4.1/qse-getting-started/) * [StreamsDev](https://developer.ibm.com/streamsdev/) - - -**Deprecations** - -The support for RabbitMQ, Kafka, and MQTT in this toolkit is deprecated. For these types of messaging systems, use one of the following specialized open source toolkits: - -* [streamsx.kafka](https://github.com/IBMStreams/streamsx.kafka) -* [streamsx.rabbitmq](https://github.com/IBMStreams/streamsx.rabbitmq) -* [streamsx.mqtt](https://github.com/IBMStreams/streamsx.mqtt) \ No newline at end of file diff --git a/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.jms/JMSSink/JMSSink.xml b/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.jms/JMSSink/JMSSink.xml index fc13424..1b1d83f 100644 --- a/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.jms/JMSSink/JMSSink.xml +++ b/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.jms/JMSSink/JMSSink.xml @@ -9,6 +9,11 @@ +**DEPRECATED**: The `com.ibm.streamsx.messaging.jms.JMSSink` operator is deprecated +and is replaced by the `com.ibm.streamsx.jms.JMSSink` operator in the `com.ibm.streamsx.jms` toolkit. +The deprecated operator might be removed in a future release. + + The `JMSSink` operator creates messages from InfoSphere Streams tuples and writes the messages to a WebSphere MQ or an Apache Active MQ queue or topic. @@ -183,8 +188,8 @@ The following example shows a sample connections.xml file: </access_specifications> </st:connections> - JMSSink_16.gif - JMSSink_32.gif + JMSSink_deprecated_16.gif + JMSSink_deprecated_32.gif nTruncatedInserts diff --git a/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.jms/JMSSink/JMSSink_deprecated_16.gif b/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.jms/JMSSink/JMSSink_deprecated_16.gif new file mode 100644 index 0000000..2a18057 Binary files /dev/null and b/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.jms/JMSSink/JMSSink_deprecated_16.gif differ diff --git a/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.jms/JMSSink/JMSSink_deprecated_32.gif b/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.jms/JMSSink/JMSSink_deprecated_32.gif new file mode 100644 index 0000000..853530c Binary files /dev/null and b/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.jms/JMSSink/JMSSink_deprecated_32.gif differ diff --git a/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.jms/JMSSource/JMSSource.xml b/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.jms/JMSSource/JMSSource.xml index 25e4284..9bb2a96 100644 --- a/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.jms/JMSSource/JMSSource.xml +++ b/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.jms/JMSSource/JMSSource.xml @@ -13,6 +13,10 @@ +**DEPRECATED**: The `com.ibm.streamsx.messaging.jms.JMSSource` operator is deprecated +and is replaced by the `com.ibm.streamsx.jms.JMSSource` operator in the `com.ibm.streamsx.jms` toolkit. +The deprecated operator might be removed in a future release. + The `JMSSource` operator reads data from a WebSphere MQ or an Apache Active MQ queue or a topic and creates tuples from the read data. @@ -188,8 +192,8 @@ This example shows the use of multiple `JMSSource` operators with different para } } - JMSSource_16.gif - JMSSource_32.gif + JMSSource_deprecated_16.gif + JMSSource_deprecated_32.gif nMessagesRead diff --git a/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.jms/JMSSource/JMSSource_deprecated_16.gif b/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.jms/JMSSource/JMSSource_deprecated_16.gif new file mode 100644 index 0000000..5c719b5 Binary files /dev/null and b/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.jms/JMSSource/JMSSource_deprecated_16.gif differ diff --git a/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.jms/JMSSource/JMSSource_deprecated_32.gif b/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.jms/JMSSource/JMSSource_deprecated_32.gif new file mode 100644 index 0000000..7c2ba2b Binary files /dev/null and b/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.jms/JMSSource/JMSSource_deprecated_32.gif differ diff --git a/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.xms/XMSSink/XMSSink.xml b/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.xms/XMSSink/XMSSink.xml index c972ba7..53175be 100644 --- a/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.xms/XMSSink/XMSSink.xml +++ b/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.xms/XMSSink/XMSSink.xml @@ -7,6 +7,10 @@ others. All Rights Reserved. +**DEPRECATED**: The `com.ibm.streamsx.messaging.xms.XMSSink` operator is deprecated. There is no toolkit +providing a replacement operator. The deprecated operator might be removed in a future release. + + The `XMSSink` operator takes messages from IBM InfoSphere Streams and can send them to a WebSphere MQ queue or topic. The incoming tuple from InfoSphere Streams can be one or many of the following data types: @@ -160,8 +164,8 @@ The following is a sample `connections.xml` file: </access_specifications> </st:connections> - XMSSink_16.gif - XMSSink_32.gif + XMSSink_deprecated_16.gif + XMSSink_deprecated_32.gif nTruncatedInserts diff --git a/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.xms/XMSSink/XMSSink_cpp.cgt b/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.xms/XMSSink/XMSSink_cpp.cgt index d4dbfcd..fdfb250 100644 --- a/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.xms/XMSSink/XMSSink_cpp.cgt +++ b/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.xms/XMSSink/XMSSink_cpp.cgt @@ -145,6 +145,7 @@ if($crContext && $crContext->isStartOfRegion()) { // Constructor MY_OPERATOR::MY_OPERATOR() : nTruncatedInserts(0),nTruncatedInsertsPC( getContext().getMetrics().getCustomMetricByName("nTruncatedInserts")),nFailedInserts(0),nFailedInsertsPC( getContext().getMetrics().getCustomMetricByName("nFailedInserts")),nConnectionAttempts(0),nConnectionAttemptsPC( getContext().getMetrics().getCustomMetricByName("nConnectionAttempts")) { + SPLAPPTRC(L_ERROR, "The `com.ibm.streamsx.messaging.xms.XMSSink` operator is deprecated. There is no toolkit providing a replacement operator. The deprecated operator might be removed in a future release.", "XMSSink"); SPLAPPTRC(L_DEBUG, "Entry: Constructor", "XMSSink"); <%if ($isInConsistentRegion) {%> diff --git a/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.xms/XMSSink/XMSSink_deprecated_16.gif b/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.xms/XMSSink/XMSSink_deprecated_16.gif new file mode 100644 index 0000000..42e80f5 Binary files /dev/null and b/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.xms/XMSSink/XMSSink_deprecated_16.gif differ diff --git a/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.xms/XMSSink/XMSSink_deprecated_32.gif b/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.xms/XMSSink/XMSSink_deprecated_32.gif new file mode 100644 index 0000000..82a17ff Binary files /dev/null and b/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.xms/XMSSink/XMSSink_deprecated_32.gif differ diff --git a/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.xms/XMSSource/XMSSource.xml b/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.xms/XMSSource/XMSSource.xml index f2f35be..382b08c 100644 --- a/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.xms/XMSSource/XMSSource.xml +++ b/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.xms/XMSSource/XMSSource.xml @@ -7,6 +7,10 @@ others. All Rights Reserved. +**DEPRECATED**: The `com.ibm.streamsx.messaging.xms.XMSSource` operator is deprecated. There is no toolkit +providing a replacement operator. The deprecated operator might be removed in a future release. + + The `XMSSource` operator reads data from a WebSphere MQ queue or topic and creates tuples out of it. Each input WebSphere MQ message is converted to a separate tuple and sent to the output stream. @@ -142,8 +146,8 @@ This example demonstrates the use of multiple `XMSSource` operators with differe This example uses the same `connections.xml` that is provided in the example for the `XMSSink` operator. - XMSSource_16.gif - XMSSource_32.gif + XMSSource_deprecated_16.gif + XMSSource_deprecated_32.gif nMessagesRead diff --git a/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.xms/XMSSource/XMSSource_cpp.cgt b/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.xms/XMSSource/XMSSource_cpp.cgt index 03ef6b0..18399ce 100644 --- a/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.xms/XMSSource/XMSSource_cpp.cgt +++ b/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.xms/XMSSource/XMSSource_cpp.cgt @@ -160,7 +160,7 @@ using namespace streams_boost; // Constructor MY_OPERATOR::MY_OPERATOR(): nMessagesReadPC( getContext().getMetrics().getCustomMetricByName("nMessagesRead")),nMessagesDroppedPC( getContext().getMetrics().getCustomMetricByName("nMessagesDropped")),nConnectionAttemptsPC( getContext().getMetrics().getCustomMetricByName("nConnectionAttempts")) { - + SPLAPPTRC(L_ERROR, "The `com.ibm.streamsx.messaging.xms.XMSSource` operator is deprecated. There is no toolkit providing a replacement operator. The deprecated operator might be removed in a future release.", "XMSSink"); SPLAPPTRC(L_DEBUG, "Entry: Constructor", "XMSSource"); periodVal=0.0; diff --git a/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.xms/XMSSource/XMSSource_deprecated_16.gif b/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.xms/XMSSource/XMSSource_deprecated_16.gif new file mode 100644 index 0000000..f8e1470 Binary files /dev/null and b/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.xms/XMSSource/XMSSource_deprecated_16.gif differ diff --git a/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.xms/XMSSource/XMSSource_deprecated_32.gif b/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.xms/XMSSource/XMSSource_deprecated_32.gif new file mode 100644 index 0000000..ce9aaf0 Binary files /dev/null and b/com.ibm.streamsx.messaging/com.ibm.streamsx.messaging.xms/XMSSource/XMSSource_deprecated_32.gif differ diff --git a/com.ibm.streamsx.messaging/impl/java/src/com/ibm/streamsx/messaging/jms/JMSSink.java b/com.ibm.streamsx.messaging/impl/java/src/com/ibm/streamsx/messaging/jms/JMSSink.java index 12749c0..e44848d 100644 --- a/com.ibm.streamsx.messaging/impl/java/src/com/ibm/streamsx/messaging/jms/JMSSink.java +++ b/com.ibm.streamsx.messaging/impl/java/src/com/ibm/streamsx/messaging/jms/JMSSink.java @@ -41,6 +41,7 @@ import com.ibm.streamsx.messaging.common.DataGovernanceUtil; import com.ibm.streamsx.messaging.common.IGovernanceConstants; import com.ibm.streamsx.messaging.common.PropertyProvider; +import com.ibm.streamsx.messaging.rabbitmq.RabbitMQSink; //The JMSSink operator publishes data from Streams to a JMS Provider queue or a topic. @@ -571,6 +572,8 @@ public synchronized void initialize(OperatorContext context) IOException, ParseConnectionDocumentException, SAXException, NamingException, ConnectionException, Exception { + tracer.log(TraceLevel.ERROR, "The `com.ibm.streamsx.messaging.jms.JMSSink` operator is deprecated and is replaced by the `com.ibm.streamsx.jms.JMSSink` operator in the `com.ibm.streamsx.jms` toolkit. The deprecated operator might be removed in a future release."); //$NON-NLS-1$ + tracer.log(TraceLevel.TRACE, "Begin initialize()"); //$NON-NLS-1$ tracer.log(TraceLevel.TRACE, "Calling super class initialization"); //$NON-NLS-1$ diff --git a/com.ibm.streamsx.messaging/impl/java/src/com/ibm/streamsx/messaging/jms/JMSSource.java b/com.ibm.streamsx.messaging/impl/java/src/com/ibm/streamsx/messaging/jms/JMSSource.java index c965395..33981e5 100644 --- a/com.ibm.streamsx.messaging/impl/java/src/com/ibm/streamsx/messaging/jms/JMSSource.java +++ b/com.ibm.streamsx.messaging/impl/java/src/com/ibm/streamsx/messaging/jms/JMSSource.java @@ -727,6 +727,8 @@ public synchronized void initialize(OperatorContext context) throws ParserConfigurationException, InterruptedException, IOException, ParseConnectionDocumentException, SAXException, NamingException, ConnectionException, Exception { + + tracer.log(TraceLevel.ERROR, "The `com.ibm.streamsx.messaging.jms.JMSSource` operator is deprecated and is replaced by the `com.ibm.streamsx.jms.JMSSource` operator in the `com.ibm.streamsx.jms` toolkit. The deprecated operator might be removed in a future release."); //$NON-NLS-1$ tracer.log(TraceLevel.TRACE, "Begin initialize()"); //$NON-NLS-1$ diff --git a/com.ibm.streamsx.messaging/info.xml b/com.ibm.streamsx.messaging/info.xml index 8cbe82e..08f18e9 100644 --- a/com.ibm.streamsx.messaging/info.xml +++ b/com.ibm.streamsx.messaging/info.xml @@ -684,7 +684,7 @@ The <attribute> element has three possible attributes: * composite types * xml - 5.4.2 + 5.4.3 4.2.0.0 diff --git a/com.ibm.streamsx.messaging/pom.xml b/com.ibm.streamsx.messaging/pom.xml index b61f127..b3514a4 100644 --- a/com.ibm.streamsx.messaging/pom.xml +++ b/com.ibm.streamsx.messaging/pom.xml @@ -6,7 +6,7 @@ com.ibm.streamsx.messaging streamsx.messaging jar - 5.4.2 + 5.4.3 com.ibm.streamsx.messaging