messaging-article-1

ma1.java

@Outgoing("publisher-payload")
public PublisherBuilder<Integer> streamOfMessages() {
   return ReactiveStreams.of(1, 2, 3);
}

@Incoming("publisher-payload")
@Outgoing("wrapped-message")
public Message<String> rewrapMessageManually(Message<Integer> message) {
   return Message.of(Integer.toString(message.getPayload()));
}

@Incoming("wrapped-message")
public void consumeImplicitlyUnwrappedMessage(String value) {
   System.out.println("Consuming message: " + value);
}

> Consuming message: 1
> Consuming message: 2
> Consuming message: 3