a useful appliance for consumer/publisher.
a class that allows tracking delivery tags in AMQP-compliant way
Showing
- .gitignore 1 addition, 1 deletion.gitignore
- README.md 5 additions, 0 deletionsREADME.md
- coolamqp/attaches/__init__.py 2 additions, 1 deletioncoolamqp/attaches/__init__.py
- coolamqp/attaches/channeler.py 177 additions, 0 deletionscoolamqp/attaches/channeler.py
- coolamqp/attaches/consumer.py 40 additions, 134 deletionscoolamqp/attaches/consumer.py
- coolamqp/attaches/publisher.py 146 additions, 0 deletionscoolamqp/attaches/publisher.py
- coolamqp/attaches/utils.py 209 additions, 0 deletionscoolamqp/attaches/utils.py
- coolamqp/backends/__init__.py 4 additions, 1 deletioncoolamqp/backends/__init__.py
- coolamqp/backends/base.py 0 additions, 4 deletionscoolamqp/backends/base.py
- coolamqp/backends/coolamqp.py 114 additions, 0 deletionscoolamqp/backends/coolamqp.py
- coolamqp/cluster.py 0 additions, 240 deletionscoolamqp/cluster.py
- coolamqp/connection/definition.py 36 additions, 17 deletionscoolamqp/connection/definition.py
- coolamqp/handler.py 0 additions, 294 deletionscoolamqp/handler.py
- coolamqp/messages.py 7 additions, 12 deletionscoolamqp/messages.py
- coolamqp/uplink/__init__.py 1 addition, 0 deletionscoolamqp/uplink/__init__.py
- coolamqp/uplink/handshake.py 8 additions, 4 deletionscoolamqp/uplink/handshake.py
- coolamqp/uplink/listener/__init__.py 0 additions, 1 deletioncoolamqp/uplink/listener/__init__.py
- tests/run.py 8 additions, 2 deletionstests/run.py
- tests/test_attaches/__init__.py 8 additions, 0 deletionstests/test_attaches/__init__.py
- tests/test_attaches/test_utils.py 62 additions, 0 deletionstests/test_attaches/test_utils.py
Loading
Please register or sign in to comment