activemq訊息型別
jms規範中的訊息型別包括textmessage、mapmessage、objectmessage、bytesmessage、和streammessage等五種。activemq也有對應的實現，下面我們結合spring jms分別來看一下五種訊息型別的收發**。
1、textmessage/**
* 向指定destination傳送text訊息
* @param destination
* @param message
*/public void sendtxtmessage(destination destination, final string message)
jmstemplate.send(destination, new messagecreator()
});system.out.println("springjms send text message...");
}2、mapmessage
/*** 向指定destination傳送map訊息
* @param destination
* @param message
*/public void sendmapmessage(destination destination, final string message)
jmstemplate.send(destination, new messagecreator()
});system.out.println("springjms send map message...");
}3、objectmessage
/*** 向指定destination傳送序列化的物件
* @param destination
* @param object object 必須序列化
*/public void sendobjectmessage(destination destination, final serializable object)
jmstemplate.send(destination, new messagecreator()
});system.out.println("springjms send object message...");
}4、bytesmessage
/*** 向指定destination傳送位元組訊息
* @param destination
* @param bytes
*/public void sendbytesmessage(destination destination, final byte bytes)
jmstemplate.send(destination, new messagecreator()
});system.out.println("springjms send bytes message...");
}5、streammessage
/*** 向預設佇列傳送stream訊息
*/public void sendstreammessage(destination destination)
});system.out.println("springjms send strem message...");
}訊息接收處理
/*** 根據訊息型別進行對應的處理
* @param destination 訊息傳送/接收共同的destination
* @throws jm***ception
*/public void receive(destination destination) throws jm***ception
// 如果是map訊息
if (message instanceof mapmessage)
// 如果是object訊息
if (message instanceof objectmessage)
// 如果是bytes訊息
if (message instanceof bytesmessage)
}// 如果是stream訊息
if (message instanceof streammessage)
}
Activemq訊息型別
activemq訊息型別 jms規範中的訊息型別包括textmessage mapmessage objectmessage bytesmessage 和streammessage 等五種。activemq也有對應的實現，下面我們結合spring jms分別來看一下五種訊息型別的收發 1 textm...
ActiveMQ訊息佇列
這個東西沒接觸到的時候挺懵的，用過一次之後，哇哦 public class producter catch jm ception e public void sendmessage string disname,listlist else thread.sleep 1000 int num coun...
activeMQ訊息佇列
session.auto acknowledge。當客戶成功的從receive 方法返回的時候，或者從messagelistener.onmessage方法成功返回的時候，會話自動確認客戶收到的訊息。session.client acknowledge。客戶通過訊息的 acknowledge 方法確...