2020欧洲杯时间表

All Questions

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
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 ...
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
23 views

Spring-AMQP - routing based on message headers

As per the documentation: https://docs.spring.io/spring-amqp/docs/2.2.5.RELEASE/reference/html/#async-annotation-driven We can have different handlers for messages based on it's converted class type ...
0
votes
1answer
41 views

spring boot and rabbitmq (AMQP 1.0) with TLS

I am looking for a spring boot sample with connection to rabbitmq (or general AMQP 1.0 server) via TLS1.2 ... possibly using some already available plugins. Many thanks in advance for any help Best ...
0
votes
1answer
46 views

How to set property 'x-message-ttl' for queue in java

How to set 'x-message-ttl' properties to this queue? rabbit: bindings: TEST_RESPONSE: consumer: bindingRoutingKey: "'${routing}'" ...
0
votes
0answers
79 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 (https://docs.spring.io/spring-amqp/reference/html/#...
0
votes
3answers
49 views

Rabbitmq dead letter exchange not working resulting in infinite retries

I got a producer: rabbitTemplate.convertAndSend(QueueConstants.PROVISIONING_EXCHANGE, QueueConstants.PROVISIONING_ROUTING_KEY, message); And my config: @Bean Queue organizationProvisioningQueue() { ...
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
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 ...
0
votes
1answer
52 views

Handle multiple amqp messages concurrently through one consumer inside one spring-rabbit service

EDIT Just found out how to run multiple consumers inside one service: @Bean SimpleMessageListenerContainer container(ConnectionFactory connectionFactory, MessageListenerAdapter listenerAdapter) {...
0
votes
1answer
56 views

Spring AMQP how to access response message when connection is lost while sending using @SendTo

we have a microservice which consumes a message using @RabbitListener and persist data into database, generate a response on successful processing of message and send it using @sendTO to different ...
0
votes
1answer
26 views

why ConfirmCallback#confirm#CorrelationData has only one property id rather than the entire message so that i can resend message immediately

I am trying some stuff about Reliability of message delivery using ConfirmCallback. So far I've done these: 1.When I send a message, I save it in the db (There is a field called status that ...
1
vote
0answers
261 views

Getting RabbitMQ connection issues when connecting with SSL

I get the following exception while connecting to a server on port 8071. I was told SSL is configured on port 8071 due to which the connection is blocked but the error message does not explicitly tell ...

15 30 50 per page
1
2 3 4 5
12