Когда я запускаю поток ниже, первый поток запускается и выдает ошибку в потоке подписчика.Я перезапустил поток, подписчик не получил сообщение.Я вижу журнал "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();
}