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