hornetq

0熱度

1回答

我正在使用一個需要使用hornet-q的應用程序。由於某種原因，這是種打擊或錯過。當我創建一個隊列時，該隊列的第一條消息有效，但第二條消息沒有，因此我試圖對JBOSS上運行的REST API的每個連接使用一個新的隊列。有時候這沒問題，有時候我會得到412 - 先決條件失敗（當多次使用同一個名字）或者僅僅是500個內部錯誤。應用程序有一個/ api/hornet-queue /隊列/路徑，但它不

1熱度

1回答

HornetQ - 如何管理'消息分組'的消費者

在發送帶有羣組ID的多個消息（消息分組）後，如何管理他們的交付，爲每個Group-ID擁有消費者？它是如何工作的如果我的消息使用者是消息驅動的豆？這個想法是爲每個Group-ID實現並行處理。

3熱度

1回答

爲什麼沒有Jboss AS 7.1與Hornet Que - 消息驅動Bean使用池連接？

我們正在使用的HornetQ上的JBoss Messaging 7.1和文檔試圖在 https://docs.jboss.org/author/display/AS71/Messaging+configuration 說還有一個池連接工廠這是特殊的，因爲它利用了HornetQ的的出站適配器JCA資源適配器。這也是特殊的，因爲： * It is only available to local cl

1熱度

1回答

尾值屬性HornetQ在2.1.2.Final

如何進行末值屬性在HornetQ的工作？我發送了4個元素到MyQueue只是爲了測試這個屬性：2與最後值屬性定義，其他2與不同的最後值。我認爲只有2個元素將在隊列中處理：每個Last-Value屬性之一。但似乎並沒有發生。 JBoss JMX控制檯中的值如下所示：MessageCount = -4，DeliveringCount = -4，MessagesAdded = 4。那麼，它是如何工

1熱度

1回答

在嘗試發送消息時獲取'MQCC_FAILED'原因'2072''MQRC_SYNCPOINT_NOT_AVAILABLE'

在JBoss 5.1 GA中有一個監聽MQ 7.0隊列的MDB（mdbA）。接收之後，消息被保存到MySQL數據庫，我想將消息發送到另一個隊列（queueB），然後繼續處理mdbA中的消息，該消息會執行更多的插入並向HornetQ發送消息。對於第一條消息，所有工作都正常，我在數據庫中看到消息以及queueB和hornetQ。對於所有後續消息，「發送到隊列B」導致「MQRC_SYNCPOINT_NO

4熱度

3回答

用戶：空沒有權限=地址上的CREATE_DURABLE_QUEUE

我只是試圖創建一個JMS持久訂閱服務器，並使用HornetQ服務器。但我得到的執行拋出異常 Connection Factory Looked Up : HornetQConnectionFactory [serverLocator=ServerLocatorImpl [initialConnectors=[TransportConfiguration(name=netty, factory=or

0熱度

1回答

HornetQ：順序使用分佈式隊列

對於當前的項目，我試圖用JBoss 7.1和HornetQ（JMS）來設置以下場景，我認爲這是一個相當常見的用例：有三個應用程序服務器。許多MDB應該處理冗長計算過程的細分片段，這些任務應該分佈在三臺服務器之間。當一個片段完成並且相應的結果準備好時，結果應該被髮送到分佈式隊列，從中分配隊列被使用，並且總結果被組裝。爲了避免總體結果彙編期間的競爭條件，「結果」隊列必須按順序處理，儘管它可能分佈在多個

0熱度

2回答

HornetQ JBoss和Weblogic消息事務

我們有兩個應用程序分別在Weblogic和JBoss AS上運行。我們希望將HornetQ作爲異步消息傳遞的中間服務器。我想寫一個發佈/訂閱者。每當一個數據插入/修改/刪除（JPA）或任何可能的消息，它可能是。在這裏生產者將是Weblogic和消費者將是JBOSS。我怎樣才能實現它？

1熱度

1回答

HornetQ服務器（eap 6）能夠在eap 5中與jms-clients進行通信嗎？

我有HornetQ服務器（jboss eap 6）在jboss eap 5中與jms-clients進行通信的要求嗎？如果是這樣，請幫助我。而且我創建了一個jms橋，工作正常，但問題是hornetq服務器複製了jms服務器（JBoss EAP5）中的消息。但在這裏我的內涵是JMS客戶端（EAP 5）應連接到HornetQ的上EAP 6

1熱度

1回答

HornetQ的消息留在隊列中，我們使用的是HornetQ的核心閱讀非跨國消息後2.2.21.Final單機ACK

後，該消息仍停留在隊列中雖然承認創建會話中使用 sessionFactory.createSession(true, true, 0) 定位器設置： val transConf = new TransportConfiguration(classOf[NettyConnectorFactory].getName,map) val locator = HornetQClient.create