Home > Back-end >  Rocketmq - springboot can achieve the same topic, use multiple environment isolation?
Rocketmq - springboot can achieve the same topic, use multiple environment isolation?

Time：10-13

Meet a problem now, we only had a rocketmq server, the development environment and test environment to send information to the topic, will be randomly consumption, how to implement separate?
The current code: 
 & lt; ! - rocketMQ - & gt; 
 
 Org. Apache. Rocketmq 
 Rocketmq - spring - boot 
 2.0.2 & lt;/version> 
 Compile 
 

@ Component 
@ RocketMQMessageListener (consumerGroup="test_consumer_group", topic.=MQConstant TOPIC_TEST) 
Public class TopicTestListener implements RocketMQListener {

@ Override 
Public void onMessage (Object Object) {
System. Out.println (MQConstant TOPIC_TEST + ", the onMessage... "); 
System. The out. Println (object. The toString ()); 
} 

Public String getName () {
return ""; 
} 
}  

           
          

          

            
Page link：https//www.codepudding.com/Backend/64222.html

          

          

               
Prev:Which bosses know through the appropriate method to compare the Date class 1486448690841 millisecond

               
Next:Of new, code, don't use break and continue

          

        
      
    
  
  

    

      

        

          
        

      

    

  

 

    

      

        

        	
    
            	
  • Related
    • 
            

          
                 

        

      

    

  



  

    

      

        
      

    

  





  
About Us:          Contact Us      Terms of Service      
Privacy Policy

  
Copyright © 2010-2023，Powered By CodePudding