Integrate Redis publish/subscribe to ripley source
Integrate Redis publish/subscribe to ripley source
(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.
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.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close