hornetq

19熱度

4回答

假設我們有一個參與XA事務的數據庫（例如Oracle）和JMS提供者（例如HornetQ）。一條消息被髮送到一個JMS隊列，並且一些數據在同一個分佈式事務中被保存在數據庫中。事務提交後，消息使用者將讀取持久數據並在單獨的事務中處理它們。關於第一XA事務，下面的事件序列可以由事務管理器（如，JBoss）製備（HornetQ的）製備（Oracle）的提交（HornetQ的）執行的提交（甲骨文

2熱度

1回答

使用JMS 2.0自動資源定義的用戶定義

我正在嘗試使用JMS 2.0自動資源定義功能。下面是資源的定義是在一個生產： @JMSConnectionFactoryDefinition( name = "java:global/jms/MyConnectionFactory", user = "guest", maxPoolSize = 30, minPoolSize = 20, p

0熱度

1回答

如何知道何時與JMS主題的連接丟失？

我有一個Java富客戶端應用程序，它在啓動時在遠程HornetQ JMS主題上註冊一個持久訂閱。但是，如果服務器重新啓動，則連接丟失，只能通過重新啓動客戶端應用程序來恢復。這會導致混淆情況，其中未收到JMS消息，並且在客戶端重新啓動後立即收到大量消息。恢復連接的簡單方法是運行定時器來定期檢查連接是否仍然有效，並嘗試重新連接。或者，服務器可以向客戶端發送心跳信號，並且如果在一段時間後沒有收到

0熱度

1回答

通過jmx檢查hornetq上的mbean值

我想使用check_jmx插件來監視hornetq 2.4.0的實例，發現了nagios here。我與螞蟻建造它後，我可以把它像這樣： ./check_jmx -U service:jmx:rmi:///jndi/rmi://127.0.0.1:6000/jmxrmi -O java.lang:type=Memory -A HeapMemoryUsage -K used -I HeapMemo

0熱度

1回答

JMS EntityManager錯誤

我有一個在JBoss 6.4上運行的應用程序，它使用JMS隊列。當第一次部署此應用程序時，所有事情都按預期工作，但如果我重新部署而不重新啓動服務器，則會收到以下堆棧跟蹤。 HQ122001: Unhandled exception thrown from onMessage: org.springframework.transaction.CannotCreateTransactionExcept

1熱度

1回答

運行HornetQ時出現NullPointerException示例

我是JMS的新手，並試圖將HornetQ與JMS和Spring嵌入到我的項目中。在這裏，我下載並運行this example。然而，行： ConnectionFactory cf = (ConnectionFactory) jmsServer.lookup("/cf"); 將始終設置cf爲null，而在任何配置文件我找不到「CF」。這有什麼問題？

6熱度

1回答

爲什麼直接ByteBuffer在HornetQ服務器上不斷增加，導致OOM？

配置我已經建立了獨立的HornetQ在Ubuntu 12.04.3 LTS（GNU/Linux的3.8.0-29-x86_64的仿製）（2.4.7決賽）集羣。該實例具有2個內核的16GB RAM，並且我已將-Xms5G -Xmx10G分配給JVM。以下是在HornetQ的配置中的地址設置： <address-settings> <address-setting match="jms

0熱度

1回答

numFailedIdleTestsDefaultUser（db連接在空閒時間靜默失敗）

我剛剛配置了我的c3p0池屬性，但一段時間後，我可以看到（從監視工具）字段「numFailedIdleTestsDefaultUser」正在增加。我們需要擔心這個嗎？如果是，如何解決這個問題。 Regareds 威拉

0熱度

1回答

JMS拓撲結構（排隊多個消費者）和消息分組

這裏是我們建立 [Front server 1 (message producer)] [Front server n (message producer)] | | |________________ ________________| | | [Messaging Server (Horn

0熱度

1回答

HornetQ的消費者流量控制

我在http://hornetq.sourceforge.net/docs/hornetq-2.0.0.GA/user-manual/en/html/flow-control.html讀「消費者流量控制該控制服務器和客戶端之間的數據流量進行客戶端使用消息。出於性能方面的客戶提供之前通常緩衝消息通過receive（）方法傳遞給消費者，或者通過消息監聽器異步傳遞給消費者。如果消費者無法像傳遞並存儲