This document is for Kombu's development version, which can be significantly different from previous releases. Get the stable docs here: 5.0.

SLMQ传输- kombu.transport.SLMQ

Kombu的SoftLayer消息队列传输模块。

功能

• 类型：虚拟

• 支持Direct：是

• 支持主题：是

• 支持扇出：否

• 支持优先级：否

• 支持TTL：否

连接字符串

Unreviewed

交通选择

Unreviewed

运输

class kombu.transport.SLMQ.Transport(client, **kwargs)

SLMQ传输。

class Channel(*args, **kwargs)

SLMQ频道。

basic_ack(delivery_tag)

确认消息。

basic_cancel(consumer_tag)

按消费者标签取消消费者。

basic_consume(queue, no_ack, *args, **kwargs)

消费来源： queue 。

property conninfo

default_visibility_timeout = 1800

delete_message(queue, message_id)

domain_format = 'kombu%(vhost)s'

entity_name(name, table={33: 95, 34: 95, 35: 95, 36: 95, 37: 95, 38: 95, 39: 95, 40: 95, 41: 95, 42: 95, 43: 95, 44: 95, 45: 95, 46: 95, 47: 95, 58: 95, 59: 95, 60: 95, 61: 95, 62: 95, 63: 95, 64: 95, 91: 95, 92: 95, 93: 95, 94: 95, 96: 95, 123: 95, 124: 95, 125: 95, 126: 95})

将AMQP队列名称格式化为有效的SLQS队列名称。

property queue_name_prefix

property slmq

property transport_options

property visibility_timeout

connection_errors = (<class 'amqp.exceptions.ConnectionError'>, None, <class 'OSError'>)

由于连接故障而可能发生的错误的元组。

default_port = None

未指定端口时使用的端口号。

polling_interval = 1

在不成功的民意调查之间睡觉的时间到了。

渠道

class kombu.transport.SLMQ.Channel(*args, **kwargs)

SLMQ频道。

basic_ack(delivery_tag)

确认消息。

basic_cancel(consumer_tag)

按消费者标签取消消费者。

basic_consume(queue, no_ack, *args, **kwargs)

消费来源： queue 。

property conninfo

default_visibility_timeout = 1800

delete_message(queue, message_id)

domain_format = 'kombu%(vhost)s'

entity_name(name, table={33: 95, 34: 95, 35: 95, 36: 95, 37: 95, 38: 95, 39: 95, 40: 95, 41: 95, 42: 95, 43: 95, 44: 95, 45: 95, 46: 95, 47: 95, 58: 95, 59: 95, 60: 95, 61: 95, 62: 95, 63: 95, 64: 95, 91: 95, 92: 95, 93: 95, 94: 95, 96: 95, 123: 95, 124: 95, 125: 95, 126: 95})

将AMQP队列名称格式化为有效的SLQS队列名称。

property queue_name_prefix

property slmq

property transport_options

property visibility_timeout