You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by hu...@apache.org on 2022/03/29 04:32:05 UTC
[rocketmq-mqtt] 37/43: [ISSUE #29] Remove redundant code in NotifyManager.java
This is an automated email from the ASF dual-hosted git repository.
huzongtang pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-mqtt.git
commit 80ad771242a9f675d909b666b5cee7b32c03cdaa
Author: 赵福建 <25...@qq.com>
AuthorDate: Wed Mar 16 17:56:56 2022 +0800
[ISSUE #29] Remove redundant code in NotifyManager.java
[ISSUE #29] Remove redundant code in NotifyManager.java
---
.../src/main/java/org/apache/rocketmq/mqtt/ds/notify/NotifyManager.java | 1 -
1 file changed, 1 deletion(-)
diff --git a/mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/notify/NotifyManager.java b/mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/notify/NotifyManager.java
index 69d7991..2ad887f 100644
--- a/mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/notify/NotifyManager.java
+++ b/mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/notify/NotifyManager.java
@@ -94,7 +94,6 @@ public class NotifyManager {
defaultMQPushConsumer.setConsumeThreadMax(64);
defaultMQProducer = MqFactory.buildDefaultMQProducer(MixAll.CID_RMQ_SYS_PREFIX + "NotifyRetrySend", serviceConf.getProperties());
- defaultMQProducer.start();
try {
defaultMQPushConsumer.start();