veritas.messagebus.database

Module Contents

Classes

Database

class veritas.messagebus.database.Database(app=None, uuid=None, database=None, use_queue=False)

write(message)

write record either to queue or to database

_message_to_database(message)

_connect_to_db()

connet to database

_dequeue(queue)

_empty_queue()