This is an automated email from the ASF dual-hosted git repository.
mxsm pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/eventmesh.git
The following commit(s) were added to refs/heads/master by this push:
new 841874530 [ISSUE 4350] Fixed eventmesh startup error under MQ plugin
(#4351)
841874530 is described below
commit 8418745305e9b5cde56821bf1ae1d2d108c83ff6
Author: Alonexc <[email protected]>
AuthorDate: Fri Aug 11 13:46:50 2023 +0800
[ISSUE 4350] Fixed eventmesh startup error under MQ plugin (#4351)
---
.../eventmesh/storage/rocketmq/producer/RocketMQProducerImpl.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/producer/RocketMQProducerImpl.java
b/eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/producer/RocketMQProducerImpl.java
index 2027a85db..f68771ca8 100644
---
a/eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/producer/RocketMQProducerImpl.java
+++
b/eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/producer/RocketMQProducerImpl.java
@@ -46,7 +46,8 @@ public class RocketMQProducerImpl implements Producer {
@Override
public synchronized void init(Properties keyValue) {
- String producerGroup = keyValue.getProperty(Constants.PRODUCER_GROUP);
+ String producerGroup = keyValue.getProperty(Constants.PRODUCER_GROUP)
+ == null ? "RMQ-producerGroup" :
keyValue.getProperty(Constants.PRODUCER_GROUP);
String omsNamesrv = clientConfiguration.getNamesrvAddr();
Properties properties = new Properties();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
