(create-nats-streaming cluster-name client-id & urls)
creates a Nats Streaming connection, returning a Nats object
creates a Nats Streaming connection, returning a Nats object - cluster-name : nats streaming cluster name - client-id : unique client id - urls : nats server urls, either a seq or comma separated
(publish nats subject-or-fn)
(publish nats subject-or-fn body)
(publish nats subject-or-fn body {:keys [reply] :as opts})
publish a message
publish a message - subject-or-fn : either a string specifying a fixed subject or a (fn [item] ...) which extracts a subject from an item
(publisher nats subject-or-fn)
returns a Manifold sink-only stream which publishes items put on the stream to NATS
returns a Manifold sink-only stream which publishes items put on the stream to NATS
(pubsub nats subject)
(pubsub nats subject opts)
returns a Manifold source+sink stream for a single NATS subject. the source returns INatsMessages, while the sink accepts strings
returns a Manifold source+sink stream for a single NATS subject. the source returns INatsMessages, while the sink accepts strings
(subscribe nats subject)
(subscribe nats subject opts)
returns a a Manifold source-only stream of INatsMessages from a NATS subject. close the stream to dispose of the subscription
returns a a Manifold source-only stream of INatsMessages from a NATS subject. close the stream to dispose of the subscription
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close