現在遇到一個問題，我們的rocketmq服務器只有一臺，開發環境和測驗環境發送到topic的資訊，會被隨機消費，怎么樣實作分開呢？
目前的代碼：
<!-- rocketMQ -->
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-spring-boot</artifactId>
<version>2.0.2</version>
<scope>compile</scope>
</dependency>
@Component
@RocketMQMessageListener(consumerGroup = "test_consumer_group", topic = MQConstant.TOPIC_TEST)
public class TopicTestListener implements RocketMQListener<Object> {
@Override
public void onMessage(Object object) {
System.out.println(MQConstant.TOPIC_TEST + ", onMessage...");
System.out.println(object.toString());
}
public String getName(){
return "";
}
}
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/169800.html
標籤：Java SE