The zaqar.notification.notifier module

class MessageType

Bases: enum.IntEnum

Enum of message type.

Notification = 3

SubscriptionConfirmation = 1

UnsubscribeConfirmation = 2

class NotifierDriver(*args, **kwargs)

Bases: object

Notifier which is responsible for sending messages to subscribers.

post(queue_name, messages, client_uuid, project=None)

Send messages to the subscribers.

send_confirm_notification(queue, subscription, conf, project=None, expires=None, api_version=None, is_unsubscribed=False)