2014-03-01 56 views
0


我有一個小的需求。我將從某些輸入文件讀取數據並將它們加載到jms隊列中,並讓一些使用者從隊列中讀取數據包並處理它們。
有沒有什麼方法可以告訴消費者輸入數據已經完成,並且他們可以在處理完他們現在保存的數據之後安全地關閉它們?JMS:流數據包結束

我正在使用Apache Active MQ。

謝謝,

回答

0

JMS實施者有一個消息分組的功能,允許消息被分組在一起和處理消息在該組中的順序。一個組中的所有消息都由同一個消費者接收。組中的消息使用序列號進行排序。爲此,JMS定義了JMSXGroupdIDJMSXGroupSeq屬性。

您可以使用JMSXGroupID屬性將從文件讀取的所有消息分組,併爲該組中的每條消息使用唯一的JMSXGroupSeq屬性。消費者必須查找帶有組ID的消息並開始拾取消息,直到JMSXGroupSeq屬性值爲-1。這標誌着該組的結束。

樣品和更多細節here