hornetq

0熱度

1回答

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

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

1熱度

2回答

自定義輪詢vs JMS MessageListener

對不起，如果它是一個重複的問題。我有一個遺留的Web應用程序，它使用隊列（是的，正常的Java隊列）和自定義輪詢（每500ms）。 REST Web服務（/消息）將被調用，如果有其他空字符串，它將返回消息。我的需求：如果隊列中有實時消息，客戶端應該會收到消息。所以我可以節省500毫秒。從目前的方法轉向JMS有沒有優勢？從這個鏈接JMS MessageConsumer's messageLis

1熱度

1回答

Mule ESB HornetQ JMS消息未發佈

因爲我被困在最可能最簡單的Mule ESB/JMS用例中，所以忍受着我。我試圖讓一個Mule應用程序接受來自現有HornetQ隊列的傳入消息。下面提供了我的mule-config.xml。我的問題是這樣的;只要消息生產者向隊列中添加消息，HornetQ就會報告消息達到了給定消息的重新傳遞嘗試的最大次數，並將其發送給死信隊列 - 顯然永遠不會被Mule JMS入站 - 端點。這隻發生在Mule服務器

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