Consumer can receive a message
Showing
- coolamqp/attaches/__init__.py 10 additions, 0 deletionscoolamqp/attaches/__init__.py
- coolamqp/attaches/consumer.py 323 additions, 0 deletionscoolamqp/attaches/consumer.py
- coolamqp/framing/compilation/textcode_fields.py 4 additions, 0 deletionscoolamqp/framing/compilation/textcode_fields.py
- coolamqp/framing/definitions.py 8 additions, 7 deletionscoolamqp/framing/definitions.py
- coolamqp/uplink/__init__.py 1 addition, 1 deletioncoolamqp/uplink/__init__.py
- coolamqp/uplink/connection/__init__.py 2 additions, 1 deletioncoolamqp/uplink/connection/__init__.py
- coolamqp/uplink/connection/connection.py 46 additions, 4 deletionscoolamqp/uplink/connection/connection.py
- coolamqp/uplink/connection/watches.py 16 additions, 1 deletioncoolamqp/uplink/connection/watches.py
- coolamqp/uplink/handshake.py 2 additions, 1 deletioncoolamqp/uplink/handshake.py
- coolamqp/uplink/listener/epoll_listener.py 0 additions, 2 deletionscoolamqp/uplink/listener/epoll_listener.py
- setup.cfg 3 additions, 0 deletionssetup.cfg
- tests/run.py 9 additions, 2 deletionstests/run.py
Loading
Please register or sign in to comment