clj-nats-streaming-async.core — alexeypopov/clj-nats-streaming-async 0.0.9

create-nats-streaming clj

(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

create-nats-subscription-callback clj

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

INatsMessage clj protocol

msg-body clj

(msg-body _)

publisher clj

(publisher nats subject-or-fn)

returns a Manifold sink-only stream which publishes items put on the stream to NATS

pubsub clj

(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

subscriber clj

(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