cielswift opened a new issue #2136:
URL: https://github.com/apache/rocketmq/issues/2136
ROCKET MQ 4.6
JDK VERSION 1.8
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-spring-boot-starter</artifactId>
<version>2.1.0</version>
</dependency>
rocketmq:
producer:
group: transcation_1
name-server: 127.0.0.1:9877
Starts normally
------------------------------------------------------------------------------------------
But I added this
@Component
@RocketMQMessageListener(consumerGroup = "consumer_1", topic =
"ciel-top-name",selectorExpression = "*")
public class RocketListener implements RocketMQListener<ScaGirlMessage> {
@Override
public void onMessage(ScaGirlMessage message) {
System.out.println(message);
}
-----
Exception in thread "main" java.lang.IllegalStateException:
org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to
[127.0.0.1:9877] failed
at
org.apache.rocketmq.client.impl.factory.MQClientInstance.updateTopicRouteInfoFromNameServer(MQClientInstance.java:681)
at
org.apache.rocketmq.client.impl.factory.MQClientInstance.updateTopicRouteInfoFromNameServer(MQClientInstance.java:511)
at
org.apache.rocketmq.client.impl.consumer.DefaultMQPushConsumerImpl.updateTopicSubscribeInfoWhenSubscriptionChanged(DefaultMQPushConsumerImpl.java:867)
at
org.apache.rocketmq.client.impl.consumer.DefaultMQPushConsumerImpl.start(DefaultMQPushConsumerImpl.java:648)
at
org.apache.rocketmq.client.consumer.DefaultMQPushConsumer.start(DefaultMQPushConsumer.java:693)
at com.ciel.scaproducer2.mq.RocketListener.main(RocketListener.java:46)
Caused by: org.apache.rocketmq.remoting.exception.RemotingConnectException:
connect to [127.0.0.1:9877] failed
at
org.apache.rocketmq.remoting.netty.NettyRemotingClient.getAndCreateNameserverChannel(NettyRemotingClient.java:441)
at
org.apache.rocketmq.remoting.netty.NettyRemotingClient.getAndCreateChannel(NettyRemotingClient.java:396)
at
org.apache.rocketmq.remoting.netty.NettyRemotingClient.invokeSync(NettyRemotingClient.java:365)
at
org.apache.rocketmq.client.impl.MQClientAPIImpl.getTopicRouteInfoFromNameServer(MQClientAPIImpl.java:1369)
at
org.apache.rocketmq.client.impl.MQClientAPIImpl.getTopicRouteInfoFromNameServer(MQClientAPIImpl.java:1359)
at
org.apache.rocketmq.client.impl.factory.MQClientInstance.updateTopicRouteInfoFromNameServer(MQClientInstance.java:624)
... 5 more
Remove RocketListener together
normally----------------------------------------
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
