This document is for Kombu's development version, which can be significantly different from previous releases. Get the stable docs here: 5.0.
传输基类- kombu.transport.base
¶
基本传输接口。
消息¶
- class kombu.transport.base.Message(body=None, delivery_tag=None, content_type=None, content_encoding=None, delivery_info=None, properties=None, headers=None, postencode=None, accept=None, channel=None, **kwargs)[源代码]¶
已接收消息的基类。
关键字参数:¶
- Channel(Channel):如果收到消息,这应该是
接收消息的通道。
Body(Str):消息正文。
- DELIVERY_MODE(Bool):设置自定义交付模式。
默认为
delivery_mode
。- 优先级(Int):消息优先级,0为已配置的代理
最大优先级,越高越好。
- Content_type(Str):消息内容_类型。如果为Content_Type
则不会发生序列化,因为假定这是一个二进制对象,或者您已经完成了自己的序列化。如果使用内置序列化,则保留为空,因为我们的库正确设置了CONTENT_TYPE。
- CONTENT_ENCODING(Str):该对象所在的字符集
是经过编码的。如果发送原始二进制对象,请使用“二进制”。如果使用内置序列化,因为我们的库正确设置了CONTENT_ENCODING,则将其留空。
属性(Dict):消息属性。
Headers(Dict):消息标头。
- payload¶
解码后的消息正文。
- channel¶
- delivery_tag¶
- content_type¶
- content_encoding¶
- delivery_info¶
- headers¶
- properties¶
- body¶
- acknowledged¶
如果消息已被确认,则设置为True。
- ack(multiple=False)[源代码]¶
确认此消息正在处理中。
这将从队列中删除该消息。
- 抛出:
MessageStateError -- 如果消息已经:已确认/已重新排队/已拒绝。
- reject(requeue=False)[源代码]¶
拒绝此邮件。
该消息将被服务器丢弃。
- 抛出:
MessageStateError -- 如果消息已经:已确认/已重新排队/已拒绝。
运输¶
- class kombu.transport.base.Transport(client, **kwargs)[源代码]¶
传输的基类。
- client = None¶
这个
Connection
拥有这个实例。
- default_port = None¶
未指定端口时使用的默认端口。
- recoverable_connection_errors¶
可以从中恢复但必须首先关闭并重新建立连接的与连接相关的异常的可选列表。
如果未定义,则全部
connection_errors
和channel_errors
将被视为可恢复,但需要先关闭连接。
- recoverable_channel_errors¶
无需重新建立连接即可自动恢复的与通道相关的异常的可选列表。
- connection_errors = (<class 'amqp.exceptions.ConnectionError'>,)¶
由于连接故障而可能发生的错误的元组。
- channel_errors = (<class 'amqp.exceptions.ChannelError'>,)¶
由于通道/方法故障而可能发生的错误元组。