diff --git a/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Send.java b/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Send.java
index e295a375d1..19dca52e5d 100644
--- a/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Send.java
+++ b/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Send.java
@@ -124,7 +124,9 @@ class Send implements StompCommand {
                 throw new ProtocolException(headers.getProperty(Stomp.Headers.TRANSACTION) + " is an invalid transaction id");
             msg.setTransactionId(tx_id);
         }
-
+        
+        msg.onSend();
+        
         return new CommandEnvelope(msg, headers);
     }