jms

    0熱度

    1回答

    我有我的JBoss 5.1的Web應用程序兼容驗證碼: public class SendNotification { @Resource(mappedName="queue/QueueNotification") private Queue destination; @Resource(mappedName="ConnectionFactory") pr

    0熱度

    1回答

    得到消息ID我有以下代碼: @JmsListener(destination = "myQueue", containerFactory = "myFactory") public void receiveMessage(MyClass message) { service.process(message); } 現在,我想獲得的JMS消息ID。我知道我可以重寫MappingJa

    0熱度

    1回答

    當談到JMS隊列/主題時,我感到困惑。我想要的是消息應該發送給每個用戶,我希望訂閱者在活動時從非活動時間接收消息。但是,我無法控制訂閱者是否擁有持久訂閱。有沒有辦法建立一個持續隊列,並設置它,以便每個用戶都會收到相同的消息?以及如何設置這個使用彈簧配置 非常感謝。

    0熱度

    1回答

    我正在嘗試使用JMS和glasfish 3做一個簡單消息發送者的虛擬示例。我創建了一個無狀態bean,並且已在glasfish 3中定義了jsm/factory和jms/queue。是以下一個: package converter.ejb.impl; import javax.annotation.Resource; import javax.ejb.Stateless; import j

    0熱度

    1回答

    假設有一個ActiveMq實例,並且有100個客戶端正在監聽主題。 當在主題中發佈新消息時,是否可以限制接收它的訂閱者數量(僅示例10)? 如果現在有其他消息傳遞組件能夠做到這一點,或者存在解決方案/合併最佳實踐?

    0熱度

    1回答

    使用案例:需要在隊列上從一臺服務器向另一臺發送大型文件(100 MB的倍數)。 目前,我正在使用Activemq Artemis服務器發送大文件作爲ByteMessage,通過tcp協議輸入流的幫助,重新嘗試間隔爲-1,無限次失敗重試。這裏的主要問題是消費者終端連接將大部分是不穩定的,即由於移動性原因斷開與網絡的連接。 因此,當在隊列中發送文件時,如果連接斷開並且重新連接的代理應該從事務中斷的地方

    -1熱度

    1回答

    我見過很多關於如何從服務器/生產者發送消息到客戶端的代碼和示例,但我失去了如何從客戶端發送消息到服務器。它是否遵循相同的格式? 例如,假設我的服務器有5個主題:A,B,C,D,E。我的客戶端只收聽主題C. 所以我的服務器創建一個隊列併發送消息給訂閱者/客戶端。 我的客戶端獲取主題C上的消息。它執行一些計算,並且我想要將消息發回給發佈者(例如int)。什麼是必需的步驟? 我是否需要爲製作人設定一個目

    1熱度

    1回答

    我不明白在Activemq PooledConnectionFactory中應用expiryTimeout字段。 java doc表示「允許連接過期,而不考慮負載或空閒時間,這對於故障轉移強制從池中重新連接,重新建立負載平衡或使用主後期恢復很有用」。請給我舉一個例子,其中expiryTimeout場效應真實場景。

    0熱度

    1回答

    我會盡我所能解釋這一點。 正如我存儲我的數據,我從我的ActiveMQ的隊列接收在若干不同的位置,我已決定建立一個複合隊列,所以我可以分別處理每個位置的數據。 我遇到的問題是,我目前擁有的隊列在生產環境中。看起來,將名爲A的隊列更改爲也稱爲A的組合隊列A具有名爲B和C的虛擬目標,這會導致我失去現有隊列中的所有數據。它不會啓動前面的消息。目前,我正在創建一個名稱不同的新CompositeQueue,

    0熱度

    1回答

    我正在使用Tibjms jar for JMS連接,它在正常情況下工作正常,但是在連接到jms提供程序的連接丟失並返回時出現問題。要重現此問題,我執行了以下步驟 - 連接到Intranet並啓動服務器。工作正常。 從內網斷開。它開始嘗試重新連接服務器。精細。 再次連接到內部網。它拋出未知的異常,並再次連接。問題。 所以,我的問題是「的javax.jms.JMSException:通過連接服務器未知