I am trying to write a simple consumer for a rabbitMQ queue on which a DLX (binded to another queue is configured). I am using camel 3.14.5 at the moment. My camel route declaration looks like : And my connectionFactory : But then when my processor throw an exception I get the following logs : How should I configure the
Tag: spring-rabbit
spring-jms – listener exchange and bind queue by jms configuration
I have a project with spring-jms I’m trying work with exchanges. I created 4 listeners and all of them are been bound into exchange named ‘jms.durable.queues’ by default. Even thought I create my own exchanges and binding my queues manually on rabbit console, spring is creating a default exchange. How could I create my own queues and bind into my
What kind of threading model changes led to DMLC
The doc explains why DMLC was introduced in version 2: https://docs.spring.io/spring-amqp/reference/html/#choose-container This architecture was required because, in early versions of the RabbitMQ client, multiple concurrent deliveries were not possible. Newer versions of the client have a revised threading model and can now support concurrency. This has allowed the introduction of the DMLC where the listener is now invoked directly on
Dynamically configure RabbitMQ users and permissions with Java Spring AMQP
For security reasons, I want to configure separate user accounts with specific permissions to isolates queues in RabbitMQ. As users need to be a dynamic (adding new, removing deactivated…) I would like to achieve this with Java Spring AMQP. Creating queues, exchanges and bindings is possible with The RabbitMQ Management HTTP API provides also features regarding the user management, as
Synchronous publish for rabbitmq
I want to have two sets API for the clients to publish messages sync send(no retry, fail immediately and send status back to the clients synchronously) async send (publisher and confirm callback, with retry, log and drop the message after certain retries). I am able to implement this by enabling confirm and return. Is there any way to implement Synchronous
Java RabbitMQ: can’t map message to corresponding class
I have two different java spring projects that communicate through rabbitmq. I’m trying to send a java object but I get this error message: I’m aware that the problem is in the classpath that should be the same in both producer and consumer, but since each project has a different name I can’t make the classpath the same even though
Sending messages from Java to RabbitMQ using com.rabbitmq.http.client.Client
I’m trying to send messages from a Java service to RabbitMQ. I’m using some Java RabbitMQ client library and trying to run the following code: In the last line (Client objectinitialization), the following error is thrown: java.lang.NoClassDefFoundError: org/springframework/http/converter/json/Jackson2ObjectMapperBuilder I think I might be missing something in my pom.xml or maybe something with the version of Spring. However, I have not
When publisher confirms are enabled, queue length limit is set and overflow is set to reject-publish,why cause in confirm callback I received is null?
I am learning Queue Length Limit(https://www.rabbitmq.com/maxlength.html), as it says, queue is set to ‘x-max-length:10’,and ‘x-overflow:reject-publish’, and also, I enable publisher confirms. So, when the number of messages in the queue reaches 10, the publisher will be informed of the reject via a basic.nack message. And it is: my confirm callback got a false ack, but cause is null. I’m wondering
Order of message receiving with concurrent consumers in Spring and RabbitMQ
I have following code, so I read messages from one queue and resend it, to another one. I am interested in setConcurrentConsumers(3) method does it means that three listener threads will be created? And in such case how I understood order of re-sending to queue1 and queue2 will not be met. As for me is importation to have the same
how to set Shutdown parameters for rabbit mq listener
we are trying to shutdown all process which are all running in micro service Any Consumer currently doing some work when trying to ack their current message Any other action on the channel. I’d like to let the consumers finish whatever message they’re processing and then close everything down. if we stop the running process and allow the transfer of