activemq

    0熱度

    1回答

    在我的申請,我正在使用Apache的駱駝通配符和我已經定義路線建設者這樣叫: 從(「ActiveMQ的:隊列:* processQueue」) .bean(beanOne 「的someMethod」); 雖然發送消息我會發短信給 「{} UNIQUEID .processQueue」 隊列,所以我需要得到UNIQUEID內的someMethod的beanOne。

    0熱度

    1回答

    我正在使用新鮮的ActiveMQ 5.10.0安裝,其中有一個名爲'testing'的隊列中有消息。我也換成了ACTIVEMQ_SUNJMX線斌/ ActiveMQ的啓用JMX: ACTIVEMQ_SUNJMX_START="-Dcom.sun.management.jmxremote.port=1099 -Dcom.sun.management.jmxremote.authenticate=fa

    -1熱度

    1回答

    我正在使用新鮮的ActiveMQ 5.10.0安裝,其中有一個名爲'testing'的隊列中有一條消息。我也換成了ACTIVEMQ_SUNJMX線斌/ ActiveMQ的啓用JMX: JMXServiceURL url1 = new JMXServiceURL("service:jmx:rmi:///jndi/rmi://10.222.222.222:1099/jmxrmi"); JMX

    1熱度

    3回答

    我想使用靜態主機在我的雙節點羣集上啓用消息重新分配。但它似乎並不奏效。 1)我有10個生產者寫入隊列「MyTestQueue」節點1(但沒有消費者)。 2)我在節點2(但沒有生產者)上有1個消費者使用來自節點2的消息。 我期望節點1將消息重新分配給消費者存在的節點2,但它不會。節點1上的消息數量仍然等於發送到節點1的消息數量。 我在broker.xml中擁有以下配置,它將forward-when-

    1熱度

    1回答

    我想創建一個json,我希望從一個生產者發送到另一個,以後需要分解並使用它。 所以我使用activemq,並踐踏,因爲我在php編程。 我有以下程序我的製片人: <?php namespace Stomp; require __DIR__ . '/../vendor/autoload.php'; use Stomp\Client; use Stomp\

    0熱度

    2回答

    我是ActiveMQ的新手。我在我的應用程序中實現了activemq消息代理,但每當我在控制檯日誌中連接到activemq服務器時,我總是會看到下面的消息。看起來它繼續輪詢它似乎聽衆隊列。我希望我的偵聽器處於活動狀態,以便每當消息進入隊列時,應用程序都可以處理它。 與此同時,我不希望這條消息堆積我的日誌文件。 10:28:05.282 [ActiveMQ InactivityMonitor Wri

    0熱度

    1回答

    將訂戶寫入Listen AMQ隊列。它正在工作,但我想在AMQ重新啓動或關閉時自動重新連接。爲此添加下面的代碼: - StompJmsConnectionFactory factory = new StompJmsConnectionFactory(); factory.setBrokerURI("failover:tcp://" + host + ":" + port+"?ret

    0熱度

    2回答

    我不知道如果ActiveMQ是一個合適的工具在這裏... 我有一個任務隊列和多個消費者,所以我的想法是使用ActiveMQ的發佈任務,然後由消耗消費者。 但我需要能夠取消任務,如果它尚未處理... 是否有從隊列中刪除的ActiveMQ消息的API? Destination destination = session.createQueue(TOPIC_NAME); MessageProducer

    0熱度

    2回答

    當我使用ObjectMessage時,哪一方負責ActiveMQ中的類序列化/反序列化? 我假設客戶端,因爲類必須以序列化的形式發送到服務器,但是我發現我的隊列通過發送ObjectMessage'中斷':即使我收到來自該隊列的空讀取已經扭轉了我的conde變化,我發送TextMessage,如前所述。當我切換到另一個隊列時,一切正常。 它看起來像的ObjectMessage的情況下,被卡在服務器端

    0熱度

    1回答

    ,我發現了以下錯誤在應用中的用戶Apache的駱駝和ActiveMQ的: 無法解析端點:iasJms:// setStatus由於:無組件 發現方案:iasJm 這是造成問題的路線聲明: rest("/setStatus") .put("/{number}") .route() .from("direct:setStatusRest") .setE