All Questions
13 questions
1
vote
1
answer
1k
views
Spring-Boot AMQP create queues based on database data
I want to use my Spring-Boot application to create queues in RabbitMQ, based on some data in my Database.
As example: I have an entity with some queue names. I need to create a new queue for each of ...
- 33
0
votes
1
answer
984
views
How do I send a message directly to a parking lot queue, prevent requeue and exit the program flow?
I currently have 4 queues:
test-queue
test-queue-short-term-dead-letter
test-queue-long-term-dead-letter
test-queue-parking-lot
When a message comes into test-queue, I do a check to see if the message ...
- 2,806
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
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
1
answer
1k
views
RabbitMQ slow receiving speed
I need to create application which should receive data from a data producer and process it. I chose RabbitMQ as a message-broker. My tests show me not the best results:
Sent - 100 msg;
Produce - 100 ...
6
votes
2
answers
14k
views
Activemq vs rabbitmq [closed]
I have read a few discussions and forums but still fail to understand which one is better rabbitmq vs activemq. I have heard the delay in rabbitmq is more because all traffic is first diverted to a ...
- 247
0
votes
2
answers
117
views
Requeue message that was accepted
I have a message that is on queue, but, when the message is successfully trigged, I don't want to delete the message from queue. I want to keep the message there, to be retriggered at another time, ...
- 639
5
votes
0
answers
2k
views
RabbitMQ : Create Dynamic queues in Direct Exchange
I am new to RabbitMQ, I just went through Rabbitmq docs (Routing). I am quite confused between Exchange with routing keys. My requirement is , I want to create multiple queues dynamically. Please ...
- 2,216
4
votes
1
answer
6k
views
RabbitMQ in Java using Protobuf. Parse received data
I am currently using springAMQP to communicate between java and my RabbitMQ node.
I am sending Protobuf data.
I would like to convert/cast/parse the received Message into the respective ProtoClass.
...
- 4,176
3
votes
1
answer
2k
views
Send message to arbitrary vhost / exchange with RabbitMQ / Spring AMQP
I use RabbitMQ and Spring AMQP to send messages.
I have this snippet:
rabbitTemplate.convertAndSend(exchange, key, object);
This works when I operate on a single VHOST.
I have to receive messages ...
- 241
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
1
vote
1
answer
2k
views
Spring AMQP: Comparing performance of multiple consumer vs multiple threads per consumer
Spring AMQP: Comparing performance of multiple consumer vs multiple threads per consumer
I'm in a phase of learning Spring AMQP from the Spring doc. I am not clear on preferred approach to increase ...
9
votes
2
answers
8k
views
when does an AMQP/RabbitMQ channel with no connections die?
I have a simple RabbitMQ test program randomly enqueuing messages, and another reading them, all using Spring-AMQP. If the consumer dies (for example killing a process without having a chance to close ...
- 7,547