pikachewie.publisher – PikaChewie base publisher class¶
-
class
pikachewie.publisher.
BlockingPublisher
(broker)¶ Base class for synchronous RabbitMQ publishers.
-
channel
¶ Return an open channel to the RabbitMQ broker.
If necessary, create and cache a new channel.
-
-
class
pikachewie.publisher.
JSONPublisherMixin
¶ Publisher Mixin that JSON-serializes the message payload.
-
publish
(exchange, routing_key, payload, properties=None)¶ Publish a message to RabbitMQ on the same channel the original message was received on, automatically serializing the message payload.
Parameters:
-
-
class
pikachewie.publisher.
PublisherMixin
¶ Mixin for publishing messages to RabbitMQ.
-
publish
(exchange, routing_key, body, properties=None)¶ Publish a message to RabbitMQ.
properties should be an instance of pikachewie.data.Properties or None.
Parameters: - exchange (str) – the exchange to publish to
- routing_key (str) – the routing key to publish with
- body (str|unicode) – the message body to publish
- properties (pikachewie.data.Properties) – the message properties
-