langohr.core — com.novemberain/langohr 3.7.0

Functions that work with connections and shared features between connections and channels (e.g. shutdown listeners).

Relevant guides:

• http://clojurerabbitmq.info/articles/connecting.html
• http://clojurerabbitmq.info/articles/tls.html

*default-config* clj

Default connection settings.

add-blocked-listener clj

(add-blocked-listener c on-blocked on-unblocked)

Adds a connection.blocked and connection.unblocked listener on connection and returns it

add-shutdown-listener clj

(add-shutdown-listener c f)

Adds a shutdown listener on connection and returns it

automatic-recovery-enabled? clj

(automatic-recovery-enabled? conn)

Returns true if provided connection uses automatic connection recovery mode, false otherwise

automatic-topology-recovery-enabled? clj

(automatic-topology-recovery-enabled? conn)

Returns true if provided connection uses automatic topology recovery mode, false otherwise

automatically-recover? clj deprecated

(automatically-recover? c)

See automatic-recovery-enabled?

blocked-listener clj

(blocked-listener on-blocked on-unblocked)

Reifies connection.blocked and connection.unblocked listener from Clojure functions

capabilities-of clj

(capabilities-of conn)

Returns capabilities of the broker on the other side of the connection

Closeable clj protocol

close clj

(close c)

Closes given entity

connect clj

(connect)

(connect settings)

Creates and returns a new connection to RabbitMQ.

create-channel clj

(create-channel & args)

Delegates to langohr.channel/open, kept for backwards compatibility

exception-handler clj

(exception-handler
  {:keys [handle-connection-exception-fn handle-return-listener-exception-fn
          handle-flow-listener-exception-fn handle-confirm-listener-exception-fn
          handle-blocked-listener-exception-fn handle-consumer-exception-fn
          handle-connection-recovery-exception-fn
          handle-channel-recovery-exception-fn
          handle-topology-recovery-exception-fn]})

normalize-settings clj

(normalize-settings config)

For setting maps that contain keys such as :host, :username, :vhost, returns the argument

on-queue-recovery clj

(on-queue-recovery conn f)

Called when server named queue gets a new name on recovery

on-recovery clj

(on-recovery target callback)

Registers a network recovery callback on a (Langohr) connection or channel

Openable clj protocol

closed? clj

(closed? this)

Checks whether given entity is closed

open? clj

(open? this)

Checks whether given entity is open

queue-recovery-listener clj

(queue-recovery-listener f)

Reifies a new queue recovery listener that delegates to a Clojure function.

settings-from clj

(settings-from uri)

Parses AMQP connection URI and returns a persistent map of settings

shutdown-listener clj

(shutdown-listener f)

Adds new shutdown signal listener that delegates to given function

thread-factory-from clj

(thread-factory-from f)

Instantiates a java.util.concurrent.ThreadFactory that delegates #newThread to provided Clojure function