2020欧洲杯时间表

Questions tagged [spring-rabbitmq]

2020欧洲杯时间表 Spring components for AMQP-based messaging.

Filter by
Sorted by
Tagged with
2
votes
1answer
30 views

Spring AMQP Set prefetchCount on Queue Bean

How do I set the prefetchCount on for this queue consumer? @Bean public Queue eventQueue(AmqpAdmin amqpAdmin) { Queue queue = QueueBuilder.durable(EVENT_QUEUE_NAME) ... ....
0
votes
1answer
20 views

Spring AMQP RabbitListener adjust auto reconnect configuration

I'm trying to better understand the RabbitListener behavior when the broker goes down & when its brought back up. I have setup a rabbit in a docker container over localhost:6672 and created a ...
0
votes
0answers
22 views

Bridge RabbitMQ listener to Flux

I have a Reactive Spring Boot application consuming messages from RabbitMQ and persisting them in a (MongoDB) repository: @RabbitListener(...) public void processMessage(Message message) { ...
0
votes
2answers
28 views

Start @RabbitListener after SpringBoot Application is started

We have rabbitMq implementation in our Spring boot application. This is how we are defining the listener. But whenever we start the application AND there are messages in the queue, Consumption of ...
0
votes
2answers
61 views

how to make every 5 seconds send message to queue in rabbitmq?

I'm new for springboot and rabbitmq. how to make every 5 seconds send a message in rabbitmq. I tried to do it in the code below but I'm not sure. Can you help me? thanks... Sample code: package com....
0
votes
1answer
16 views

RabbitTemplate: Broker does not support fast replies via 'amq.rabbitmq.reply-to'

I am using Spring boot (version 2.2.7.RELEASE hence spring rabbit 2.2.6) and RabbitMQ 3.3.5. why RabbitTemplate can not use direct-reply? is there any configuration with the broker? spring rabbit ...
0
votes
1answer
26 views

How to dynamically create bindings using “Declarables” in RabbitMQ Spring Framework

My code gets user's input which is a list of routing keys and use them to bind a queue with an exchange. I use Declarables to generate the bindings for each routing key. The problem is, the number of ...
1
vote
1answer
28 views

Spring AMQP RabbitListener to connect with 2 Rabbit Clusters

I have one listener method annotated with @RabbitListener currently its configured to listen from 1 rabbit cluster. Now i have another rabbit cluster(cluster2) having the same queue/exchange/routing ...
0
votes
1answer
24 views

Spring boot rabbitmq no exchange '“xxxxxxx”' in vhost '/'

I'm writing a simple rabbitmq producer with spring boot 2.2.7. On the broker side I've setup a direct exchange samples , a queue named samples.default and binded them together adding a samples....
0
votes
0answers
20 views

Disable RabbitMQ health check for a specific binder using configuration(yml) file

My configuration properties for RabbitMQ are as below. stream: bindings: input: destination: dataEvents consumer: concurrency: 20 ...
0
votes
0answers
31 views

Spring Boot push notifications to specific user

I have micro-service architecture and there is event based communication. In background I have RabbitMQ and I listen multiple event types like this: @Slf4j @Component @RabbitListener(queues = "${app....
0
votes
1answer
22 views

Custom RabbitMessageListner Throws Wrapped Exception

I have custom MessageListener from the custom lib import org.springframework.amqp.core.* public class Subscriber { private SimpleMessageListenerContainer simpleMessageListenerContainer; ...
0
votes
1answer
26 views

CachingConnectionFactory confirm type simple vs correlated

What is difference between CachingConnectionFactory confirm type simple vs correlated.
0
votes
1answer
27 views

Spring boot Failover retryer using rabbitmq: Failed to invoke target method

I'm actually trying to implement a failover retryer functionality using rabbit mq. So the requirement is that I get a message from a queue and process it. If by any issue happens then the message ...
0
votes
1answer
35 views

kotlin object (local final class) not serializable

For Some reason, I need to construct an object in kotlin like below and need to send to rabbitMQ using rabbitTemplate.convertAndSend. But when I do that, I get an error var myObject = object ...

15 30 50 per page
1
2 3 4 5
45