2020欧洲杯时间表

All Questions

Tagged with
Filter by
Sorted by
Tagged with
1
vote
0answers
33 views

RabbitMQ @RabbitListener annotation not working in Spring (not spring-boot)

I am trying to implement rabbitmq in my spring-core developed application. Below is my pom.xml <dependency> <groupId>org.springframework</groupId> <...
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
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....
-1
votes
1answer
46 views

is there any setting to go back to the first cluster CachingConnectionFactory setAddresses

I am using CachingConnectionFactory the setAddresses method for multiple clusters. connection = new CachingConnectionFactory(); connection.setAddresses("rabbit1:5672,rabbit2:5672"); when i turn off ...
0
votes
1answer
12 views

Spring AMQP Get Existing Queue Names and Argument

We have a queue in production where message TTL was set via application. Now we want to change message TTL and attach policy via rabbit CTL than setting within application. Snippet: Map<String,...
0
votes
1answer
32 views

Spring Integration with consumer and Nifi as dispatcher

we are developing a service that listens or consume message from RabbitMQ queue. The message is dispatch from Apache Nifi to the message queue (e.g. queue name is "workitems"). Now, I would like to ...
0
votes
1answer
63 views

Caused by: java.lang.ClassNotFoundException: org.springframework.integration.dsl.IntegrationFlowBuilder

I'm working on Spring Cloud Stream using RabbitMQ using Spring Boot v2.2.6.RELEASE. Error: java.lang.IllegalStateException: Error processing condition on org.springframework.cloud.stream.config....
0
votes
1answer
39 views

Update from Spring Boot 1.5.x to 2.2.x RabbitMQ doesn't declare bindings with a list

I used to declare queues, exchanges and bindings in one of my configuration files as follows: @EnableRabbit @Configuration public class MyRabbitConfiguration { @Bean public FanoutExchange ...
0
votes
1answer
45 views

Spring Reactive Stream - Unexpected Shutdown

We are using Spring Cloud Reactive Streams with RabbitMQ. Spring Reactive Stream appears to acknowledge the message as soon as it pulls it off the queue. So any errors unhandled exceptions that ...
0
votes
0answers
81 views

“Fatal message conversion error” when receiving JSON with Spring RabbitMQ

I'm trying to setup synchronisation between two Spring applications with their own DBs. I need one table synchronised between them. @Configuration public class ConfigureRabbitMq { public static ...
1
vote
1answer
19 views

Understanding, replacing, configuring and modifying Spring Rabbit (AMQP) thread pools: A list of questions

I've got a few short questions about RabbitMQ + Spring , and i'd appreciate your help on this matter. After reading the documentation here (http://docs.spring.io/spring-amqp/reference/html/#...
0
votes
1answer
35 views

Do we need to create bean for all in-built classes in Spring Boot?

I am trying to configure RabbitMQ with Spring Boot. Below is a snapshot of my config class. Case 1: @Bean public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) { ...
-1
votes
1answer
89 views

Add non-blocking consumer using AsyncRabbitTemplate

I am new to Rabbitmq and i would like to build a non-blocking consumer. i followed How to build a nonblocking Consumer when using AsyncRabbitTemplate with Request/Reply Pattern and created an ...
1
vote
0answers
16 views

Contract testing for multiple events in the same destination

I've got this configuration: spring: cloud.stream.bindings: input-product-created: content-type: application/json destination: output-product-management input-product-deleted: ...
0
votes
0answers
51 views

How to get end to end tracing between multiple microservices?

I am using following dependency to trace rabbitmq spans. compile group: 'io.opentracing.contrib', name: 'opentracing-spring-rabbitmq-parent', version: '2.0.5' I am trying to trace the spans between ...

15 30 50 per page
1
2 3 4 5
11