diff --git a/libraries/networking/src/udt/Connection.cpp b/libraries/networking/src/udt/Connection.cpp
index e0943a63f8..f1b69e0039 100644
--- a/libraries/networking/src/udt/Connection.cpp
+++ b/libraries/networking/src/udt/Connection.cpp
@@ -650,8 +650,6 @@ void Connection::processTimeoutNAK(std::unique_ptr<ControlPacket> controlPacket)
 }
 
 void Connection::resetReceiveState() {
-    // TODO: this should also reset any queued messages we might be processing
-    
     // reset all SequenceNumber member variables back to default
     SequenceNumber defaultSequenceNumber;
     
@@ -680,6 +678,9 @@ void Connection::resetReceiveState() {
     
     // clear the intervals in the receive window
     _receiveWindow.reset();
+    
+    // clear any pending received messages
+    _pendingReceivedMessages.clear();
 }
 
 void Connection::updateRTT(int rtt) {