Activemq訊息型別

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 方法確...