2020欧洲杯时间表

Questions tagged [spring-rabbitmq]

Spring components for AMQP-based messaging.

242 questions with no upvoted or accepted answers
Filter by
Sorted by
Tagged with
8
votes
1answer
2k views

How to restart a SimpleMessageListenerContainer

I try to connect to a RabbitMQ with spring boot. The connection should always restart/retry the connection. I have a problem reconnecting after a fatal exception. The application can never loose a ...
6
votes
2answers
826 views

Spring Amqp internal NullPointerException on RabbitTemplate convertAndSend

I randomically experience a NullPointerException while trying to publish a message using RabbitTemplate.convertAndSend I tried both spring-amqp:1.7.6 and spring-amqp:1.7.8 and this should be the ...
6
votes
0answers
791 views

Rabbitmq reload/refresh new certificates without restart

I am using self signed certificates in my Rabbitmq server and the broker is started successfully with SSL port. I am now trying to renew / use new SSL certificates, SSL key and truststore but I do not ...
5
votes
0answers
1k views

RabbitMQ health check failed

I'm using Spring Boot and running RabbitMQ inside docker container. All works well except Rabbit health check problem. Which means I can't queue messages from my web app. This is exact error I have ...
4
votes
1answer
9k views

Channel shutdown: channel error

sometimes i found follow entry in my log file. I have no idea what the problem is. My guess is to set a lower request heartbeat. Any other ideas? Additionally i had the situtation that after a rabbit ...
3
votes
1answer
75 views

Spring cloud stream rabbitmq binder - spring cloud function error handling

i am using spring cloud stream rabbit binder with spring cloud function and defining listeners like: public Function<Flux<SomeObject>, Flux<OtherObject>> foo() { //some code } I ...
3
votes
1answer
988 views

Rabbitmq: Unacked message not going away after broker restart

We have observed the following behavior of RabbitMQ and are trying to understand if it is correct and how to resolve it. Scenario: A (persistent) message is delivered into a durable queue The (...
3
votes
1answer
1k views

How can I set the spring-rabbitmq listener's rate of receive message

I am using spring-rabbitmq ,and I can get messages successfully. but when I debug I found that the listener creates a thread and it will ask for messages every 1 second .I think the rate is too high ....
3
votes
0answers
570 views

Spring Cloud Stream - How to implement retry using reactive API?

I am using Spring Cloud Stream, with RabbitMQ binder and reactive API. The official documentation provides information on how to implement retry using DLQ, which works great but I can't get it to work ...
3
votes
1answer
2k views

How to avoid shutdown of SimpleMessageListenerContainer in case of unexpected errors?

I am using Java boot 1.4.0 and 'spring-boot-starter-amqp' for connecting to rabbitMq. The message producer, consumer and the rabbitMq server are under my control.Things were working fine for a few ...
3
votes
2answers
4k views

SimpleMessageListenerContainer - Consumer raised exception, processing can restart if the connection factory supports it

I keep getting the following warning in my spring rabbitmq consumer side. it keeps looking for restarting . [SimpleAsyncTaskExecutor-3317] WARN org.springframework.amqp.rabbit.listener....
2
votes
0answers
196 views

rabbitmq overflow redirecting messages - issue

I am using rabbit mq 3.7.4 and have a queue with x-max-length:3 and x-overflow:reject-publish, I am trying to redirect those messages which comes once queue reaches it's max limit (i.efrom 4th ...
2
votes
0answers
338 views

RabbitMq Asynchronous call have to wait until subscriber return a response

I am using Rabbitmq for communicating between Publisher and subscriber . My publisher is pushing message to Queue and subscriber is doing some process and returning response back to publisher. My ...
2
votes
0answers
197 views

Designing Complex Notification system in spring

I want to design and implement a complex notification system where I have a user which will be automatically and manually subscribed to different events. After some research I made up my mind to go ...
2
votes
0answers
218 views

Spring-RabbitMQ : Any Converter for sending Spring`s Multipart file

I want to publish MultipartFile to the queue and bind the rabbit listener to retrieve the MultipartFile from the queue. I tried sending as bytes and able to retrieve it. Is there any converter ...

15 30 50 per page
1
2 3 4 5
17