poiesis.core.adaptors.message_broker package¶

Submodules¶

poiesis.core.adaptors.message_broker.redis_adaptor module¶

Redis message broker adaptor.

class poiesis.core.adaptors.message_broker.redis_adaptor.RedisMessageBroker[source]¶

Bases: MessageBroker

Redis message broker.

redis¶: The Redis client

pubsub¶: The Redis pubsub client

close()[source]¶

Close the message broker.

Return type:: None

publish(channel, message)[source]¶

Publish a message to a channel.

Parameters:

channel (str) – The channel/topic to publish to
message (Message) – The message to publish

Return type:

None

subscribe(channel)[source]¶

Subscribe to a channel.

Parameters:: channel (str) – The channel/topic to subscribe to
Return type:: Iterator[Message]
Returns:: An async iterator of messages

Module contents¶

Adaptor for message brokers.