private static STOMPManager stompManager;
private static STOMPSender stompSender;
private static STOMPReceiver stompReceiver;
private String topicName = "testTopic";
public void MessageQueue () {
  //初始化库
  STOMPManager.initializeLibrary();
  //构造STOMPManager
  stompManager = new STOMPManager();
  //建立连接
  stompManager.connection(
    "failover:(tcp://192.168.18.179:61613?wireFormat=stomp)","supermap", "supermap123");
    //创建接收端
    stompReceiver = stompManager.newReceiver(true, topicName, clientID[0]);
    //接收消息
    thread = new Thread(new Runnable() {
      @Override
      public void run() {
        // TODO Auto-generated method stub
        while (threadFlag) {
          //接收消息
          String expReceive = stompReceiver.receive();
        }
      }
    });
    thread.start();
    //创建发送端
    stompSender = stompManager.newSender(true, topicName);
    //发送消息
    stompSender.sendMessage(sMessage);
}