Liking cljdoc? Tell your friends :D

langohr.core

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

Relevant guides:

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

*default-config*clj

Default connection settings.

Default connection settings.
sourceraw docstring

add-blocked-listenerclj

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

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

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

add-shutdown-listenerclj

(add-shutdown-listener c f)

Adds a shutdown listener on connection and returns it

Adds a shutdown listener on connection and returns it
sourceraw docstring

automatic-recovery-enabled?clj

(automatic-recovery-enabled? conn)

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

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

automatic-topology-recovery-enabled?clj

(automatic-topology-recovery-enabled? conn)

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

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

automatically-recover?cljdeprecated

(automatically-recover? c)

See automatic-recovery-enabled?

See automatic-recovery-enabled?
sourceraw docstring

blocked-listenerclj

(blocked-listener on-blocked on-unblocked)

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

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

capabilities-ofclj

(capabilities-of conn)

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

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

Closeablecljprotocol

closeclj

(close c)

Closes given entity

Closes given entity
source

connectclj

(connect)
(connect settings)

Creates and returns a new connection to RabbitMQ.

Creates and returns a new connection to RabbitMQ.
sourceraw docstring

create-channelclj

(create-channel & args)

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

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

exception-handlerclj

(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]})
source

normalize-settingsclj

(normalize-settings config)

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

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

on-queue-recoveryclj

(on-queue-recovery conn f)

Called when server named queue gets a new name on recovery

Called when server named queue gets a new name on recovery
sourceraw docstring

on-recoveryclj

(on-recovery target recovery-finished-fn)
(on-recovery target recovery-started-fn recovery-finished-fn)

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

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

Openablecljprotocol

closed?clj

(closed? this)

Checks whether given entity is closed

Checks whether given entity is closed

open?clj

(open? this)

Checks whether given entity is open

Checks whether given entity is open
source

queue-recovery-listenerclj

(queue-recovery-listener f)

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

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

settings-fromclj

(settings-from uri)

Parses AMQP connection URI and returns a persistent map of settings

Parses AMQP connection URI and returns a persistent map of settings
sourceraw docstring

shutdown-listenerclj

(shutdown-listener f)

Adds new shutdown signal listener that delegates to given function

Adds new shutdown signal listener that delegates to given function
sourceraw docstring

thread-factory-fromclj

(thread-factory-from f)

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

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

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close