| commit | de1d746c32c2e5af23c6f8153e3dd87864e24d35 | [log] [tgz] |
|---|---|---|
| author | ychen <yeliang.cheng@freemud.com> | Thu Mar 18 10:58:07 2021 +0800 |
| committer | Willem Jiang <willem.jiang@gmail.com> | Mon Mar 29 12:53:04 2021 +0800 |
| tree | 8fcb93e907c25eb09de8d8b6a08d9f25f49a17d8 | |
| parent | 4f31045819bcce76649fc48f26128763e579a0f8 [diff] |
support rabbitmq
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 @@ 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()); }