AMQP Procotol SupportΒΆ
asynqp is under development.
Here is a table documenting the parts of the AMQP protocol
that are currently supported by asynqp.
Note
This library is alpha software. Even the methods marked as ‘full support’ may still have bugs. Please report any bugs to the Github tracker.
| Class | Method | Support | API | Notes |
|---|---|---|---|---|
| connection | partial | asynqp.Connection |
||
| start/start-ok | full | asynqp.connect |
||
| secure/secure-ok | none | Not required for default auth mechanism | ||
| tune/tune-ok | partial | Not presently user-customisable | ||
| open/open-ok | full | asynqp.connect |
||
| close/close-ok | full | asynqp.Connection.close |
||
| channel | partial | asynqp.Channel |
||
| open/open-ok | full | asynqp.Connection.open_channel |
||
| flow/flow-ok | none | |||
| close/close-ok | full | asynqp.Channel.close |
||
| exchange | partial | asynqp.Exchange |
||
| declare/declare-ok | full | asynqp.Channel.declare_exchange |
||
| delete/delete-ok | full | asynqp.Exchange.delete |
||
| bind/bind-ok | none | RabbitMQ extension | ||
| unbind/unbind-ok | none | RabbitMQ extension | ||
| queue | partial | asynqp.Queue |
||
| declare/declare-ok | full | asynqp.Channel.declare_queue |
||
| bind/bind-ok | partial | asynqp.Queue.bind |
Not all parameters presently supported | |
| unbind/unbind-ok | full | asynqp.QueueBinding.unbind |
||
| purge/purge-ok | partial | asynqp.Queue.purge |
no-wait not presently supported |
|
| delete/delete-ok | partial | asynqp.Queue.delete |
no-wait not presently supported |
|
| basic | partial | |||
| qos/qos-ok | full | asynqp.Channel.set_qos |
||
| consume/consume-ok | partial | asynqp.Queue.consume |
Not all parameters presently supported | |
| cancel/cancel-ok | partial | asynqp.Consumer.cancel |
no-wait not presently supported |
|
| publish | partial | asynqp.Exchange.publish |
immediate not presently supported |
|
| return | full | asynqp.Channel.set_return_handler |
||
| deliver | full | |||
| get/get-ok/get-empty | full | asynqp.Queue.get |
||
| ack | full | asynqp.IncomingMessage.ack |
||
| reject | full | asynqp.IncomingMessage.reject |
||
| recover/recover-ok | none | |||
| recover-async | none | |||
| nack | none | RabbitMQ extension | ||
| tx | none | |||
| select/select-ok | none | |||
| commit/commit-ok | none | |||
| rollback/rollback-ok | none | |||
| confirm | none | |||
| select/select-ok | none |