diff --git a/rosbridge_library/src/rosbridge_library/internal/subscription_modifiers.py b/rosbridge_library/src/rosbridge_library/internal/subscription_modifiers.py
index ac129c5c..f05231ed 100644
--- a/rosbridge_library/src/rosbridge_library/internal/subscription_modifiers.py
+++ b/rosbridge_library/src/rosbridge_library/internal/subscription_modifiers.py
@@ -163,6 +163,7 @@ def run(self):
                     traceback.print_exc(file=sys.stderr)
         while self.time_remaining() == 0 and len(self.queue) > 0:
             try:
-                MessageHandler.handle_message(self, self.queue[0])
+                msg = self.queue.popleft()
+                MessageHandler.handle_message(self, msg)
             except Exception:
                 traceback.print_exc(file=sys.stderr)