0
我有一個小的需求。我將從某些輸入文件讀取數據並將它們加載到jms隊列中,並讓一些使用者從隊列中讀取數據包並處理它們。
有沒有什麼方法可以告訴消費者輸入數據已經完成,並且他們可以在處理完他們現在保存的數據之後安全地關閉它們?JMS:流數據包結束
我正在使用Apache Active MQ。
謝謝,
我有一個小的需求。我將從某些輸入文件讀取數據並將它們加載到jms隊列中,並讓一些使用者從隊列中讀取數據包並處理它們。
有沒有什麼方法可以告訴消費者輸入數據已經完成,並且他們可以在處理完他們現在保存的數據之後安全地關閉它們?JMS:流數據包結束
我正在使用Apache Active MQ。
謝謝,
JMS實施者有一個消息分組的功能,允許消息被分組在一起和處理消息在該組中的順序。一個組中的所有消息都由同一個消費者接收。組中的消息使用序列號進行排序。爲此,JMS定義了JMSXGroupdID
和JMSXGroupSeq
屬性。
您可以使用JMSXGroupID
屬性將從文件讀取的所有消息分組,併爲該組中的每條消息使用唯一的JMSXGroupSeq
屬性。消費者必須查找帶有組ID的消息並開始拾取消息,直到JMSXGroupSeq
屬性值爲-1。這標誌着該組的結束。
樣品和更多細節here