#rocketmq
Вопрос:
Это происходит в проекте Spring-Boot Dubbo. В одном модуле возникает такое исключение, в то время как другие модули работают хорошо. Это исключение также проявляется в тестовом примере, но странно, что приведенный ниже код должен выполняться без каких-либо проблем в основном методе. Есть ли кто-нибудь, кто сталкивался с такой проблемой и мог бы дать мне несколько советов, большое спасибо.
@Test
public void testNamesrv() throws MQClientException, RemotingException, InterruptedException, MQBrokerException {
DefaultMQProducer producer = new DefaultMQProducer("test_producer");
producer.setNamesrvAddr("127.0.0.1:9876");
producer.start();
Message testMessage = new Message("test_topic", "testMessage".getBytes());
SendResult send = producer.send(testMessage);//exception: no name server , please set it
System.out.println(send);
}