clj-nats-async.core — clj-nats-async 1.3.0-TESTREL-20180625-2

configure-global-message-delivery-thread-pool clj

(configure-global-message-delivery-thread-pool)

(configure-global-message-delivery-thread-pool pool-size)

configure the global-message-delivery-thread-pool, if not already configured

create-nats clj

(create-nats & urls)

creates a Nats connection, returning a Nats object. uses the global message delivery threadpool, and configures it with a default pool-size of 100 if it's not already configured

• urls : nats server urls, either a seq or comma separated

INatsMessage clj protocol

msg-body clj

(msg-body _)

publish clj

(publish nats subject-or-fn)

(publish nats subject-or-fn body)

(publish nats subject-or-fn body {:keys [reply] :as opts})

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

subscribe clj

(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