Skip to content
Advertisement

Tag: rabbitmq

JMS Dynamic Message Selection

I have a message queue containing a customer id and some of their data. To improve performance those messages will be processed by multiple threads. My issue is that I need to find a way to ensure the message order for individual customers. To give an example, take a financial system with a queue of transactions: Message1: customer: 1, deposit:

@StreamListener is not visible when outside main Application class of Spring Boot. What could be the reason?

This is Spring Cloud Stream application. As i mention in the title, the StreamListener annotation works when inside the SpringBootApplication main class, but not when it resides in a different class with @Component annotation. I believe it is some sort of StreamListener visibility issue. I am publishing messages from the RabbitMQ management interface. Below is the exception i get: ConsumerApplication.java

How to configure separately both consumer and producer spring boot app when using rabbitmq?

I watched a tutorial that explains how to integrate RabbitMQ into Spring Boot app. In the tutorial, the ReceiveMessageHandler.java (Consumer) and SendMessageController.java (Producer) classes were in the same project. I want to implement them in two different Spring Boot application. However I can’t split the tutorial project into two consumer and producer project because of the ConfigureRabbitMq class. Because it

Re-creating a queue afters its manually deleted RabbitMQ

Is it possible to automatically re-create a queue afters it has been manually removed? I’m able to create the queue on start up using However, if it’s manually removed from rabbitmq, I want to be able to create a queue with the same name automatically. Today if I remove it, I will keep throwing exceptions like Answer Yes, you can

RabbitMQ Connection reset Exception

I have the same issue from this question: RabbitMQ Connection reset. My code is in kotlin and from https://www.rabbitmq.com/ssl.html#java-client-connecting. I have RabbitMQ configured this way: I tested this: https://www.rabbitmq.com/troubleshooting-ssl.html#sclient-connection and getting result in cmd: RabbitMQ log (1 attempt to connect): And exception, it’s coming from line with “val connection = connectionFactory.newConnection()” When I try to check TLS support in Erlang

java.lang.IllegalArgumentException when publishing a message with RabbitTemplate

I try to publish a message on a Queue with RabbitTemplate (using Spring Boot) and I got this message. I already tried to search for a solution. Maybe this part of code can help I appreciate any collaboration. Answer The problem is that your class SimpleMessage does not implement Serializable. RabbitTemplate.convertAndSend uses SimpleMessageConveter to convert your message into an amqp

Spring Rabbit MQ listener issues

My Configuration Class is below:- The DTO is :- The Snippet for publishing the message is:- And the snippet to listen the message is:- The issue is the logs here are not coming up but if I try with The snippet below then it works:- it does goes to the logs but how to get the TestDto in that case?

Advertisement