Пересылка сообщения в канал сообщений вручную - Spring Integration
Я могу успешно отправить сообщение, используя приведенное ниже из моего FirstHandler
messageChannel.send(MessageBuilder.withPayload(pa).build());
Но поток ожидает завершения обработчика2, связанного с messageChannel.
Я хотел бы просто переслать данные на канал и забыл, я попытался опубликовать-подписаться и направить канал, оба ждут завершения обработчика2
Ответы 1
Пожалуйста, узнайте, какие существуют типы реализации MessageChannel: https://docs.spring.io/spring-integration/docs/current/reference/html/core.html#channel-implementations
Это правильно, что DirectChannel просто вызывает MessageHandler в том же потоке отправки. По умолчанию PublishSubscribeChannel ведет себя так же.
Если вы хотите отправить-забыть, вам нужен MessageChannel, который переносит потребляющую задачу в другой поток. Для этого есть QueueChannel, ExecutorChannel и FluxMessageChannel.
Спасибо! Это сработало, реализовано с помощью ExecutorChannel.
Предоставьте достаточно кода, чтобы другие могли лучше понять или воспроизвести проблему.