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

Optimize documents and logs.

Browse Source
This commit is contained in:
wangxing 2019-08-13 13:45:08 +08:00
parent de2f3f2131
commit 7073be1186
2 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -181,6 +181,16 @@ 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<RocketMQProducerProperties> producerProperties,

4
spring-cloud-stream-binder-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/integration/RocketMQMessageHandler.java
View File

@ -117,8 +117,8 @@ public class RocketMQMessageHandler extends AbstractMessageHandler implements Li
.fetchPublishMessageQueues(destination);
if (producerProperties.getPartitionCount() != messageQueues.size()) {
logger.info(String.format(
"The partition count will change from '%s' to '%s'",
producerProperties.getPartitionCount(),
"The partition count of topic '%s' will change from '%s' to '%s'",
destination, producerProperties.getPartitionCount(),
messageQueues.size()));
producerProperties.setPartitionCount(messageQueues.size());
partitioningInterceptor