study/Spring-Cloud-Alibaba
1
0
Fork 0
mirror of https://gitee.com/mirrors/Spring-Cloud-Alibaba.git synced 2021-06-26 13:25:11 +08:00
Code Issues Releases Wiki Activity

Change exception msg.

Browse Source
This commit is contained in:
wangxing 2019-08-13 14:25:41 +08:00
parent 7073be1186
commit 3ad57fb7bf
1 changed files with 2 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
spring-cloud-stream-binder-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/RocketMQMessageChannelBinder.java
View File

@ -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 @Override
protected MessageHandler createProducerMessageHandler(ProducerDestination destination, protected MessageHandler createProducerMessageHandler(ProducerDestination destination,
ExtendedProducerProperties<RocketMQProducerProperties> producerProperties, ExtendedProducerProperties<RocketMQProducerProperties> producerProperties,
MessageChannel errorChannel) throws Exception { MessageChannel errorChannel) throws Exception {
throw new UnsupportedOperationException(); throw new UnsupportedOperationException(
"The abstract binder should not call this method");
} }
@Override @Override