Don't Extend AbstractMessageProducingHandler.

Author: garyrussell

spring-integration-amqp/src/main/java/org/springframework/integration/amqp/outbound/RabbitStreamMessageHandler.java

@@ -27,7 +27,8 @@
 import org.springframework.integration.amqp.support.AmqpHeaderMapper;
 import org.springframework.integration.amqp.support.DefaultAmqpHeaderMapper;
 import org.springframework.integration.amqp.support.MappingUtils;
-import org.springframework.integration.handler.AbstractMessageProducingHandler;
+import org.springframework.integration.core.MessagingTemplate;
+import org.springframework.integration.handler.AbstractMessageHandler;
 import org.springframework.messaging.Message;
 import org.springframework.messaging.MessageChannel;
 import org.springframework.messaging.MessageHandler;
@@ -45,12 +46,14 @@
  * @since 6.0
  *
  */
-public class RabbitStreamMessageHandler extends AbstractMessageProducingHandler {
+public class RabbitStreamMessageHandler extends AbstractMessageHandler {
 
 	private static final int DEFAULT_CONFIRM_TIMEOUT = 10_000;
 
 	private final RabbitStreamOperations streamOperations;
 
+	private final MessagingTemplate messagingTemplate = new MessagingTemplate();
+
 	private boolean sync;
 
 	private long confirmTimeout = DEFAULT_CONFIRM_TIMEOUT;

src/reference/asciidoc/whats-new.adoc

@@ -44,6 +44,11 @@ A `PostgresSubscribableChannel` allows to receive push notifications via `Postgr
 
 See <<./jdbc.adoc#postgresql-push,PostgreSQL: Receiving Push Notifications>> for more information.
 
+[[x6.0-rmq]]
+=== RabbitMQ Stream Queue Support
+
+The AMQP module has been enhanced to provide support for inbound and outbound channel adapters using RabbitMQ Stream Queues.
+See <<./amqp.adoc#rmq-streams,RabbitMQ Stream Queue Support>> for more information.
 
 [[x6.0-general]]
 === General Changes
@@ -104,8 +109,3 @@ See <<./jdbc.adoc#jdbc-lock-registry,JDBC Lock Registry>> for more information.
 The `lookupHost` property of the `AbstractConnectionFactory` and `DatagramPacketMessageMapper` is now set to `false` by default to avoid delays in the environments where DNS is not configured.
 
 See <<./ip.adoc#ip,TCP and UDP Support>> for more information.
-
-=== RabbitMQ Changes
-
-The AMQP module has been enhanced to provide support for inbound and outbound channel adapters using RabbitMQ Stream Queues.
-See <<./amqp.adoc#rmq-streams,RabbitMQ Stream Queue Support>> for more information.