[servicecomb-pack] 04/05: support rabbitmq

[ni...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

ningjiang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/servicecomb-pack.git

commit de1d746c32c2e5af23c6f8153e3dd87864e24d35
Author: ychen <ye...@freemud.com>
AuthorDate: Thu Mar 18 10:58:07 2021 +0800

    support rabbitmq
---
 .../pack/alpha/fsm/channel/rabbit/RabbitMessagePublisher.java           | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/rabbit/RabbitMessagePublisher.java b/alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/rabbit/RabbitMessagePublisher.java
index 05fc775..a441749 100644
--- a/alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/rabbit/RabbitMessagePublisher.java
+++ b/alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/rabbit/RabbitMessagePublisher.java
@@ -48,7 +48,7 @@ public class RabbitMessagePublisher implements MessagePublisher<BaseEvent> {
         if (LOG.isDebugEnabled()) {
             LOG.debug("send message [{}] to [{}]", data, partitionIndex);
         }
-        //partitionKey 分区的名称必须与配置中的key保持一致
+        // the headerName must consistent with partition key expression of spring cloud stream
         producerMessage.messageChannel().send(MessageBuilder.withPayload(data).setHeader("partitionKey", partitionIndex).build());
 
     }