Потребитель не смог начать в 60000 миллисекунд; у исполнителя задач достаточно потоков для поддержки параллелизма контейнера? - PullRequest
Новая
       16

Потребитель не смог начать в 60000 миллисекунд; у исполнителя задач достаточно потоков для поддержки параллелизма контейнера?

0 голосов
/ 05 февраля 2020

ошибка регистратора:

Потребитель не смог запуститься через 60000 миллисекунд; у исполнителя задач достаточно потоков для поддержки параллелизма контейнера?

Как я могу решить эту проблему?

Большое спасибо.

Я пытаюсь изменить свой конфиг например:

@ Конфигурация publi c class 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);
}

}

ошибка в том, что журнал также существует, и весенняя загрузка запускается медленно.

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 миллисекунд; у исполнителя задач достаточно потоков для поддержки параллелизма контейнера?

...