Auto create exchange by spring boot rabbit mq producer

[rapetum228]

Hello. How can I configure the Spring RabbitMq message producer to automatically create exchanges for messages?

I was able to send messages only to ready exchanges.

I also managed to configure the consumer to create the exchanger itself via AutoDeclare. Is there something similar for the producer?

[davsclaus]

It may be that rabbitmq has some option to allow auto delcare when sending to new destinations that does not already exists. You may look in their docs. Also there may be a ticket about this in Camel JIRA. You are welcome to search and report back

[davsclaus]

You need to refer to the bean via #bean:xxx syntax where xxx is the id of the bean. Some details at
https://camel.apache.org/components/4.0.x/others/main.html#_specifying_custom_beans

[davsclaus]

https://camel.apache.org/components/next/others/yaml-dsl.html#_creating_bean_using_constructors

[rapetum228]

Thanks, that does seem to work. I'll try to do something about it 🙃

[rapetum228]

I was able to create a RabbitMq exchange by adding Process in the route itself

import org.apache.camel.BindToRegistry;
import org.apache.camel.BeanInject;
import org.apache.camel.Configuration;
import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import org.springframework.amqp.core.FanoutExchange;
import org.springframework.amqp.rabbit.core.RabbitAdmin;
import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;

@Configuration
@BindToRegistry("CustomProcess")
public class CustomProcess implements Processor {

    @BeanInject("KaravanRabbitConnection")
    private CachingConnectionFactory connectionFactory;

    public void process(Exchange exchange) throws Exception {

        RabbitAdmin rabbitAdmin = new RabbitAdmin(connectionFactory);
        rabbitAdmin.declareExchange(new FanoutExchange("my_exchange", true, false));
    }
}

I'm not sure that's the right way to do it ...

[davsclaus]

Thanks for the solution. We can use some of that in camel-spring-rabbitmq and have a way of automating this

[davsclaus]

https://issues.apache.org/jira/browse/CAMEL-20299

Camel 4.5 will have a new option autoDeclareProducer you can set to true. Also remember to set exchangeType as it uses direct by deafult.

[rapetum228]

@davsclaus thank you! We wait 😁