发送 异步消息时报错了

Question

org.apache.rocketmq.client.exception.MQClientException: No route info of this topic, test_quick_topic_real_oneway See http://rocketmq.apache.org/docs/faq/ for further details. at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:610) at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.access$4(DefaultMQProducerImpl.java:469) at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl$2.run(DefaultMQProducerImpl.java:443)atjava.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745) ------发送失败

Answer 1

阿神 2018-11-28 16:07:18

自己手动create一个，这个是oneway队列，在控制台新建一个消息队列即可

• 提问者 慕用8378807 #1

  Message message = new Message("test_quick_topic_Async",	 
  					"TagA", 
  					"key" + i,	 
  					("Hello RocketMQ" + i).getBytes(RemotingHelper.DEFAULT_CHARSET));	 
  
  这个消息不对吗

• 提问者 慕用8378807 #2

  怎么在控制台新建一个消息队列？？？求指导哈 谢谢

• 阿神 #3

  我有讲到鸭，就是使用console，create一个即可蛤

点开查看后面7条评论