记录器错误:
消费者无法在60000毫秒内启动;执行任务执行器有足够的线程来支持容器并发?
我该如何解决?
非常感谢。
我试图这样更改我的配置:
@配置公共类RabbitMQConfig {
private final SimpleRabbitListenerContainerFactory simpleRabbitListenerContainerFactory;
private final RabbitTemplate mqTemplate;
@Autowired
public RabbitMQConfig(SimpleRabbitListenerContainerFactory simpleRabbitListenerContainerFactory,
RabbitTemplate mqTemplate) {
this.simpleRabbitListenerContainerFactory = simpleRabbitListenerContainerFactory;
this.mqTemplate = mqTemplate;
}
@PostConstruct
public void init() {
simpleRabbitListenerContainerFactory.setMessageConverter(new Jackson2JsonMessageConverter());
simpleRabbitListenerContainerFactory.setTaskExecutor(Executors.newCachedThreadPool());
simpleRabbitListenerContainerFactory.setContainerConfigurer(c -> {
c.setAutoDeclare(false);
c.setConsumerStartTimeout(100000L);
});
mqTemplate.setMessageConverter(new Jackson2JsonMessageConverter());
}
@Bean
public Queue dlQueue() {
return new Queue(RabbitMQConstant.DEAD_LETTER_Q, true, false, false);
}
@Bean
public TopicExchange dlExchange() {
return new TopicExchange(RabbitMQConstant.DEAD_LETTER_EXCHANGE, true, false);
}
@Bean
public Binding dlxBinding() {
return BindingBuilder.bind(dlQueue()).to(dlExchange()).with(RabbitMQConstant.ROUTE_KEY);
}
}
调试日志也存在,并且Spring Boot启动缓慢。
2020-02-14 12:29:14.861 [main]错误org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer [,,,,] hia-api-使用者未能在100000毫秒内启动;任务执行器是否有足够的线程来支持容器并发?2020-02-14 12:30:54.870 [main]错误org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer [,,,] hia-api-使用者未能在100000毫秒内启动;任务执行器是否有足够的线程来支持容器并发?2020-02-14 12:32:34.872 [main]错误org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer [,,,] hia-api-使用者无法在100000毫秒内启动;任务执行器是否有足够的线程来支持容器并发?2020-02-14 12:34:14.873 [main]错误org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer [,,,] hia-api-使用者未能在100000毫秒内启动;任务执行器是否有足够的线程来支持容器并发?2020-02-14 12:35:54.877 [main]错误org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer [,,,] hia-api-使用者无法在100000毫秒内启动;任务执行器是否有足够的线程来支持容器并发?
您解决了问题吗?我有同样的问题。