progames.modules.plaintext_mq package

Submodules

progames.modules.plaintext_mq.abc module

class progames.modules.plaintext_mq.abc.Subscriber

Bases: object

receive(*args, **kwargs)

progames.modules.plaintext_mq.core module

class progames.modules.plaintext_mq.core.Broker

Bases: object

broadcast(message)

static deliver(receiver, message)

static get_instance()

static hash(obj)

hash stuffs

publish(channel, message)

subscribe(channel: str, subscriber)

unsubscribe(channel, subscriber)

progames.modules.plaintext_mq.core.broadcast(message)

progames.modules.plaintext_mq.core.publish(channel, message)

progames.modules.plaintext_mq.core.subscribe(channel, subscriber)

progames.modules.plaintext_mq.core.unsubscribe(channel, subscriber)

Module contents