Я создал 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());
}
}
Есть личто-то мне не хватает для настройки?
Спасибо