in mns/queue.py [0:0]
def __init__(self, vis_timeout=None, max_msg_size=None, msg_ttl=None,
delay_sec=None, polling_wait_sec=None, logging_enabled=None):
""" 队列属性
@note: 设置属性
:: visibility_timeout: message被receive后,持续不可消费的时间, 单位:秒
:: maximum_message_size: message body的最大长度, 单位:Byte
:: message_retention_period: message最长存活时间,单位:秒
:: delay_seconds: 新message可消费的默认延迟时间,单位:秒
:: polling_wait_seconds: receive message时,长轮询时间,单位:秒
:: logging_enabled: 是否开启logging功能,如果开启MNS将该队列的日志推送到Account的logging bucket中
@note: 非设置属性
:: active_messages: 可消费消息数,近似值
:: inactive_messages: 正在被消费的消息数,近似值
:: delay_messages: 延迟消息数,近似值
:: create_time: queue创建时间,单位:秒
:: last_modify_time: 修改queue属性的最近时间,单位:秒
:: queue_name: 队列名称
"""
self.visibility_timeout = QueueMeta.DEFAULT_VISIBILITY_TIMEOUT if vis_timeout is None else vis_timeout
self.maximum_message_size = QueueMeta.DEFAULT_MAXIMUM_MESSAGE_SIZE if max_msg_size is None else max_msg_size
self.message_retention_period = QueueMeta.DEFAULT_MESSAGE_RETENTION_PERIOD if msg_ttl is None else msg_ttl
self.delay_seconds = QueueMeta.DEFAULT_DELAY_SECONDS if delay_sec is None else delay_sec
self.polling_wait_seconds = QueueMeta.DEFAULT_POLLING_WAIT_SECONDS if polling_wait_sec is None else polling_wait_sec
self.logging_enabled = logging_enabled
self.active_messages = -1
self.inactive_messages = -1
self.delay_messages = -1
self.create_time = -1
self.last_modify_time = -1
self.queue_name = ""