ripley.integration.redis — io.github.tatut/ripley 2024-04-03.285

Integrate Redis publish/subscribe to ripley source

pubsub-listener-source clj

(pubsub-listener-source channels)

(pubsub-listener-source {:keys [conn parse-message]
                         :or {conn {} parse-message default-parse-message}}
                        channels)

Create a source that listens to one or more channels. Channels can be a string (one channel name) or a collection of strings (multiple channels)

Opts can have the following options :conn connection spec for Carmine redis client :parse-message function to parse message into a source value takes 2 arguments: channel name and message payload string by default just returns payload.