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,
newmessagecreator()
});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,
newmessagecreator()
});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,
newmessagecreator()
});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,
newmessagecreator()
});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 textme...
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 方法確...