2020欧洲杯时间表

Questions tagged [spring-rabbitmq]

Spring components for AMQP-based messaging.

Filter by
Sorted by
Tagged with
0
votes
1answer
45 views

How to handle spring boot stomp websocket subscribe endpoint to authorize users

We have successfully developed webosocket+stomp+rabbitmq for our project with security. It is working fine although we have some problems in solving the following case: The workflow of this ...
0
votes
1answer
28 views

Set MDC properties only for rabbitmq events

I want to apply filters to log only for rabbit events using MDC properties. And set trace Id && correlation id from the event header. I already have a RequestResponseLoggingFilter which is ...
0
votes
1answer
219 views

Add Custom Headers to Spring Cloud Stream (with Spring Reactor)

Being new to Spring Reactor, I am trying to stream the data using Spring cloud stream(using rabbitMQ). I need to add some custom headers before the message is sent to the queue. My spring-cloud-...
0
votes
2answers
177 views

How to disable Rabbit health check via Configuration

I would like to disable the rabbit health check in my default RabbitMockConfiguration. We have a Configuration that is imported via @Import. Unfortunately the Configuration does not prevent the health ...
2
votes
1answer
103 views

RabbitMQ - Move messages before deleting a queue

Using RabbitMQ 3.7.16, with spring-amqp 2.2.3.RELEASE. Multiple clients publish messages to the DataExchange topic exchange in our RabbitMQ server, using a unique routing key. In the absence of any ...
0
votes
0answers
48 views

Keda with Rabbitmq and Spring boot

I am trying to run KEDA with Rabbitmq & Spring Boot. But it is not working. Basically KEDA is not generating Kubernetes HPA object. I tried sample code (which is provided by KEDA in GO ...
0
votes
1answer
22 views

spring amqp rabbit - no receiver by default

I'm building two applications, one for publishing messages to RabbitMq and another for consuming the messages from RabbitMq. I got started with spring's getting started with rabbitmq The problem: ...
0
votes
0answers
25 views

Getting shutdown error in RabbitMQ consumers

I have a cluster of rabbitmq nodes and few days back I pulled one node due to some maintainance activity and pushed it back in the quorum after the activity was done. After this activity few consumers ...
0
votes
1answer
25 views

Spring Rabbit Listener shutdown handler or return message without redelivered flag

I have an unusual scenario in which I don't want a message to be sent back to the queue with the redelivered flag if my application has been shutdown gracefully (e.g. autoscaling) during processing of ...
0
votes
1answer
43 views

How to handle network time-out exception with rabbit mq while sending messages asynchronously using spring-amqp library

I have written a program which requires multiple queues interaction - means consumer of one queue writes message to another queue and same program has consumer to take action on that queue. Problem: ...
0
votes
0answers
55 views

How to config delay queue in RabbitMQ Java Application

Trying to set up a delay queue for my java Application. But when I ran the application I faced an exception. It seems when declaring the delay queue can't pass the arguments. I'm using rabbitmq 3.7 ...
0
votes
1answer
23 views

DirectMessageListenerContainer and SimpleMessageListenerContainer relationship to Rabbit Channels

When using DirectMessageListenerContainer with consumersPerQueue property of 25, I noticed 25 rabbit channels get created per listener container's subscribed queue. The rabbit channel count quickly ...
1
vote
2answers
30 views

How to bind to topic with Spring AMQP only if exchange exists?

I need to bind a queue to a topic exchange, but: Only if the topic exists If the topic exists, use the existing settings (e.g. durable, auto-delete, etc) Reason is, I need a 3rd party application ...
0
votes
1answer
43 views

Proper use of SpringRabbit DirectMessageListenerContainer and setConsumersPerQueue property

I use the DirectMessageListenerContainer to listen to individual queues, since it creates a consumer per queue, preventing queue starvation if a messages on say "queue1" take a while to process, while ...
1
vote
0answers
209 views

org.springframework.amqp.AmqpException: No method found for class java.util.LinkedHashMap

I have a problem with Spring Boot Rabbit Mq. I have 2 listeners which listen the same queue but handle different objects: @Service @RabbitListener(queues = "#{changeDataQueue.name}") public class ...

15 30 50 per page
1
3 4
5
6 7
45