ARTEMIS-3815 proper retry through IOCompletion when message not found on target queue...
authoriliya <iliya.gr@gmail.com>
Thu, 30 Jun 2022 18:40:46 +0000 (14:40 -0400)
committerclebertsuconic <clebert.suconic@gmail.com>
Thu, 30 Jun 2022 21:37:27 +0000 (17:37 -0400)
commitd90179b99cc217a2611a7d439ddcc9a27d79dd12
tree3da2e3121040a007597e61258bb8138d379416a6
parent2f361b1d4075a6ef79716bc630b43bde2cbed418
ARTEMIS-3815 proper retry through IOCompletion when message not found on target queue on Mirror

co-authored Clebert Suconic
artemis-journal/src/main/java/org/apache/activemq/artemis/core/io/RunnableCallback.java [new file with mode: 0644]
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPSessionCallback.java
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/mirror/AMQPMirrorControllerTarget.java
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/connect/AMQPMirrorFastACKTest.java [new file with mode: 0644]