Persistent queue

Persistent queue are used to store mail and SMS message for further sending

class janua.utils.sqlite_queue.PersistentSqliteQueue(path, *args, **kwargs)[source]

A persistent sqlite queue

__init__(path, *args, **kwargs)[source]

Initialize the persistent queue

Parameters:path – path to sqlite database file

Mail queue

Mail queue accept mail object only (janua.utils.mail.MailObj):

from janua import mail_queue

mail_queue.put(mailobj)

Sms queue

Sms queue take a tuple containing:

  • message to send
  • recipient phone number
  • admin database object id which send the message
from janua import sms_queue

sms_queue.put((message, phone_number, admin_id))