manual_ack.java

    private AtomicInteger counter = new AtomicInteger();

    @Incoming("from-aq")
    @Acknowledgment(Acknowledgment.Strategy.MANUAL)
    public CompletionStage<?> fromAq(AqMessage<String> msg) {
        System.out.println("Received: " + msg.getPayload());
        if (counter.getAndIncrement() == 5) {
            throw new RuntimeException("5th message exception!");
        }
        //Acknowledgement/commit is called after the business code
        return msg.ack();
    }