nextChannelNumber is being incremented twice. When the counter wraps around it starts declaring already existing channels and the AMQP server disconnects the client. This patch doubles the number of channels that can be created before this happens. |
||
|---|---|---|
| src | ||
| tests | ||
| tutorials | ||
| .gitignore | ||
| .travis.yml | ||
| Doxyfile | ||
| LICENSE | ||
| README.md | ||
| qamqp.pri | ||
| qamqp.pro | ||
README.md
QAMQP
A Qt4/Qt5 implementation of AMQP 0.9.1, focusing primarily on RabbitMQ support.
Usage
Documentation
Coming soon!
AMQP Support
connection
| method | supported |
|---|---|
| connection.start | ✓ |
| connection.start-ok | ✓ |
| connection.secure | ✓ |
| connection.secure-ok | ✓ |
| connection.tune | ✓ |
| connection.tune-ok | ✓ |
| connection.open | ✓ |
| connection.open-ok | ✓ |
| connection.close | ✓ |
| connection.close-ok | ✓ |
channel
| method | supported |
|---|---|
| channel.open | ✓ |
| channel.open-ok | ✓ |
| channel.flow | ✓ |
| channel.flow-ok | ✓ |
| channel.close | ✓ |
| channel.close-ok | ✓ |
exchange
| method | supported |
|---|---|
| exchange.declare | ✓ |
| exchange.declare-ok | ✓ |
| exchange.delete | ✓ |
| exchange.delete-ok | ✓ |
queue
| method | supported |
|---|---|
| queue.declare | ✓ |
| queue.declare-ok | ✓ |
| queue.bind | ✓ |
| queue.bind-ok | ✓ |
| queue.unbind | ✓ |
| queue.unbind-ok | ✓ |
| queue.purge | ✓ |
| queue.purge-ok | ✓ |
| queue.delete | ✓ |
| queue.delete-ok | ✓ |
basic
| method | supported |
|---|---|
| basic.qos | ✓ |
| basic.consume | ✓ |
| basic.consume-ok | ✓ |
| basic.cancel | ✓ |
| basic.cancel-ok | ✓ |
| basic.publish | ✓ |
| basic.return | ✓ |
| basic.deliver | ✓ |
| basic.get | ✓ |
| basic.get-ok | ✓ |
| basic.get-empty | ✓ |
| basic.ack | ✓ |
| basic.reject | ✓ |
| basic.recover | ✓ |
tx
| method | supported |
|---|---|
| tx.select | X |
| tx.select-ok | X |
| tx.commit | X |
| tx.commit-ok | X |
| tx.rollback | X |
| tx.rollback-ok | X |
confirm
| method | supported |
|---|---|
| confirm.select | ✓ |
| confirm.select-ok | ✓ |
Credits
- Thank you to @fuCtor for the original implementation work.