如果有人在Spring中共享一個簡單的基於xml的消費者監聽器配置示例,我會很高興。提前致謝。Activemq如何配置一個消費者監聽器(用Java編寫)
編輯;
我只想聽聽消費者的聽衆,而不是消費者的實現,因爲我已經在我的應用中實現了一個active-mq。並且它運行良好,但是我不能確定消費者同步發送的物品的順序。 問題是由於一次一個方法的異步執行(同時持有某些對象到db以記錄它們)而導致的不一致和數據操作。
編輯2: 讓我澄清這個複雜性。我有一個包含兩個基本單獨部分的應用程序。第一個是同步執行的Producer,爲新產品詢問db,然後「逐個」通過active-mq提供的「jmsTemplate.send」方法發送它們。這是從Cron/Timer同步執行的操作。換句話說,生產者正在從計時器/計時器執行。現在的問題是消費者本身。當生產者「一個接一個」地發送產品時,異步消費者(啓用併發)接收產品並異步使用它們。
問題從這裏開始。因爲當產品剛收到時從消費者執行的方法會執行一些數據庫持久性操作。當同一個產品被不同的併發消費者接收時(它是因爲我們的系統而發生的,而不是jms的問題,不關注這一點),那麼在同一個實體上執行相同的持久化操作會發生一些容易預測的異常。如何防止產品的異步操作或管理這類應用程序中令人厭惡的產品的訂單。
謝謝。
這部分 - >但是我不能確定消費者同步發送的物品的順序。問題是由於一次一個方法異步執行一個方法(持久化一些對象到db以記錄它們)而導致的不一致和數據操作。< - 真的很複雜,可能會詳細說明發生了什麼在你的系統中,問題在哪裏? – Eugene 2012-01-31 17:27:29
請再次檢查我編輯的問題上面..非常感謝.. – Javatar 2012-02-02 15:50:14