openmq

0熱度

1回答

標題可能會令人困惑，但這是我想完成。我想從1 ejb發送一個jms消息到另一個，第二個ejb有一個消息監聽器，現在這個工作正常。但我想讓第一個ejb創建一個臨時目標隊列，第二個ejb會響應 - 這也正常工作。我的問題是在第二個ejb中，它調用了第三方web服務，在某些情況下會在很長一段時間後響應，並且臨時隊列在那段時間應該過期。但問題是，它並沒有根據java.net：http://java.ne

0熱度

1回答

Spring MQ JMS重新連接配置

首先，我有一個關於如何配置JMS MQ以在代理連接關閉並重新啓動時重新連接到應用程序的問題。下面是我試過，這是我最初在我的配置彈簧MQ-JMS-connections.xml  <!-- <bean id="jmsQueueConnectionFactory.7" cl

0熱度

1回答

以編程方式讀取DMQ

如何以編程方式從「mq.sys.dmq」讀取消息。我用Glassfish的3.1.2.2 當我嘗試： InitialContext ctx = new InitialContext(); Queue queue = (Queue) ctx.lookup("mq.sys.dmq"); QueueConnectionFactory connFactory = (QueueConnectionFa

1熱度

1回答

使用Open MQ時彈出JMS會話問題

我正在使用spring-jms-3.0.6.RELEASE並打開MQ。關於爲什麼會提高以下例外的任何想法？ 2012-05-02 17:56:18,420 [stuJmsContainer-803059] WARN org.springframework.jms.listener.DefaultMessageListenerContainer - Setup of JMS message lis

0熱度

1回答

將Mule ESB連接到OpenMQ Broker

我試圖將Mule ESB連接到現有的OpenMQ代理。從mulesoft docs for openmq integration構建，我有以下流程; <jms:custom-connector name="Custom_JMS" specification="1.1" class="com.sun.messaging.ConnectionFactory" v

1熱度

1回答

可以使用什麼工具監視GlassFish中的jms代理

我使用Open MQ GUI管理控制檯（在Glassfish安裝目錄中）和QBrowser。是否有其他工具需要考慮？

1熱度

1回答

消息隊列應用程序

我被告知爲某些應用程序開發了一個類似MSMQ的消息隊列，但它必須用Java編寫，因此它能夠在Linux服務器上工作。一位同事通過glassfish測試了openmq，但它非常慢，甚至在同一臺計算機上安裝了這兩個應用程序。它會在慢速計算機上延遲每個消息1秒，在一個快速計算機上延遲.8，讀取他的代碼，一切看起來都很好，延遲似乎是由openmq glassfish函數（而不是他的代碼）引起的。我讀了一

0熱度

1回答

如何爲OpenMQ編寫一個簡約的Java客戶端

請幫助MQ nubee編寫他的第一個Java客戶端，我在Oracle文檔中有點迷茫。我已經啓動並運行了OpenMQ。在OpenMQ管理控制檯中，我建立了名爲「MyFirstTest」的代理 6個服務中有1個是「jms」（這似乎是最易於使用的服務），該服務也已啓動並正在運行（說：服務狀態正在運行）。所以我來了有趣的部分。如何連接到代理「MyFirstTest」，然後發送消息，並且最後讀取此消

2熱度

1回答

如何配置OpenMQ不將所有正在進行的消息存儲在內存中？

我已經爲我們的通知服務加載測試不同的JMS實現。沒有一個ActiveMQ，HornetQ和OpenMQ的行爲如預期（可靠性和消息優先級問題）。但是現在我用OpenMQ取得了最好的結果。預計兩個問題可能只是配置錯誤（我希望）。一個與JDBC存儲測試場景： 2生產者提供一個隊列不同的優先級發送消息。 1名消費者從隊列中消耗，速度略低於生產者生產的速度。 OpenMQ獨立運行，並使用PostgreS

3熱度

4回答

在調用onMessage（）時儘快調用JMS異步消息，從隊列中刪除消息

要求：我希望消息在隊列中保留，直到onMessage()成功執行。如果在執行onMessage()期間發生任何異常，並且如果它不處理，那麼應該將消息重新發送給監聽器。我將Glassfish v2作爲應用程序服務器。我正在使用OpenMQConnectionFactory和JmsTemplate在隊列上發送消息。請注意，我沒有使用MDB。 <bean id="openMQConnectionFa