experimental work around for recursion issue.

pika · Feb 11, 2014 · f73c141 · f73c141
1 parent a623f69
commit f73c141
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/pika/adapters/blocking_connection.py b/pika/adapters/blocking_connection.py
@@ -18,6 +18,7 @@
 import errno
 from functools import wraps
 
+from pika import frame
 from pika import callback
 from pika import channel
 from pika import exceptions
@@ -405,9 +406,10 @@ def _send_frame(self, frame_value):
         """
         super(BlockingConnection, self)._send_frame(frame_value)
         self._frames_written_without_read += 1
-        if self._frames_written_without_read == self.WRITE_TO_READ_RATIO:
-            self._frames_written_without_read = 0
-            self.process_data_events()
+        if self._frames_written_without_read >= self.WRITE_TO_READ_RATIO:
+            if not isinstance(frame_value, frame.Method):
+                self._frames_written_without_read = 0
+                self.process_data_events()
 
 
 class BlockingChannel(channel.Channel):