snakemq_pubsub Package¶

`snakemq_pubsub` Package¶

An implementation of the publish-subscribe pattern for snakeMQ.

copyright:	(c) 2015 by Nicholas Repole and contributors. See AUTHORS for more details.
license:	MIT - See LICENSE for more details.

class snakemq_pubsub.__init__.Broker(host, port, identity)[source]¶

A snakeMQ Pub/Sub broker.

link_on_disconnect(conn)[source]¶: Remove any remaining subscriptions on disconnect.

on_recv(conn, ident, message)[source]¶: Handle PUBLISH, SUBSCRIBE, and UNSUBSCRIBE commands.

class snakemq_pubsub.__init__.BrokerClient(broker_host, broker_port, broker_identity, identity)[source]¶

Client connection to a broker server.

Publisher and Subscriber inherit from this class.

class snakemq_pubsub.__init__.MQConnectorMixin(identity)[source]¶

One end of a snakeMQ connection.

Broker, Subscriber, and Publisher all inherit from this class.

messenger_on_connect(conn, ident)[source]¶: Log any new messenger connections.

messenger_on_disconnect(conn, ident)[source]¶: Log any new new messenger disconnections.

on_recv(conn, ident, message)[source]¶

Handle an incoming message.

Will typically be overriden by an inheriting class.

run(runtime=None)[source]¶: Run the snakeMQ stack and listen for messages.

class snakemq_pubsub.__init__.Publisher(broker_host, broker_port, broker_identity, identity)[source]¶

Manages publishing messages to a message broker.

publish(channel, message)[source]¶: Publish a message on the supplied channel.

class snakemq_pubsub.__init__.Subscriber(broker_host, broker_port, broker_identity, identity, on_recv)[source]¶

A snakeMQ Pub/Sub subscriber.

messenger_on_connect(conn, ident)[source]¶: Resubscribe to any prior subscriptions.

on_recv(conn, ident, message)[source]¶: Forward a received message to the prior provided callback.