Абонент Spring интеграции с pub-sub каналом и исполнителем задач не получает сообщение - PullRequest
0 голосов
/ 27 сентября 2019

Когда я запускаю поток ниже, первый поток запускается и выдает ошибку в потоке подписчика.Я перезапустил поток, подписчик не получил сообщение.Я вижу журнал "postSend" на канале подписчика ниже.Что может быть причиной?

IntegrationFlows
                .from(Http.inboundChannelAdapter("/input")
                        .requestMapping(m -> m.methods(HttpMethod.POST))
                        .requestPayloadType(String.class)
                        .errorChannel("errorChannel")
                        .replyTimeout(5000)
                        .statusCodeFunction(m -> HttpStatus.OK))
                .log(LoggingHandler.Level.INFO)
                .channel(pubSubChannel())

@Bean
    public PublishSubscribeChannel pubSubChannel() {
        return MessageChannels.publishSubscribe("pubSubChannel", taskExecutor()).applySequence(true)
                .get();

}
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...