activemq

    5熱度

    2回答

    我正面臨連接ActiveMQ網絡的問題。 我有兩個方案: S1:我的應用程序連接到第一ActiveMQ的 「A」。這個activeMQ「A」連接到一個ActiveMQ「B」 - 這是導致我一些問題的場景。 S2:我的應用程序直接連接到ActiveMQ「B」。 在這兩種情況下,我們都發送數據到同一隊列,當然我們發送完全相同的數據。 預期結果:當ActiveMQ「B」接收到數據時,它應該在同一隊列中響

    -2熱度

    2回答

    我已經搜索了一段時間尋找一步一步的教程來解釋ActiveMQ與Camel的設置和集成,但幾乎沒有成功找到基本教程。 我已經有一個正在運行和配置的ActiveMQ服務器,但我無法啓動並運行Camel組件。它總是創建一個獨立的代理,我不能讓駱駝連接到現有的代理實例。 任何提示,我可以找到關於如何整合駱駝和更好地理解這兩個如何一起工作的基本教程? 請不要參考駱駝網站,因爲這與ActiveMQ的文檔一起,

    -1熱度

    1回答

    我有JSF應用程序 我曾試圖獲取消息從ActiveMQ的其他應用程序, 這是碎片從我代碼 @ResourceAdapter("activemq") public class Listener implements MessageListener { @Override public void onMessage(Message message) { String msg = n

    0熱度

    1回答

    創建連接下方,然後創建一個會話,然後從隊列中獲取一定量的消息。 public class Consumer { public static void main(String[] args) throws JMSException { Consumer consumer = new Consumer(); // creates a connection and session

    0熱度

    1回答

    背景: 我有一個標準的生產者消費者隊列,消費者緩慢,而生產者速度很快。期望是每當生產者完成所請求的消息時,它就認可該消息,並且生產者將假定與消息相關的任務完成。由於生產者速度很快,我不希望生產線等待,相反,只要消息被確認,就應該調用回調。由於JMS在這方面受到限制,並且我儘可能直接使用了像ActiveMQMessageProducer這樣的ActiveMQ類。 問題: 消息正在自動確認,即使Con

    0熱度

    1回答

    有誰知道如何將activeMQ的日誌作爲事件寫入Windows事件日誌(或者甚至可能)嗎? 謝謝

    0熱度

    1回答

    我正在使用Hibernate和ActiveMQ的atomikos。我的交易涉及消息被提交給數據庫併發送到隊列。 JMS reveiver然後讀取消息並調用db獲取。 有些情況下,Atomikos已經對Queue進行了提交,但是hibernate提交仍在進行中,同時從receiver中觸發了get查詢。我試圖找到是否有辦法在XA事務中指定提交順序,似乎沒有閱讀this。 所以我在想有沒有一種方法可以

    0熱度

    2回答

    我通過org.springframework.jms.core.JmsTemplate將org.springframework.messaging.support.GenericMessage發送到ActiveMQ中的隊列。在ActiveMQ中,我看到這條消息: Cannot display ObjectMessage body. Reason: Failed to build body from

    1熱度

    1回答

    我嘗試將消息寫入JMS隊列,我在下一步中將其寫入數據庫。第一部分應該是第二個異步同步。 JMS部分非常慢(1分鐘內1100個項目到隊列中)。 這就是我的工作。 @Bean public Job multiThreadedStepJob() { Flow flow1 = new FlowBuilder<Flow>("subflow1").from(step()).end();

    0熱度

    1回答

    我有一個正在運行的GlassFish服務器(版本4.1)。現在我有興趣使用jms和獨立消息客戶端創建一個簡單的消息服務。 (這應該在單獨的JVM中的遠程機器上運行。)不幸的是,當我嘗試初始化QueueConnectionFactory時,仍然收到NameNotFoundException。 這是我的代碼: import java.util.Properties; import javax.nam