kombu.transport.sqlalchemy

Kombu transport using SQLAlchemy as the message store.

Transport

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

class Channel(connection, **kwargs)

session

Transport.channel_errors = ()

Transport.connection_errors = ()

Transport.default_port = 0

Channel

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

session