diff --git a/Changes.md b/Changes.md
index 97d5fe450..078ceeaf5 100644
--- a/Changes.md
+++ b/Changes.md
@@ -14,6 +14,7 @@
 - avg: repackaged as NPM module #3347
 - bounce: repackaged plugin as NPM module #3341
 - connection: check remote is connected before queue #3338
+  - improve log message for queue* hooks, fixes #2998
   - support IPv6 when setting remote.is_private #3295
   - in setTLS, replace forEach with for...of
   - NOTE: remove a handful of 3.0 sunset property names #3315
diff --git a/connection.js b/connection.js
index 5f2c3c121..2b4cf446b 100644
--- a/connection.js
+++ b/connection.js
@@ -1701,7 +1701,12 @@ class Connection {
         });
     }
     queue_msg (retval, msg) {
-        if (msg) return msg;
+        if (msg) {
+            if (typeof msg === 'object' && msg.constructor.name === 'DSN') {
+                return msg.reply
+            }
+            return msg;
+        }
 
         switch (retval) {
             case constants.ok:
@@ -1737,7 +1742,7 @@ class Connection {
     }
     queue_outbound_respond (retval, msg) {
         if (this.remote.closed) return;
-        if (!msg) msg = this.queue_msg(retval, msg) || 'Message Queued';
+        msg = this.queue_msg(retval, msg) || 'Message Queued';
         this.store_queue_result(retval, msg);
         msg = `${msg} (${this.transaction.uuid})`;
         if (retval !== constants.ok) {
@@ -1813,7 +1818,7 @@ class Connection {
         }
     }
     queue_respond (retval, msg) {
-        if (!msg) msg = this.queue_msg(retval, msg);
+        msg = this.queue_msg(retval, msg);
         this.store_queue_result(retval, msg);
         msg = `${msg} (${this.transaction.uuid})`;