From 7073be1186193b69c772a68b42f60ee07ae09622 Mon Sep 17 00:00:00 2001
From: wangxing <1271029739@qq.com>
Date: Tue, 13 Aug 2019 13:45:08 +0800
Subject: [PATCH] Optimize documents and logs.

---
 .../binder/rocketmq/RocketMQMessageChannelBinder.java  | 10 ++++++++++
 .../rocketmq/integration/RocketMQMessageHandler.java   |  4 ++--
 2 files changed, 12 insertions(+), 2 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 25712e420..62e54fc0c 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,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,
diff --git a/spring-cloud-stream-binder-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/integration/RocketMQMessageHandler.java b/spring-cloud-stream-binder-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/integration/RocketMQMessageHandler.java
index 376e7f615..9186b064c 100644
--- a/spring-cloud-stream-binder-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/integration/RocketMQMessageHandler.java
+++ b/spring-cloud-stream-binder-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/integration/RocketMQMessageHandler.java
@@ -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