mirror of
https://github.com/apache/rocketmq.git
synced 2026-09-24 16:04:00 +08:00
Merge pull request #2802 from zhangjidi2016/develop
[ISSUE #2801]Fix NamesrvAddr connot set in Producer
This commit is contained in:
@@ -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"};
|
||||
|
||||
Reference in New Issue
Block a user