You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by du...@apache.org on 2021/04/14 05:48:33 UTC
[rocketmq] branch develop updated: [ISSUE #2801]Fix NamesrvAddr
connot set in Producer
This is an automated email from the ASF dual-hosted git repository.
duhengforever pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new 0ff882b [ISSUE #2801]Fix NamesrvAddr connot set in Producer
new 0f860e5 Merge pull request #2802 from zhangjidi2016/develop
0ff882b is described below
commit 0ff882bd4d1d0054ce9d261abef21fa6da3bcfe5
Author: zhangjidi2016 <zh...@cmss.chinamobile.com>
AuthorDate: Wed Apr 14 11:16:25 2021 +0800
[ISSUE #2801]Fix NamesrvAddr connot set in Producer
---
.../main/java/org/apache/rocketmq/example/ordermessage/Producer.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/example/src/main/java/org/apache/rocketmq/example/ordermessage/Producer.java b/example/src/main/java/org/apache/rocketmq/example/ordermessage/Producer.java
index 6a6bdc7..ba8ef4d 100644
--- a/example/src/main/java/org/apache/rocketmq/example/ordermessage/Producer.java
+++ b/example/src/main/java/org/apache/rocketmq/example/ordermessage/Producer.java
@@ -32,7 +32,7 @@ import org.apache.rocketmq.remoting.exception.RemotingException;
public class Producer {
public static void main(String[] args) throws UnsupportedEncodingException {
try {
- MQProducer producer = new DefaultMQProducer("please_rename_unique_group_name");
+ DefaultMQProducer producer = new DefaultMQProducer("please_rename_unique_group_name");
producer.start();
String[] tags = new String[] {"TagA", "TagB", "TagC", "TagD", "TagE"};