kombu.transport.sqlalchemy

Kombu transport using SQLAlchemy as the message store.

Transport

class kombu.transport.sqlalchemy.Transport(client, **kwargs)
class Channel(connection, **kwargs)
message_cls
queue_cls
session
Transport.can_parse_url = True
Transport.connection_errors = (<class 'sqlalchemy.exc.OperationalError'>,)
Transport.default_port = 0
Transport.driver_name = 'sqlalchemy'
Transport.driver_type = 'sql'
Transport.driver_version()

Channel

class kombu.transport.sqlalchemy.Channel(connection, **kwargs)
message_cls
queue_cls
session

Table Of Contents

Previous topic

Django Management - clean_kombu_messages

Next topic

Models

This Page