spring-amqp Questions
2
Solved
I have a rabbit queue with messages for consuming. I also have a listener that can fail. The queue is configured with a dead letter exchange (along with a dead letter queue). What I want is to see ...
Constitutive asked 19/11, 2015 at 17:24
3
Solved
This is the scenario - There are multiple app servers. Browser can connect via websocket to any app server.
The app servers (consumers) are all listening on a particular queue. As soon as a web so...
Westbrook asked 3/3, 2016 at 21:19
5
Here are my code snippets.
MQConfiguration class for configuration
@Configuration
public class MQConfiguration {
@Bean
public Receiver receiver() {
return new Receiver();
}
}
Receiver class...
Muldrow asked 28/2, 2017 at 9:28
7
I am new to Spring AMQP / Rabbit MQ.
Am using a Spring AMQP / Rabbit MQ in my project. I am facing following error after running a tomcat:
org.springframework.amqp.rabbit.listener.SimpleMessage...
Dauntless asked 25/11, 2015 at 11:30
18
Solved
Spring AMQP + RabbitMQ 3.3.5 ACCESS_REFUSED - Login was refused using authentication mechanism PLAIN
I am getting below exception
org.springframework.amqp.AmqpAuthenticationException: com.rabbitmq.client.AuthenticationFailureException: ACCESS_REFUSED - Login was refused using authentication mec...
Hermosillo asked 7/11, 2014 at 23:42
2
Solved
I have written a RabbitMQ consumer by implementing the MessageListener interface and setting up a SimpleMessageListenerContainer. Its working well when I test it manually. Now I would like to write...
Angelicaangelico asked 22/1, 2015 at 21:37
3
Solved
In question How to set the consumer-tag value in spring-amqp it is being asked how to change the consumer tag when using Spring Amqp and the answer suggests to provide an implementation of Consumer...
Firebug asked 2/11, 2018 at 13:35
8
Solved
How to mock spring rabbitmq/amqp so it will not fail during a Spring Boot Test while trying to auto create exchanges/queues?
Given I have a simple RabbitListener that will cause the queue and exch...
Palpebrate asked 3/8, 2016 at 14:31
2
Solved
I think I am missing something here..I am trying to create simple rabbit listner which can accept custom object as message type. Now as per doc it says
In versions prior to 1.6, the type informati...
Balefire asked 28/1, 2017 at 20:45
4
Solved
I am building an application using RabbitMQ with Spring: so far so good.
To define Unit Tests I am using JUnit targeting an external server.
What I wanted to find out is if there is a way to mock...
Sarette asked 19/1, 2015 at 12:37
3
Solved
Getting stocked while doing with RabbitMQ using Spring-AMQP.
Just need to get a way to configure AutomaticRecoveryEnabled and NetworkRecoveryInterval using Spring-AMQP. There is a direct option to...
Misprint asked 7/8, 2014 at 6:18
2
Solved
I am trying out simple sender and receiving of messages using Spring AMQP with jackson2JsonMessageConverter.
Also, what is the significance of _TypeId_ here
why it is showing sender package with cl...
Fredricfredrick asked 25/8, 2016 at 6:3
2
Solved
I understand below
prefetch simply controls how many messsages the broker allows to be outstanding at the consumer at a time. When set to 1, this means the broker will send 1 message, wait for the ...
Erythrite asked 8/12, 2020 at 15:0
2
Solved
Is there a way to gracefully stop a ListenerContainer, and its associated Consumers.
What I'm trying to achieve.
Stop consuming messages.
Gracefully stop ListenerContainer.
Await long running co...
Dactylogram asked 5/5, 2019 at 12:15
1
I'm working on a Java application which uses Spring Boot version 2.0.4.RELEASE and RabbitMQ version 3.7.7. The app is caching all the messages from the RabbitMQ in Redis database and has to resend ...
Codger asked 20/8, 2018 at 16:47
5
Solved
I plan on storing stacktraces in the RabbitMQ message header. Do message headers have a size limit?
Muncy asked 8/6, 2015 at 18:0
5
Solved
I know it is possible to make SimpleMessageListenerContainer bean and set prefetch count and message listener here, like this:
@Bean
public SimpleMessageListenerContainer messageListenerContainer(...
Manasseh asked 1/6, 2016 at 0:23
4
I have a SpringBoot Application which makes use of Spring AMQP. At the moment I am implementing the receiver side of it using JavaConfig classes as directed by official Spring docs examples. Howeve...
Sinegold asked 25/10, 2016 at 13:3
3
I have a component that sends a message to a worker service waiting back the result.
@Autowired
private RabbitTemplate rabbit;
[...]
Object response = rabbit.convertSendAndReceive("testQ", ...);
...
Coppersmith asked 9/6, 2015 at 15:37
2
Solved
I am trying to update the consumer-tag to be more informative than the randomly generated string. We have a pattern which we use that includes hostname + identifier + randomized string. This works ...
Wives asked 22/4, 2015 at 15:13
2
is there any way to return the number of messages that are unacknowledged?
I am using this code to get the number of messages in the queue:
DeclareOk declareOk = amqpAdmin.getRabbitTemplate().exe...
Gerrygerrymander asked 5/12, 2012 at 10:28
2
I have read a few discussions and forums but still fail to understand which one is better rabbitmq vs activemq. I have heard the delay in rabbitmq is more because all traffic is first diverte...
Snoddy asked 21/10, 2017 at 20:29
1
I am using self signed certificates in my Rabbitmq server and the broker is started successfully with SSL port. I am now trying to renew / use new SSL certificates, SSL key and truststore but I do ...
Savil asked 4/7, 2018 at 6:0
2
Solved
I have a use case where I need to consume messages from queues which are discovered at runtime.
Here I have a config class and the listener class. I have defined a consumer for the two existing que...
Mucus asked 29/7, 2020 at 21:38
4
Solved
I have an existing queue created in RabbitMQ. It can be created with or without x-dead-letter-exchange parameter. I am creating a consumer of this queue in Spring using the RabbitTemplate. When I d...
Introductory asked 11/8, 2015 at 9:54
1 Next >
© 2022 - 2024 — McMap. All rights reserved.