activemq

0熱度

2回答

在我們的項目中，我需要將消息推送到ActiveMQ並保持它們的持久性。當我發送新消息並且內存限制超過隊列中最老的消息時，應該從隊列中刪除/刪除或替換爲新消息。我不想清除整個隊列，隊列就像我們產品的故障安全消息積壓一樣工作，所以我需要在隊列中保留最後x個消息量。我試圖從谷歌和目前沒有運氣看。這裏是我的settings.xml政策 <destinationPolicy> <polic

0熱度

1回答

進行java調用以確定Apache Camel條件路由

這是我的場景。我有一個現有的處理應用程序，當前正在使用camel將ActiveMQ消息從隊列發送到Java應用程序進行處理，通常有多個應用程序在不同節點上運行。我需要能夠只將消息路由到一個應用程序實例時，該實例有能力處理它。應用程序bean本身意識到其容量狀態。「testCapacity」方法返回一個表示可用容量的布爾值。據我已搜查，我可以試圖找到一種方法，我的用作決策點到豆本身提出的「當」

0熱度

1回答

Spring與ActiveMQ的集成：當隊列中沒有更多待處理消息時獲取通知

我正在使用ActiveMQ與Spring集成。當我的隊列爲空時（沒有更多待處理的消息），我有要求做一些處理。我已經實現了這樣的事情， package my.com.spring.integration; public class MyListenerContainer extends DefaultMessageListenerContainer { @Override prot

2熱度

3回答

ActiveMQ的訪問此前公佈的數據上訂閱

我們利用當地的ActiveMQ到同時開啓5個進程之間傳輸數據。我有一些數據我需要發送一個過程，無論是在運行時（這工作完全正常），而且在啓動的默認值。事情是在流程啓動時發佈的，它不會被讀取，因爲它在數據發送時沒有訂閱主題。我有多個解決方案：我可能會推遲第一個發佈了一會，這樣的過程有時間啓動（這似乎不是非常有吸引力）;或者是否有辦法將所有存儲的以前未處理的消息發送給剛訂閱的某個進程？我編碼在C＃

0熱度

1回答

使用python從ActiveMQ隊列接收單條消息STOMP

嗨，我使用stomp.py模塊來發送和接收來自使用python的消息。雖然接收消息偵聽器將讀取指定的睡眠時間內的多個消息。但我只需要閱讀一條消息。這是可能的在Java中。如何使用STOMP從ActiveMQ讀取單個消息？下面是我測試的聽者腳本， import stomp import time class SampleListener(object): def on_me

0熱度

1回答

我如何將消息發送到使用JMS發件人在wso2esb

如何設置端點使用JMS發送到數據推到ActiveMQ的一個ActiveMQ的。當我給端點JMS：？/ sampleQueue transport.jms.ConnectionFactoryJNDIName =的QueueConnectionFactory & java.naming.factory.initial的= org.apache。 activemq.jndi.ActiveMQInitia

0熱度

2回答

activemq-all.jar（5.14.0）不適用於Spring 4.3.6？

早些時候我使用activemq-all-4.1.2.jar從apache-activemq-5.14.0中獲取/偵聽。但是，這使我以下異常： - 15-05-2017 18:50:32.685|WARN |AcitveMQ Connection Worker: ssl://BDNVM4APK756V02/X.X.X.X:61616|Encountered a JMSException - rese

0熱度

1回答

ActiveMQ ActiveMQ.Advisory.TempQueue越來越大

問題，在ActiveMQ出於某種原因（我不知道爲什麼）ActiveMQ.Advisory.TempQueue越來越大（每天1GB）。這裏是一個快照： Name Producer # Consumer # Enqueue # Dequeue # Memory % Dispatch # Always retroactive Average blocked time Average enq

2熱度

1回答

新手：ActiveMQ的駱駝

我很新的這個話題，需要一些解釋... 我們有一個正在運行的ActiveMQ-Server，它現在應該與Apache駱駝路由和處理增強。我們的整個配置是基於XML的。我的第一種方法是在我們的activemq.xml文件末尾做一個普通的<import resource="camel.xml">，但這似乎是錯誤的路徑。這些都是當前transortConnectors： <transportConne

0熱度

2回答

找不到類[org.apache.activemq.command.ActiveMQQueue]

<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:amq="http://activemq.apache.org/schema/core" xmlns:context="http://www.springframework.org/sc