Spring-Integration: невозможно использовать из адаптера пользовательских сообщений с помощью IntegrationFlow - PullRequest
0 голосов
/ 20 сентября 2018

Я создал MessageAdapter, расширив MessageProducerSupport.Я создаю сообщение для выходного канала, вызывая MessageProducerSupport.sendMessage.Затем я определил IntegrationFlow для получения сообщений от адаптера сообщений и отправки его на канал.Но я не получаю никаких сообщений на канале.

Это моя конфигурация

 @Bean
  public MyAdapter myAdapter() {
    MyAdapter myAdapter = new MyAdapter();
    myAdapter.setOutputChannel(new QueueChannel());
    return myAdapter;
  }

  @Bean
  public IntegrationFlow integrationFlow() {

    return IntegrationFlows
        .from(myAdapter())
        .channel("myChannel")
        .get();
  }

и конечная точка сообщения для "myChannel":

@MessageEndpoint
public class MyConsumer {

  @ServiceActivator(inputChannel = "myChannel")
  public void parseMessage(Message message) {
    System.out.println(message.getPayload().toString());
  }

}

Есть личто-то мне не хватает для настройки?

Спасибо

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