diff --git a/tokio-xmpp/src/stanzastream/connected.rs b/tokio-xmpp/src/stanzastream/connected.rs
index 0438a0e5bf77617f197f9664159fda162c52f5b1..48c384f3cc1c899bae4b5ed784217b6a6ec607da 100644
--- a/tokio-xmpp/src/stanzastream/connected.rs
+++ b/tokio-xmpp/src/stanzastream/connected.rs
@@ -260,6 +260,7 @@ impl ConnectedState {
             let next = next.take();
             match stream.as_mut().start_send(&next.stanza) {
                 Ok(()) => {
+                    next.token.send_replace(StanzaState::Sent {});
                     if let Some(sm_state) = sm_state.as_mut() {
                         sm_state.enqueue(next);
                     }