ma7.java

@Outgoing("test-channel")
public Publisher<Message<String>> produceMessage() {
   return ReactiveStreams.of(Message.of("test-data", () -> {
       System.out.println("Message acked!");
       return CompletableFuture.completedStage(null);
   })).buildRs();
}

@Incoming("test-channel")
@Acknowledgment(Acknowledgment.Strategy.POST_PROCESSING)
public void receiveMessage(String msg) {
   System.out.println("Received payload:" + msg);
}

> Received payload: test-data
> Message acked!