diff --git a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/AMQPLargeMessageWriter.java b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/AMQPLargeMessageWriter.java
index d6fccce451c..b2cffb483b7 100644
--- a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/AMQPLargeMessageWriter.java
+++ b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/AMQPLargeMessageWriter.java
@@ -166,7 +166,7 @@ public void writeBytes(MessageReference messageReference) {
     * Used to provide re-entry from the flow control executor when IO back-pressure has eased
     */
    private void resume() {
-      connection.runNow(this::tryDelivering);
+      connection.runLater(this::tryDelivering);
    }
 
    private void tryDelivering() {