ActiveMQ java Client

原创
2014/06/05 11:49
阅读数 4.4K
在网上找了一下,没找到相关的代码,给初学者做参考:

import java.text.SimpleDateFormat;
import java.util.Date;
import org.apache.activemq.transport.stomp.StompConnection;
import org.apache.activemq.transport.stomp.StompFrame;

class Listener {

    public static void main(String []args) throws Exception {
    	
    	final String topic = "/topic/TRACK";  
    	
    	StompConnection connection = new StompConnection();    	
    	connection.open("10.10.2.14", 61613);        
    	connection.connect("admin", "admin");    	
    	connection.subscribe(topic);     	
    	
    	while(true){  
            try {                 
                StompFrame message = connection.receive(60*1000);//60 秒钟timeout  
                System.out.println(new SimpleDateFormat("HH:mm:ss").format(new Date()) + " get -> " + message.getBody());  
            } catch (Exception e) {              	
                System.out.println(e.toString());  
                break;
            }                          
//            Thread.sleep(10);  
        }  
          
        connection.disconnect();  
    }  
    
}
    	
    	
    
    	     
    	
    	         
    


展开阅读全文
加载中

作者的其它热门文章

打赏
0
6 收藏
分享
打赏
0 评论
6 收藏
0
分享
返回顶部
顶部