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.