diff --git a/src/cas/generic/casDGClient.cc b/src/cas/generic/casDGClient.cc
index 1c1cd5d3b..e18af2771 100644
--- a/src/cas/generic/casDGClient.cc
+++ b/src/cas/generic/casDGClient.cc
@@ -831,6 +831,7 @@ caStatus casDGClient::processMsg ()
             }
 		    status = ( this->*pHandler ) ();
 		    if ( status ) {
+                this->in.removeMsg ( this->in.bytesPresent() );
 			    break;
 		    }