All Questions
13 questions
2
votes
1
answer
2k
views
How can I use @RabbitListener in multiple classes?
I have a Spring application using RabbitMQ (spring-boot-starter-amqp).
I wanted to know if it's possible to use the @RabbitListener annotation across different classes.
I currently have two classes:...
- 2,806
-1
votes
1
answer
195
views
RabbitMQ: How to set common prefetchCount for all consumers?
I need to define the number of simultaneously processing messages for a queue. The prefetchCount works fine, but the limitation is for each consumer. In my case, I can have multiple consumers, but I ...
0
votes
1
answer
59
views
Return a job to the queue silently
I have a RabbitMQ with a job queue defined, and I'm consuming it with the Java through Spring Framework. I know that, if I throw an exception somewhere in the code while processing the job which I ...
- 1,435
0
votes
1
answer
652
views
RabbitMQ Listen messages from queue from multiple servers
We are listening rabbimq messages from a clustered environment where we have multiple nodes. We want to make one node as a primary node that always listens to messages and by any chance, if that node ...
1
vote
2
answers
2k
views
Spring Cloud and RabbitMQ: how change the queue to auto-delete = false?
I'm using a Spring Cloud example with RabbitMQ.
After starting a docker with RabbitMQ:
sudo docker run -t -i --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:3-management
I executed the example ...
- 19.2k
1
vote
1
answer
127
views
rabbitmq setting requeue in spring xd
1) spring-xd rabbitmq 'requeue=false' option not working.
below both setting result is same.
i was set 'requeue' option to 'false' but rabbitmq always attempt requeue(=retry).
Are there any ...
- 87
1
vote
1
answer
3k
views
Spring amqp: Remove all bindings for specific queue
Is there a way to remove all bindings for specific queue using spring-amqp?
There's a workaround, first delete a queue, and then redeclare it
amqpAdmin.deleteQueue("testQueue");
amqpAdmin....
- 6,895
1
vote
1
answer
1k
views
how to prevent message re-queue within rabbitmq server?
I'm using direct exchange to publish messages to certain queues with routing keys, all configured in rabbit-server not code, I'm consuming messages with spring micro-service then some failures ...
- 13
2
votes
1
answer
682
views
Configuring spring-rabbit queue address to be changeable in runtime
Here is a web app listening a RabbitMQ queue. Everything works fine, but it is inacceptable that host address of the queue (127.0.0.1) is hardcoded in spring xml config.
How can I have the host to be ...
- 4,371
9
votes
1
answer
7k
views
Spring as Broker Relay by using an external Message Broker
I would like to use Spring Messaging to create a real time notification system for logged users for my webapp.
I defined a AbstractWebSocketMessageBrokerConfigurer as follows:
@Override
public void ...
- 13.6k
2
votes
1
answer
932
views
Handle reconnection/retries using Lyra-style in Spring AMQP
I am using RabbitMQ covered with Spring AMQP abstraction.
So in essence I am using Spring AMQP.
I need to handle conneciton failures. It's fairly easy to achieve this using Lyra when you use raw ...
- 861
2
votes
2
answers
3k
views
Spring Integration - creating an anonymous queue
Problem:
I am using Spring Integration backed by RabbitMQ. I have a Fanout Exchange to which messages are published. I wish to launch multiple instances of the same service which creates a queue ...
- 485
1
vote
1
answer
675
views
rabbit mq message listener
Im using
@Autowired
RabbitTemplate temp;
temp.convertAndSend("aQueue", msg);
for sending and
@Autowired
RabbitTemplate temp;
return temp.receiveAndConvert("aQueue");
for receving messages from ...
- 2,342