fixed #16

coolamqp/uplink/connection/connection.py

@@ -253,7 +253,7 @@ class Connection(object):
             #todo why is that necessary? it doesnt pass travis CI if there's no this block
             self.listener_socket.oneshot(delay, callback)
         except AttributeError:
-            print(dir(self))
+            pass #print(dir(self))
 
     def unwatch_all(self, channel_id):
         """

coolamqp/uplink/listener/epoll_listener.py

@@ -90,7 +90,7 @@ class EpollListener(object):
                     if sock.on_write():
                         # I'm done with sending for now
                         assert len(sock.data_to_send) == 0 and len(sock.priority_queue) == 0
-                        self.epoll.modify(sock.fileno(), RW)
+                        self.epoll.modify(sock.fileno(), RO)
 
             except SocketFailed:
                 self.epoll.unregister(fd)

tests/run.py

@@ -25,7 +25,6 @@ if __name__ == '__main__':
     except AMQPError:
         print(':)')
 
-    while True:
-        time.sleep(30)
+    time.sleep(30)
 
     amqp.shutdown(True)