This document describes the current stable version of Kombu (5.3). For development docs, go here.

SLMQ Transport - kombu.transport.SLMQ

SoftLayer Message Queue transport module for kombu.

Features

  • Type: Virtual

  • Supports Direct: Yes

  • Supports Topic: Yes

  • Supports Fanout: No

  • Supports Priority: No

  • Supports TTL: No

Connection String

Unreviewed

Transport Options

Unreviewed

Transport

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

SLMQ Transport.

class Channel(*args, **kwargs)

SLMQ Channel.

basic_ack(delivery_tag)

Acknowledge message.

basic_cancel(consumer_tag)

Cancel consumer by consumer tag.

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

Consume from 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})

Format AMQP queue name into a valid SLQS queue name.

property queue_name_prefix
property slmq
property transport_options
property visibility_timeout
connection_errors = (<class 'amqp.exceptions.ConnectionError'>, None, <class 'OSError'>)

Tuple of errors that can happen due to connection failure.

default_port = None

port number used when no port is specified.

polling_interval = 1

Time to sleep between unsuccessful polls.

Channel

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

SLMQ Channel.

basic_ack(delivery_tag)[source]

Acknowledge message.

basic_cancel(consumer_tag)[source]

Cancel consumer by consumer tag.

basic_consume(queue, no_ack, *args, **kwargs)[source]

Consume from queue.

property conninfo
default_visibility_timeout = 1800
delete_message(queue, message_id)[source]
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})[source]

Format AMQP queue name into a valid SLQS queue name.

property queue_name_prefix
property slmq
property transport_options
property visibility_timeout