spring-rabbitmq

0熱度

1回答

我已經閱讀了有關該主題的多個答案，看起來我的配置應該正常工作，但由於某種原因它沒有。這裏是配置： @Bean Queue intakeQueue(String name) { return new Queue(name, true); } @Bean Exchange dlx(String name) { return new DirectExchange(name); } @Bean

1熱度

2回答

春季Autowiring對RabbitListenerContainer不起作用

我正在使用Spring AMQP的MessageListenerContainer從RabbitMq Broker接收消息。儘管我能夠在偵聽器內部接收消息，但自動裝配不在偵聽器內部工作。這裏是如何我已經配置我的聽衆 @Bean public SimpleMessageListenerContainer listenerContainer() { SimpleMessageListen

1熱度

1回答

如何在測試配置中使用相同的bean但具有不同的屬性？

我有單獨的配置類，根據Spring Profile創建不同的bean。我希望我的測試儘可能模擬生產代碼，因此我想使用在Spring ‘PROD’ Profile下創建的相同的豆類，但添加/更新專門用於測試的不同屬性。什麼是實現這一目標的最佳方式？我的意思例子： @Profile(PROD) public class ProdConfig { @Bean public Sim

0熱度

1回答

如果爲HA使用rabbitmq鏡像隊列，應該定義應答隊列是否持久？

如果使用rabbitmq鏡像隊列作爲HA與RPC模式，應該定義應答隊列是否持久？同時，還有哪些特殊的配置要做？

2熱度

2回答

春季RabbitTemplate-如何在發佈商確認模式下獲得NACK發佈的消息

我有一個使用spring在RabbitQueue上發佈消息的Web應用程序。我已啓用發佈商確認並返回啓用，並使用spring rabbit：模板。這是我的配置： <rabbit:template id="amqpTemplate" connection-factory="amqpConnectionFactory" retry-template="retryTemplate" confirm-ca

2熱度

1回答

RabbitMQ消息優先級隊列不工作

我在我的日食中運行優先隊列java program，我遇到了問題，第一次得到正確的答案。還有一次，我在隊列中增加了一條消息，但這次我得到了不同的結果。 public static void main(String[] argv) throws Exception { ConnectionFactory factory = new ConnectionFactory(); Co

1熱度

2回答

是否有可能使用java應用程序將JSON對象傳遞給RabbitMQ隊列？

我想將JSON對象傳遞給RabbitMQ隊列。在下面的代碼中，我使用obj.toJSONString().getBytes()將Json對象轉換爲字符串，是否有可能在隊列中傳遞JSON對象而不是作爲字符串傳遞。 JSONObject obj = new JSONObject(); obj.put("Transaction","Test value"); \t \t \t \t \t \t

0熱度

2回答

SPRINGAMQP或RabbitMq Java API

我是rabbitMq和Spring AMQP的新手。我正在從頭開始構建一個新項目。在這裏，我們使用rabbit-Mq作爲消息代理的其中一個組件。在這個項目中，主要是所有的開發都在Java中進行。我們對一些組件使用Spring。現在，rabbit-mq雖然用Erlang編寫，但確實提供了一個乾淨的java Api。還有spring amqp，它提供了一個很好的界面來支持鬆耦合（通過AMQPTe

2熱度

1回答

創建一個具有2個消費者和多個端點的單個RabbitListenerContainerFactory來監聽消息的行爲

我有一個要求，我有1個直接交換，並且5個不同的隊列通過唯一的路由鍵綁定到它。基本上每個隊列都是針對不同的消費者端點。我正在使用彈簧託管端點註冊表，使用@RabbitListener。所以有5個端點註冊。在我實現它的時候，我創建了一個RabbitListenerContainerFactory，其值爲concurrentConsumer。但是我有一個問題，如果有一個工廠創建的消費者規模爲2，那麼所有

0熱度

1回答

基於密鑰（如ID）與RabbitMQ的

我們正在建設使用的RabbitMQ和Spring的監聽器，容器生產併發如下Web應用程序確定併發同時（例如本例中有10個線程），但我不希望它們同時處理具有相同數據的消息。例如，如果我發送Foo對象的id，我只想要同時處理不同的Foo對象，但應該按順序處理相同的Foo對象。我已經瞭解了RabbitMQ的交換和隊列類型，但無法想出這些與他們中的任何一個。我能想到的一種方式是創建多個不同模式的隊列，