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 builds & hosts documentation for Clojure/Script libraries
| Ctrl+k | Jump to recent docs |
| ← | Move to previous article |
| → | Move to next article |
| Ctrl+/ | Jump to the search field |