connection recovers just fine :D
Showing
- coolamqp/attaches/agroup.py 5 additions, 2 deletionscoolamqp/attaches/agroup.py
- coolamqp/attaches/channeler.py 2 additions, 0 deletionscoolamqp/attaches/channeler.py
- coolamqp/attaches/publisher.py 17 additions, 4 deletionscoolamqp/attaches/publisher.py
- coolamqp/attaches/utils.py 28 additions, 0 deletionscoolamqp/attaches/utils.py
- coolamqp/persistence/__init__.py 5 additions, 5 deletionscoolamqp/persistence/__init__.py
- coolamqp/uplink/connection/connection.py 34 additions, 6 deletionscoolamqp/uplink/connection/connection.py
- coolamqp/uplink/connection/watches.py 4 additions, 6 deletionscoolamqp/uplink/connection/watches.py
- coolamqp/uplink/heartbeat.py 0 additions, 3 deletionscoolamqp/uplink/heartbeat.py
- coolamqp/uplink/listener/epoll_listener.py 8 additions, 1 deletioncoolamqp/uplink/listener/epoll_listener.py
- coolamqp/uplink/listener/socket.py 7 additions, 0 deletionscoolamqp/uplink/listener/socket.py
- tests/run.py 1 addition, 0 deletionstests/run.py
Loading
Please register or sign in to comment