当前位置:首页 / 文章测试 / asyncTaskExecutor

asyncTaskExecutor

开始打字练习

@Configuration

public class RabbitmqConfig {

@Value("${spring.rabbitmq.concurrency}")

private Integer concurrency;

@Bean("containerFactory")

public SimpleRabbitListenerContainerFactory containerFactory(SimpleRabbitListenerContainerFactoryConfigurer configurer, ConnectionFactory connectionFactory){

SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();

//设置线程数

factory.setConcurrentConsumers(concurrency);

//设置最大线程数

factory.setMaxConcurrentConsumers(concurrency);

configurer.configure(factory, connectionFactory);

return factory;

}

}

声明:以上文章均为用户自行发布,仅供打字交流使用,不代表本站观点,本站不承担任何法律责任,特此声明!如果有侵犯到您的权利,请及时联系我们删除。