can receive and ack a bunch of messages
Showing
- coolamqp/attaches/consumer.py 80 additions, 10 deletionscoolamqp/attaches/consumer.py
- coolamqp/framing/base.py 10 additions, 10 deletionscoolamqp/framing/base.py
- coolamqp/framing/compilation/compile_definitions.py 2 additions, 2 deletionscoolamqp/framing/compilation/compile_definitions.py
- coolamqp/framing/compilation/textcode_fields.py 27 additions, 10 deletionscoolamqp/framing/compilation/textcode_fields.py
- coolamqp/framing/definitions.py 34 additions, 19 deletionscoolamqp/framing/definitions.py
- coolamqp/messages.py 15 additions, 26 deletionscoolamqp/messages.py
- coolamqp/uplink/__init__.py 1 addition, 1 deletioncoolamqp/uplink/__init__.py
- coolamqp/uplink/connection/__init__.py 1 addition, 1 deletioncoolamqp/uplink/connection/__init__.py
- coolamqp/uplink/connection/connection.py 38 additions, 13 deletionscoolamqp/uplink/connection/connection.py
- coolamqp/uplink/connection/send_framer.py 5 additions, 3 deletionscoolamqp/uplink/connection/send_framer.py
- coolamqp/uplink/connection/watches.py 24 additions, 16 deletionscoolamqp/uplink/connection/watches.py
- coolamqp/uplink/heartbeat.py 23 additions, 5 deletionscoolamqp/uplink/heartbeat.py
- coolamqp/uplink/listener/epoll_listener.py 25 additions, 20 deletionscoolamqp/uplink/listener/epoll_listener.py
- coolamqp/uplink/listener/socket.py 26 additions, 11 deletionscoolamqp/uplink/listener/socket.py
- tests/run.py 2 additions, 3 deletionstests/run.py
Loading
Please register or sign in to comment