Весенние каналы DSL - PullRequest
Новая
       13

Весенние каналы DSL

0 голосов
/ 12 марта 2019

У меня следующий поток: 

 return IntegrationFlows.from(inputChannel())
        .filter(this)
        .channel(rerouteChannel())
        .transform(Transformers.fromJson(this))
        .handle(this)
        .get();

Я довольно новичок в весенней интеграции, но здесь я пытаюсь отфильтровать свое сообщение, отправить его в "rerouteChannel", затем преобразовать его и обработать, а также другой мой поток, который имеет вход "rerouteChannel" обрабатывать одно и то же сообщение.

Сначала я использовал прямой канал для rerouteChannel, который в конечном итоге отправлял сообщение в канал при вызове и не обрабатывал сообщение в этом потоке, или обрабатывал сообщение и не отправлял его в другой поток. Это случилось 1/2 раза.

Я пытался понять, пока это происходит, читая документацию на весеннем сайте, но я все еще в замешательстве. Если я использую PublishSubscribe, он работает, как я ожидал, но я не уверен, какой канал подходит для моего случая, и какой мне следует использовать.

Спасибо

...