All Questions
83 questions
0
votes
0
answers
60
views
How to define RabbitMQ queue using spring-cloud-streams without a listener
I need to set the exchange and queue for RabbitMQ in my Spring Boot application, the thing is, The application only acts as a producer, but I need to define de queue as well in the service.
steps that ...
- 306
0
votes
0
answers
52
views
Issue with Dynamically Configuring Streams in RabbitMQ with STOMP and WebSocket
I hope you are all well. I would like to share a problem I am facing in my messaging architecture.
Architecture:
Web clients: Connect to RabbitMQ using the STOMP protocol.
Exchange: Clients subscribe ...
1
vote
0
answers
2k
views
why rabbitmq message consumption is so slow
Currently I am making logic to consume Message using Rabbitmq. However, contrary to expectations, it takes too long to consume the message.
If you look at the Queued messages graph in the picture ...
- 21
1
vote
1
answer
976
views
Unauthorized access to the RabbitMQ API
I am trying to accomplish each time when I start my app, to get from the RabbitMQ API, all the queues and exchanges that exist. But unfortunately I get the following error:
org.springframework.web....
user20598130
1
vote
1
answer
669
views
RabbitMQ direct exchange is not consuming messages
edit: edited to make it more generalized
I have a producer thread wanting to send a message to the consumer threads in Java using RabbitMQ direct exchange, but my consumer are not receiving the dish. ...
- 105
1
vote
0
answers
142
views
convertSendAndReceive() returns null Object
I have been looking for a solution since morning. Why is it returning null rather than an Object? Any ideas
Consumer part takes the message but the response is Null with the convertSendAndReceive() ...
- 31
0
votes
1
answer
798
views
How to get a response using RabbitMQ
Two microservices (CustomerService, OrderService) are communicating with each other using rabbitMQ. However, I want to get a response from the OrderService on whether the request has been successful ...
- 21
0
votes
0
answers
222
views
How to perform operation when a message is sent to dead letter queue because of expiration?
I have a requirement where I want to perform some operation with the message (like sending the message to the support team or logging the message in the console) when a message expires and is sent to ...
- 105
0
votes
1
answer
855
views
RabbitMQ Java channel "Closed due to exception from Consumer method handleDelivery for channel AMQChannel" in JavaFX
I'm trying to set up an amqp RabbitMQ consumer that is connected to a message queue from work. The code works just fine by itself, but as soon as I add it to my JavaFX application and open the channel,...
- 25
0
votes
1
answer
756
views
Rabbit listener method is not getting invoked with the incoming message
I have a method to consume messages in similar line as shown below:
@RabbitListener(queues = "${com.rabbimq.myQueue}")
public void receive(String msg, Channel channel, @Header(AmqpHeaders....
- 105
0
votes
1
answer
527
views
How to halt consuming messages in an AMQP for a certain period of time (where time is not fixed)?
I am trying to achieve the following scenario in my application:
When my application is up, the message from the incoming exchange should be consumed by the incoming queue.
If any exception/error ...
- 105
2
votes
1
answer
629
views
Stop consumption of message for rabbitmq for a period of time
Calling the stop method of SimpleMessageListenerContainer class is closing the channel ("Closing channel for unresponsive consumer"). But I don't want to close the channel. I am trying to ...
- 105
0
votes
1
answer
188
views
How to stop one micro service from consuming the message from Message queue-RabbitMQ
Please help me in this scenario
Suppose there are multiple micro service consuming the messages from rabbitmq
But I want to stop for sometime one microservice to consume the message.
1.How will I ...
- 11
2
votes
0
answers
493
views
Multi-threaded RabbitMQ consumer
I am working on a simple worker micro-service in Java, which is consuming (basicConsume) messages from RMQ, processing them and inserting them into a DB.
Currently, the service is using 1 thread for ...
- 649
0
votes
1
answer
92
views
JMS Dynamic Message Selection
I have a message queue containing a customer id and some of their data. To improve performance those messages will be processed by multiple threads. My issue is that I need to find a way to ensure the ...
- 1,790