(add-filtered-tap this pred f)Adds a filtered (by pred) tap to the pipe. Filtered messages are processed by function f.
Starts the new handler immediately if the pipe is running. Use the returned pipe for subsequent lifecycle operations.
Adds a filtered (by `pred`) tap to the pipe. Filtered messages are processed by function `f`. Starts the new handler immediately if the pipe is running. Use the returned pipe for subsequent lifecycle operations.
(make-pipe)(make-pipe pred f)Creates a pipe with a built-in ActiveMQ listener.
If a predicate pred and a function f are provided, then also adds a filtered tap to it and starts the pipe.
Creates a pipe with a built-in ActiveMQ listener. If a predicate `pred` and a function `f` are provided, then also adds a filtered tap to it and starts the pipe.
(make-tap mult pred)Returns a filtered tap connected to the mult channel.
The tap is filtered by predicate pred.
Returns a filtered tap connected to the `mult` channel. The tap is filtered by predicate `pred`.
(remove-taps this)Stops the pipe if running, disconnects and closes its tap channels, and removes the taps. Discards queued messages on removed taps to release pending deliveries from the mult.
Stops the pipe if running, disconnects and closes its tap channels, and removes the taps. Discards queued messages on removed taps to release pending deliveries from the mult.
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 |