nats.stream — no.cjohansen/clj-nats 0.2025.02.21

compression-options clj

Available compression options

• :nats.compression-option/none
• :nats.compression-option/s2

configure clj

(configure conn jet-stream-options)

Re-configure the JetStream management instance. Returns a new conn with the new configuration, does not change the original conn.

jet-stream-options is a map of:

• :nats.stream/domain
• :nats.stream/opt-out-290-consumer-create?
• :nats.stream/prefix
• :nats.stream/publish-no-ack?
• :nats.stream/request-timeout

create-stream clj

(create-stream conn config)

Adds a stream. config is a map of the following keys:

• :nats.stream/name
• :nats.stream/description
• :nats.stream/subjects
• :nats.stream/retention-policy
• :nats.stream/allow-direct?
• :nats.stream/allow-rollup?
• :nats.stream/deny-delete?
• :nats.stream/deny-purge?
• :nats.stream/max-age
• :nats.stream/max-bytes
• :nats.stream/max-consumers
• :nats.stream/max-messages
• :nats.stream/max-messages-per-subject
• :nats.stream/max-msg-size
• :nats.stream/replicas

delete-message clj

(delete-message conn stream-name seq-n & [{:keys [erase?] :as opt}])

Delete the specific message from stream-name with seq-n.

delete-stream clj

(delete-stream conn stream-name)

discard-policies clj

Available discard policies:

• :nats.discard-policy/new
• :nats.discard-policy/old

get-account-statistics clj

(get-account-statistics conn)

get-cluster-info clj

(get-cluster-info conn stream-name & [options])

get-first-message clj

(get-first-message conn stream-name subject)

get-last-message clj

(get-last-message conn stream-name subject)

get-message clj

(get-message conn stream-name seq)

get-mirror-info clj

(get-mirror-info conn stream-name & [opts])

Get the mirror info for stream-name. opts is a map of:

• :include-deleted-details?
• :filter-subjects

get-next-message clj

(get-next-message conn stream-name seq subject)

get-stream-config clj

(get-stream-config conn stream-name & [opts])

Get the configuration for stream-name. opts is a map of:

• :include-deleted-details?
• :filter-subjects

get-stream-info clj

(get-stream-info conn stream-name & [opts])

Get the information about stream-name. opts is a map of:

• :include-deleted-details?
• :filter-subjects

get-stream-names clj

(get-stream-names conn & [{:keys [subject-filter]}])

get-stream-state clj

(get-stream-state conn stream-name & [opts])

Get the state for stream-name. opts is a map of:

• :include-deleted-details?
• :filter-subjects

get-streams clj

(get-streams conn & [{:keys [subject-filter]}])

publish clj

(publish conn message & [opts])

Publish a message to a JetStream subject. Performs publish acking if the stream requires it. Use nats.core/publish for regular PubSub messaging.

message is a map of:

• :nats.message/subject - The subject to publish to
• :nats.message/data - The message data. Can be any Clojure value
• :nats.message/headers - An optional map of string keys to string (or collection of string) values to set as meta-data on the message.
• :nats.message/reply-to - An optional reply-to subject.

opts is a map of:

• :expected-last-msg-id
• :expected-last-sequence
• :expected-last-subject-sequence
• :expected-stream
• :message-id
• :stream
• :stream-timeout

purge-stream clj

(purge-stream conn stream-name & [opts])

Purge stream stream-name. opts is a map of:

• :keep
• :sequence
• :subject

retention-policies clj

Available retention policies:

• :nats.retention-policy/limits
• :nats.retention-policy/work-queue
• :nats.retention-policy/interest

storage-types clj

Available storage types

• :nats.storage-type/file
• :nats.storage-type/memory

update-stream clj

(update-stream conn config)

Updates a stream. See create-stream for valid options in config.