pika/pika — Issue #118: Channel.basic_publish() does not publish messages until after the connection closes
Author: invisibleroads
Created: 2012-01-10 05:01:14+00:00
State: open

In pika 0.9.6-pre0, I am noticing that Channel.basic_publish() does not publish messages until after the connection closes.

I looked in connection.py and noticed that Connection._send_frame() contains a call to Connection._flush_outbound() in pika 0.9.5, but this call to Connection._flush_outbound() is commented out in pika 0.9.6-pre0. Why is Connection._flush_outbound() commented out?

```
class Connection(object):

def _send_frame(self, frame):
marshalled_frame = frame.marshal()
self.bytes_sent += len(marshalled_frame)
self.frames_sent += 1

#pika.frame.log_frame(frame.name, marshalled_frame)
self.outbound_buffer.write(marshalled_frame)
#self._flush_outbound() <== WHY IS THIS COMMENTED OUT??
self._detect_backpressure()
```