diff --git a/src/pcas/generic/casDGClient.cc b/src/pcas/generic/casDGClient.cc
index 4cc05be32..fdee8c2ac 100644
--- a/src/pcas/generic/casDGClient.cc
+++ b/src/pcas/generic/casDGClient.cc
@@ -665,6 +665,10 @@ caStatus casDGClient::processDG ()
         if ( status != S_cas_success ) {
             break;
         }
+
+        if ( this->in.bytesPresent () > 0 && dgInBytesConsumed == 0 ) {
+            this->in.removeMsg ( this->in.bytesPresent() );
+        }
     }
     return status;
 }