spring-rabbitmq

0熱度

1回答

我有一個使用駱駝來設置從隊列中消耗的路由的spring應用程序。我使用rabbitmq作爲消息代理。現在的問題是，如果rabbitmq代理跌落連接不自動恢復。我試過啓用automaticRecoveryEnabled。但我得到noSuchMethodError。我將顯示用於創建連接的代碼。 <camelContext xmlns="http://camel.apache.org/schem

1熱度

1回答

無法使用Spring Boot向RabbitMQ隊列發送簡單的「Hello World」消息

我無法使用Spring Boot向RabbitMQ服務器發送消息。我沒有看到任何異常。不知道發生了什麼事。我對管理控制檯RabbitMQ擁有管理員級訪問權限，並可以查看隊列是否已創建。但是我沒有看到任何隊列被創建。而且在控制檯日誌中我看到的就是這個。控制檯日誌： 2017-08-15 11:32:17.015 INFO 8256 --- [ main] com.study.jms.Basi

2熱度

1回答

如何設置spring-rabbitmq收聽消息的速率

我正在使用spring-rabbitmq，並且我可以成功獲取消息。但是當我調試時，我發現監聽器創建一個線程，它會每1秒詢問消息。我認爲速率太高，我想要做的是將速率設置爲1分鐘或任何其他。我搜索了很多，但沒有工作我springrabbit.xml： <rabbit:listener-container connection-factory="connectionFactory" messag

0熱度

2回答

spring-boot-starter-amqp將在微服務之間起作用嗎？

我是Spring amqp的新手。我試圖通過以下方式發送消息：https://spring.io/guides/gs/messaging-rabbitmq/ 我能夠在微服務內發送消息。但無法發送消息到另一個微服務？是否預計？如果我想發送微服務之間的消息，我應該遵循的依賴關係？請幫我這裏。

0熱度

1回答

消息不發送，如果我不指定隊列，TopicExchange，在SpringBootApplication

綁定我試圖發送消息如下： rabbitTemplate.convertAndSend("my.exchange", "my.queue", "Test Message"); 並試圖如下接收消息： @RabbitListener(bindings = @QueueBinding(value = @Queue(value = "my.queue", durable = "true"), excha

1熱度

1回答

無法使用SprintBoot

在RabbitMQ的NACK消息，我有以下Consumer類監聽隊列上的傳入消息，然後兩個ACK和NACK他們。 ack部分工作正常，但nack不起作用。由於某種原因，所有的消息都會得到迴應。 application.properties中 spring.rabbitmq.host=192.168.99.100 spring.rabbitmq.port=5677 spring.rabbitmq

0熱度

1回答

在Spring AMQP

相關SimpleMessageListenerContainer一樣關閉連接我目前工作的一個基於事件的異步AMQP消息監聽器，像這樣： @Configuration public class ExampleAmqpConfiguration { @Bean(name = "container") public SimpleMessageListenerContainer m

0熱度

1回答

聽兔子隊列

我正在通過彈簧隊列聽兔子隊列和我收到此錯誤： org.springframework.amqp.rabbit.listener.exception.ListenerExecutionFailedException: Failed to invoke target method 'orchestrate' with argument type = [class [B], value = [{[[em

0熱度

1回答

如何註冊一個隊列，並且它是RabbitMQ和Spring的獨佔使用者/偵聽器？

我有以下問題需要解決：我想實現一個簡單的使用RabbitMQ消息傳遞的延遲重試機制。我有一個基礎設施，可以讓我延遲傳遞信息。我可以有任何想要在運行時利用這種延遲重試機制的感興趣的參與者。參與者只想給我提供2個細節和消息： 1.隊列名稱，他們希望在延遲T秒後傳遞消息。 2.隊列的消費者（比如消息的消費者。）我試圖做到以下幾點： private void startSeparateListene

0熱度

1回答

解決「無法創建航線ROUTE1在：>>>要[stream.out]」在駱駝

這是我寫從隊列 public class Sender { public static void main(String[] args) throws Exception { CamelContext camelContext = new DefaultCamelContext(); camelContext.addRoutes(new RouteBuilder(