2020欧洲杯时间表

Questions tagged [spring-amqp]

Spring components for AMQP-based messaging.

Filter by
Sorted by
Tagged with
0
votes
0answers
29 views

Spring-core with @RabbitListener annotation does not fire bounded method

I am trying to use rabbitmq @RabbitListener annotation in my methods so that whenever any message arrives, my method can get auto executed. Based on the official documentation provided here, I made ...
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
1answer
15 views

How to get consumerTag in spring-rabbitmq 1.x

the spring-rabbitmq config is like <groupId>org.springframework.amqp</groupId> <artifactId>spring-rabbit</artifactId> <version>1.1.3....
0
votes
1answer
21 views

No correlation header in reply

I have a problem using rabbitmq Using rabbitmq in the latest version of springboot, there is a method of convertSendAndReceive(..) , The specific use is as follows Object object = rabbitTemplate....
1
vote
1answer
29 views

How to declare bean as top level which is a requirement in SpringAMQP

I have tried creating beans in Spring which were defined in earlier versions of Spring core as beans.xml. SpringAMQP has a requirement to declare Queue, Topic Exchange, and Bindings as a top-level ...
0
votes
1answer
20 views

DirectMessageListenerContainer is it possible to use with BatchMessageListener

In current version org.springframework.amqp: 2.2.2 BatchMessageListener contains: @Override default void onMessage(Message message) { throw new UnsupportedOperationException("Should never be ...
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 ...
2
votes
2answers
33 views

How to consume message from RabbitMQ dead letter queue one by one

The requirement is like to process the messages from dead letter queue by exposed a REST service API(Spring Boot). So that once REST service is called, one message will be consumed from the DL queue ...
0
votes
0answers
26 views

Spring boot with two rabbitmq hosts

I am looking to configure multiple rabbit mq hosts with my springboot application using SimpleRoutingConnectionFactory. mq is used to read the data and has to be configured in IntegrationFlow host1 ...
0
votes
1answer
51 views

Problem handling Exception thrown by RabbitMq Listener

I have this Listener in my project: @Service @RequiredArgsConstructor @Slf4j public class ConsumerService { @RabbitListener(queues = "${queue.treatment.request}") public void ...
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
56 views

Spring AMQP - Publisher Confirms not closing unused channels

Publishing and getting acks/nacks is working as expected. My concern here is, it is not closing extra channels which are not in use. On the other hand with Publisher Confirms set to false the unused ...

15 30 50 per page
1
2 3 4 5
87