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 |