pushme.mq package

Submodules

pushme.mq.backend_snakemq module

Очередь на базе snakeMQ. Подходит для использования на машинах разработчиков, т.к. является pure-python.

class pushme.mq.backend_snakemq.Queue(*args, **kwargs)

Базовые классы: pushme.mq.interface.Queue

Простой сервер очереди на ОДНОГО получателя и несколько отправителей

run()

class pushme.mq.backend_snakemq.Receiver(*args, **kwargs)

Базовые классы: pushme.mq.interface.Receiver

Простой получатель. В данной реализации очереди может быть ТОЛЬКО ОДИН получатель!

loop_timeout = 0.1

process()

class pushme.mq.backend_snakemq.Sender(*args, **kwargs)

Базовые классы: pushme.mq.interface.Sender

Простой отправитель.

loop_len = 2

loop_timeout = 0.02

msg_ttl = 500

send(data, uid=None, topic=None)

Отправляет сообщение получателю посредством очереди :uid :: int - id socket-соединения :topic - тема сообщения :data - данные для отправки

pushme.mq.interface module

Базовые классы для queue backends

class pushme.mq.interface.Queue(addr, quiet=False)

Базовые классы: object

Сервер очереди

run()

class pushme.mq.interface.Receiver(ident, queue_addr, quiet=False)

Базовые классы: pushme.mq.interface._Client

Клиент-получатель

static callback(uid, topic, data)

Умолчательный обработчик получения сообщений

process()

Производит получение сообщений (это callback для асинхронного ядра tornado)

class pushme.mq.interface.Sender(ident, queue_addr, quiet=False)

Базовые классы: pushme.mq.interface._Client

Клиент-отправитель

send(data, uid=None, topic=None)

Отправляет сообщение получателю посредством очереди :uid :: int - id socket-соединения :topic - тема сообщения :data - данные для отправки

Module contents

Очередь сообщений. Предоставляет единый интерфейс для различных реализаций очередей.

pushme.mq.get_queue(backend, *args, **kwargs)

Возвращает реализацию сервера очереди :backend - имя конкретной реализации очереди

pushme.mq.get_receiver(backend, *args, **kwargs)

Возвращает реализацию клиента - получателя сообщений :backend - имя конкретной реализации очереди

pushme.mq.get_sender(backend, *args, **kwargs)

Возвращает реализацию клиента - отправителя сообщений :backend - имя конкретной реализации очереди