From 3ad57fb7bfcf5d94c9093056960875e647f1669b Mon Sep 17 00:00:00 2001 From: wangxing <1271029739@qq.com> Date: Tue, 13 Aug 2019 14:25:41 +0800 Subject: [PATCH] Change exception msg. --- .../rocketmq/RocketMQMessageChannelBinder.java | 13 ++----------- 1 file changed, 2 insertions(+), 11 deletions(-) diff --git a/spring-cloud-stream-binder-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/RocketMQMessageChannelBinder.java b/spring-cloud-stream-binder-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/RocketMQMessageChannelBinder.java index 62e54fc0..bc35de93 100644 --- a/spring-cloud-stream-binder-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/RocketMQMessageChannelBinder.java +++ b/spring-cloud-stream-binder-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/RocketMQMessageChannelBinder.java @@ -181,21 +181,12 @@ public class RocketMQMessageChannelBinder extends } } - /** - * The abstract binder should not call this method. - * @param destination - * @param producerProperties - * @param errorChannel - * @return - * @throws Exception - * @see RocketMQMessageChannelBinder#createProducerMessageHandler(ProducerDestination, - * ExtendedProducerProperties, MessageChannel, MessageChannel) - */ @Override protected MessageHandler createProducerMessageHandler(ProducerDestination destination, ExtendedProducerProperties producerProperties, MessageChannel errorChannel) throws Exception { - throw new UnsupportedOperationException(); + throw new UnsupportedOperationException( + "The abstract binder should not call this method"); } @Override