2020欧洲杯时间表

Questions tagged [spring-rabbit]

Spring components for AMQP-based messaging with RabbitMQ.

Filter by
Sorted by
Tagged with
0
votes
0answers
14 views

Spring Cloud Stream Rabbit closes/recreates Source connection when Sink binder is down

When one of publisher binder is down, SCS is closing existing connection to rabbit1 server, is it expected? Our processor application connects to two binder's [rabbit1 and rabbit2] rabbit1 is our ...
2
votes
1answer
30 views

Spring AMQP Set prefetchCount on Queue Bean

How do I set the prefetchCount on for this queue consumer? @Bean public Queue eventQueue(AmqpAdmin amqpAdmin) { Queue queue = QueueBuilder.durable(EVENT_QUEUE_NAME) ... ....
0
votes
1answer
28 views

How to dynamically create bindings using “Declarables” in RabbitMQ Spring Framework

My code gets user's input which is a list of routing keys and use them to bind a queue with an exchange. I use Declarables to generate the bindings for each routing key. The problem is, the number of ...
0
votes
1answer
14 views

Creating a library to have rabbit spring beans created

I am creating a message bus jar which connects to different MQ broker like Rabbit MQ. The jar will be used by many applications to send and receive message from Rabbit. While sending message is ...
0
votes
1answer
31 views

Declarabes in Spring application using Rabbit MQ

I am using spring aqmp version 2.2.6 to create multiple binding to a topic exchange. I understand from the discussion and the reference document that i can use declarables .Spring AMQP: Creating ...
0
votes
1answer
12 views

Spring AMQP Get Existing Queue Names and Argument

We have a queue in production where message TTL was set via application. Now we want to change message TTL and attach policy via rabbit CTL than setting within application. Snippet: Map<String,...
0
votes
1answer
27 views

Any reason why RabbitMQ doesn't create exchange on start application?

I have strange RabbitMQ behavior (as for me of course). When I started spring boot web application, in my configuration I'm trying to create rabbit direct exchange: @Bean public DirectExchange ...
0
votes
1answer
24 views

Spring-AMQP - routing based on message headers

As per the documentation: http://docs.spring.io/spring-amqp/docs/2.2.5.RELEASE/reference/html/#async-annotation-driven We can have different handlers for messages based on it's converted class type ...
0
votes
1answer
43 views

spring boot and rabbitmq (AMQP 1.0) with TLS

I am looking for a spring boot sample with connection to rabbitmq (or general AMQP 1.0 server) via TLS1.2 ... possibly using some already available plugins. Many thanks in advance for any help Best ...
0
votes
1answer
47 views

How to set property 'x-message-ttl' for queue in java

How to set 'x-message-ttl' properties to this queue? rabbit: bindings: TEST_RESPONSE: consumer: bindingRoutingKey: "'${routing}'" ...
0
votes
0answers
81 views

“Fatal message conversion error” when receiving JSON with Spring RabbitMQ

I'm trying to setup synchronisation between two Spring applications with their own DBs. I need one table synchronised between them. @Configuration public class ConfigureRabbitMq { public static ...
1
vote
1answer
19 views

Understanding, replacing, configuring and modifying Spring Rabbit (AMQP) thread pools: A list of questions

I've got a few short questions about RabbitMQ + Spring , and i'd appreciate your help on this matter. After reading the documentation here (http://docs.spring.io/spring-amqp/reference/html/#...
0
votes
3answers
49 views

Rabbitmq dead letter exchange not working resulting in infinite retries

I got a producer: rabbitTemplate.convertAndSend(QueueConstants.PROVISIONING_EXCHANGE, QueueConstants.PROVISIONING_ROUTING_KEY, message); And my config: @Bean Queue organizationProvisioningQueue() { ...
0
votes
1answer
33 views

Alternative of @RabbitListner annotation in Reactor RabbitMQ

I want to use Reactor RabbitMQ for my existing RabbitMQ project with Spring boot(http://github.com/gotidhavalh/amqpdemo). So I want to know how can I implement it and when any AMQP message is sent ...
0
votes
0answers
26 views

Spring Cloud stream connecting to RabbitMQ thrown the following error: an unexpected connection driver error occurred

While the consumer tries to connect a remote RabbitMQ instance using Spring Cloud Stream the following exception is thrown c.r.c.impl.ForgivingExceptionHandler: An unexpected connection driver error ...

15 30 50 per page
1
2 3 4 5
32