kombu.transport.sqlalchemy
Kombu transport using SQLAlchemy as the message store.
-
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()
-
class kombu.transport.sqlalchemy.Channel(connection, **kwargs)
-
message_cls
-
queue_cls
-
session