lupapiste-pubsub.protocol

Liking cljdoc? Tell your friends :D

Clojure only.

MessageQueueClient

MessageQueueClient^cljprotocol

get-publisher^clj

(get-publisher this topic-name)

Get or create the Publisher for the given topic name.

Get or create the Publisher for the given topic name.

halt^clj

(halt this)

Shutdown all publishers and subscribers associated with this client.

Shutdown all publishers and subscribers associated with this client.

publish^clj

(publish this topic-name message)

Publish a message to the topic, which will be created if necessary. Message should be Clojure map.

Publish a message to the topic, which will be created if necessary. Message should be Clojure map.

remove-subscription^clj

(remove-subscription this topic-name)

Shuts down subscriber and removes subscription. Messages in the subscription will be lost.

Shuts down subscriber and removes subscription. Messages in the subscription will be lost.

stop-subscriber^clj

(stop-subscriber this topic-name)

Stops subscriber.

Stops subscriber.

subscribe^clj

(subscribe this topic-name handler)

(subscribe this topic-name handler additional-config)

Subscribe to the topic, which will be created if necessary. The decoded message map will be passed to handler. Handler must return a truthy value for the message to be ACKed from the queue. Returning a falsy value results in a NACK and the message will be redelivered. additional-config will be merged into the general subscriber config

Subscribe to the topic, which will be created if necessary. The decoded message map will be passed to `handler`.
Handler must return a truthy value for the message to be ACKed from the queue.
Returning a falsy value results in a NACK and the message will be redelivered.
`additional-config` will be merged into the general subscriber config

source