cider-ci.utils.messaging

Liking cljdoc? Tell your friends :D

Clojure only.

check-connection
conf
disconnect
initialize
listen
publish
with-channel

check-connection^clj

(check-connection)

source

conf^clj

source

disconnect^clj

(disconnect)

source

initialize^clj

(initialize new-conf)

source

listen^clj

(listen name receiver)

(listen exchange-name receiver queue-name)

(listen exchange-name receiver qname options)

Listen to the message with (the routing key) name usually in ad hoc fashion. Listener is a function that takes one argument, the message. The message is a json compatible object. The variant without specifying the queue name creates a temporary, exclusive and auto deleted queue. The variant specifying the queue name creates a durable queue.

Listen to the message with (the routing key) name  usually in ad hoc
fashion.  Listener is a function that takes one argument, the message. The
message is a json compatible object.  The variant without specifying the
queue name creates a temporary, exclusive and auto deleted queue. The variant
specifying the queue name creates a durable queue.

source raw docstring

publish^clj

(publish name message)

(publish name message options)

(publish exchange-name message options routing-key)

Publish a (ad hoc) message in json format. Message must be convertible by json/write-str. Creates an topic exchange with default parameters for the given name. The topic is only created once for a given connection and name. Uses name as the routing key if no routing-key is given.

Publish a (ad hoc) message in json format. Message must be convertible  by
json/write-str. Creates an topic exchange with default parameters for the
given name. The topic is only created once for a given connection and name.
Uses name as the routing key if no routing-key is given.

source raw docstring