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 QPID隊列與主題

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

0熱度

1回答

JEE 6 JMS示例

我正在嘗試使用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主題中發送消息的訂戶的最大數量

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

0熱度

1回答

Activemq - 通過不穩定連接發送大文件的最佳協議

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

-1熱度

1回答

Java ActiveMQ：如何發送消息從客戶端到服務器

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

1熱度

1回答

Activemq PooledConnectionFactory中到期超時的含義是什麼？

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

0熱度

1回答

ActiveMQ將現有的隊列轉換爲CompositeQueue

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

0熱度

1回答

Tibjms javax.jms.JMSException：服務器連接未知

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