On socket errors we always close the socket per amqp specification, however there is no need to do so if the connection has already been forcibly closed from the server side. This causes recursive loops when using SSL connections |
||
|---|---|---|
| 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.