diff --git a/r2dbc-mysql/src/main/java/io/asyncer/r2dbc/mysql/client/ReactorNettyClient.java b/r2dbc-mysql/src/main/java/io/asyncer/r2dbc/mysql/client/ReactorNettyClient.java
index 961b2806..8e926f21 100644
--- a/r2dbc-mysql/src/main/java/io/asyncer/r2dbc/mysql/client/ReactorNettyClient.java
+++ b/r2dbc-mysql/src/main/java/io/asyncer/r2dbc/mysql/client/ReactorNettyClient.java
@@ -131,6 +131,14 @@ final class ReactorNettyClient implements Client {
                     logger.debug("Request: {}", message);
                 }
 
+                if (message == ExitMessage.INSTANCE) {
+                    if (STATE_UPDATER.compareAndSet(this, ST_CONNECTED, ST_CLOSING)) {
+                        logger.debug("Exit message sent");
+                    } else {
+                        logger.debug("Exit message sent (duplicated / connection already closed)");
+                    }
+                }
+
                 if (message.isSequenceReset()) {
                     resetSequence(connection);
                 }
@@ -213,15 +221,8 @@ public Mono<Void> close() {
 
             requestQueue.submit(RequestTask.wrap(sink, Mono.fromRunnable(() -> {
                 Sinks.EmitResult result = requests.tryEmitNext(ExitMessage.INSTANCE);
-
                 if (result != Sinks.EmitResult.OK) {
                     logger.error("Exit message sending failed due to {}, force closing", result);
-                } else {
-                    if (STATE_UPDATER.compareAndSet(this, ST_CONNECTED, ST_CLOSING)) {
-                        logger.debug("Exit message sent");
-                    } else {
-                        logger.debug("Exit message sent (duplicated / connection already closed)");
-                    }
                 }
             })));
         }).flatMap(Function.identity()).onErrorResume(e -> {