2020欧洲杯时间表

All Questions

Tagged with
Filter by
Sorted by
Tagged with
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
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
52 views

Dynamic queues and listeners, messages not being sent?

Rabbit config: package com.rabbitMQ; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.amqp.core.AmqpAdmin; import org.springframework.amqp.core.AmqpTemplate; ...
1
vote
1answer
38 views

SimpleMessageListenerContainer unable to call message handler correctly

I'm trying listen to a RabbitMq queue in my Spring Boot application. In my RabbitConfig.java file, I have the following beans: // RabbitConfig.java // ...Queue, exchange, binding beans, etc @Bean ...
0
votes
2answers
57 views

How get currently IP address of RabbitMQ in Java?

I have a connectionFactory (org.springframework.amqp.rabbit.connection) with list of addresses @Bean(name = "mainConnectionFactory") @Primary public ConnectionFactory ...
0
votes
0answers
99 views

Spring RabbitMQ - Getting ClassCastException in MessageListener

I am getting ClassCastException from AMQP internals while using Spring RabbitMQ. We found this in application logs on production and were not able to reproduce this, but it's a real pain for us. ...
0
votes
1answer
119 views

Spring AMQP - Proper way to register queues to container on startup

I have a situation where I need to register queues dynamically in a run-time to a SimpleMessageListenerContainer. The problem I am experiencing is a deadlock that happens because of this: Thread: [52]...
0
votes
1answer
316 views

Using spring-rabbit, spring-amqp. How to set thread-name of listener thread started using SimpleMessageListenerContainer.start()

Using SimpleMessageListenerContainer.start() to start listener threads in client machine to listen for messages from RabbitMQ. All listener threads have name as SimpleAsyncTaskExecutor-1 . Is ...
1
vote
1answer
51 views

How to disconnect from rabbitmq after each test?

I have integrated with rabbitmq in a spring application. There are two SpringRunner tests which assert on whether the amqp receiver receives a message. The tests connect to a rabbitmq broker running ...
0
votes
1answer
201 views

How to requeue or reject in RabbitListenerErrorHandler on MANUAL ack mode?

i'm trying to reject message in RabbitListenerErrorHandler by throwing AmqpRejextAndDontRequeueException. But it's not working in MANUAL ack mode.(in AUTO ack mode work fine). How can i reject ...
0
votes
1answer
110 views

DirectMessageListenerContainer without a configured Task Executor on TomCat?

I'm setting a DirectMessageListenerContainer for my messaging application. I am working with Tomcat, Spring, AMQP. The docs have this warning https://docs.spring.io/spring-amqp/reference/#threading ...
1
vote
1answer
148 views

Validate exchange, routing key when publishing message using Spring RabbitMessagingTemplate

Is there a way to validate that the exchange and routing key/queue when sending message using RabbitMessagingTemplate? Currently, there is a default exchange and routing key which blank string and ...
0
votes
1answer
58 views

Rabbitmq + Spring AMQP: resend msg but no ack return

I use spring amqp to send msg, and add the resend logic if ack=false, with the same rabbitTemplate @Bean public RabbitTemplate customRabbitTemplate(ConnectionFactory connectionFactory) { ...
-1
votes
1answer
66 views

For high message volume, why for the same message am I getting frame_size error in rabbitmq?

I have a direct type exchange which is routing a message to a queue. I am getting frame size error. I am using Apache camel camel_rabbitmq component for a message publishing.
0
votes
1answer
417 views

Close connections related to SimpleMessageListenerContainer in Spring AMQP

I am currently working on an event-based async AMQP message listener, like this: @Configuration public class ExampleAmqpConfiguration { @Bean(name = "container") public ...

15 30 50 per page