nameko.amqp

Submodules

• nameko.amqp.publish

Exceptions

UndeliverableMessage

当启用了发布者确认并且消息无法路由或持久存储时抛出的异常。

Functions

get_connection(amqp_uri[, ssl, login_method, ...])
get_producer(amqp_uri[, confirms, ssl, login_method, ...])

Package Contents

exception nameko.amqp.UndeliverableMessage

Bases: Exception

当启用了发布者确认并且消息无法路由或持久存储时抛出的异常。

Initialize self. See help(type(self)) for accurate signature.

nameko.amqp.get_connection(amqp_uri, ssl=None, login_method=None, transport_options=None)

nameko.amqp.get_producer(amqp_uri, confirms=True, ssl=None, login_method=None, transport_options=None)