Hi!
We are using Camel CDI 1.2.0, Camel core 2.16.1 and Camel RabbitMQ 2.16.1 in
our project.
For this project, I need to declare a queue on the default exchange of an
existing RabbitMQ Server. If i set declare=true on my endpoint URI the
RabbitMQConsumer tries to declare the queue and the defaul
Hello Souciance
Thanks for your answer!
The standard case you described works well for me.
However the following does not work:
I create an endpoint with the following URI:
rabbitmq://:/
(leaving the exchange part empty because i need to declare the queue on the
default exchange)
This causes
I tried what I described without camel, by directly using the RabbitMQ Java
Client. By directly using the client I am able to declare a queue on the
default exchange.
It seems the problem lies in the method declareExchangeAndQueue of the
RabbitMQEndpoint. This method calls channel.exchangeDeclare
I forgot to write that I only need to read from that queue.
The server side requires each client to declare a queue on the default
exchange to receive messages. To send messages the client uses pre-declared
queues and exchanges (this side works well, like you said).
So my problem only exists wh
I solved this problem by making a few changes to camel-rabbitMQ.
These are the parts that cause the problem:
- If the consumer declares a queue it always declares the exchange as well.
I now check, if the exchange name is null or empty and in that case don't
declare the exchange. Maybe an option
