Liking cljdoc? Tell your friends :D

clj-nats-streaming-async.core


create-nats-streamingclj

(create-nats-streaming cluster-name client-id & urls)

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
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
sourceraw docstring

create-nats-subscription-callbackclj

(create-nats-subscription-callback nats
                                   subject
                                   {:keys [queue durable-name max-in-flight]
                                    :as opts}
                                   cb)
source

INatsMessagecljprotocol

msg-bodyclj

(msg-body _)
source

publisherclj

(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
sourceraw docstring

pubsubclj

(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
sourceraw docstring

subscriberclj

(subscriber nats subject)
(subscriber 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
sourceraw docstring

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close