Questions tagged [micronaut-rabbitmq]
11 questions
7
votes
2 answers
How to mock a service with spock in micronaut when testing a rabbit consumer?
I'm currently working with:
Micronaut 3.7.3
RabbitMQ 3.11.2
Spock
Groovy / Java 17
I'm implementing a rabbitmq consumer for a simple demo project following the guidelines from micronaut project…
ada-stack
- 73
- 4
1
vote
1 answer
Throw RabbitListenerException from the Listener method in Micronaut
I have a consumer exception handler in Micronaut as below
@Singleton
@Primary
@Replaces(DefaultRabbitListenerExceptionHandler.class)
public class RabbitListenerCustomExceptionHandler implements RabbitListenerExceptionHandler {
private static…
San Jaisy
- 15,327
- 34
- 171
- 290
0
votes
0 answers
Micronaut RabbitMQ library: Are there any guarantees that a published message is received by RabbitMQ?
I've heard that if a RabbitMQ connection goes down, Micronaut provides auto recovery and I was wondering what other features it provides. So, if I write a standard publisher class like:
import io.micronaut.rabbitmq.annotation.Binding;
import…
myworkaccount
- 33
- 2
0
votes
0 answers
micronaut integration tests bean order
I'm using Micornaut 3.7.4 and java 11.The server engine is netty. I use RabbitListener annotaion to retrieve messages from RabbitMQ. My producer and consumer are in the same application. I also injected http client to RabbitListener…
ali
- 145
- 14
0
votes
1 answer
RabbitMq Consumer not working because micronaut assigns executor threads to kafka consumer
I am running kafka in micronaut v3.4.3 in Kotlin and recently I integrated RabbitMq with the server using micronaut-rabbitmq v3.4.0. In the docs it is mentioned to specify the executors for the RabbitMq consumers in application.yml.
Now when the…
Sarthak Gupta
- 1
- 1
0
votes
0 answers
Rabbitmq Micronaut not reading queue message
I am facing an issue in rabbitmq-micronaut.
Issue: When I publish a message the rabbitmq the listener doesnt read the message and message goes into unack mode in the queue and when I restart this service which contain listener then the listener…
0
votes
2 answers
Micronaut: How to create queues in ChannelPoolListener when multiple connections exist
Micronaut 3.0.2 with io.micronaut.rabbitmq:micronaut-rabbitmq dependency.
I would like to use multiple connections and then use the proposed ChannelPoolListener based on io.micronaut.rabbitmq.connect.ChannelInitializer to create queues/exchanges…
abedurftig
- 1,118
- 1
- 12
- 24
0
votes
2 answers
How to test if channel and queue are created and bind to the exchange in rabbitMq using rabbitMq TestContainer in Micronaut
At the start of the application, I am creating the below channel and associated queues
@Singleton
public class ChannelPoolListener extends ChannelInitializer {
@Override
public void initialize(Channel channel) throws IOException {
…
San Jaisy
- 15,327
- 34
- 171
- 290
0
votes
0 answers
How to programmatically stop RabbitListener in Micronaut
I have a RabbitListener that looks like:
@RabbitListener
public class ProductListener {
@Queue(value = "product", executor = "product-listener")
public void receive(MyType message) {
// process message
}
}
In certain cases, I…
stm
- 174
- 1
- 2
- 11
0
votes
1 answer
Micronaut and RabbitMQ
I am working on an application that uses Micronaut and needs to consume message from a RabbitMQ queue. The matter is that the queue can provide a lot of messages so I would like to have a parameterized number of instance of the consumer.
For example…
Jib'z
- 953
- 1
- 12
- 23
0
votes
2 answers
Micronaut with rabbit mq sending the message from producer to consumer, on consumer side it accept the same value in parameter
Using rabbitMQ with Micronaut latest version. On consumer both the parameter accepts the same value from the producer, however, I am sending the different value from the producer.
Output of consumer, since the value for categoryId and id are…
San Jaisy
- 15,327
- 34
- 171
- 290