blame | history | patch | commit | commitdiff | ignore whitespace
xiaoyong931011
2021-12-08 f5e6133809c553cfd9fb28ee61019927c547c374 
 src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java


@@ -5,9 +5,11 @@


import org.springframework.amqp.core.BindingBuilder;


import org.springframework.amqp.core.DirectExchange;


import org.springframework.amqp.core.Queue;


import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory;


import org.springframework.amqp.rabbit.connection.ConnectionFactory;


import org.springframework.amqp.rabbit.core.RabbitTemplate;


import org.springframework.beans.factory.config.ConfigurableBeanFactory;


import org.springframework.boot.autoconfigure.amqp.SimpleRabbitListenerContainerFactoryConfigurer;


import org.springframework.context.annotation.Bean;


import org.springframework.context.annotation.Configuration;


import org.springframework.context.annotation.Scope;


@@ -148,6 +150,16 @@


//        return connectionFactory;


//    }




    @Bean("customContainerFactory")


    public SimpleRabbitListenerContainerFactory containerFactory(SimpleRabbitListenerContainerFactoryConfigurer configurer,


                                                                 ConnectionFactory connectionFactory) {


        SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();


        factory.setConcurrentConsumers(10);


        factory.setMaxConcurrentConsumers(10);


        configurer.configure(factory, connectionFactory);


        return factory;


    }




    @Bean


    @Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE)


    public RabbitTemplate rabbitTemplate() {