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
(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
(add-shutdown-listener c f)Adds a shutdown listener on connection and returns it
Adds a shutdown listener on connection and returns it
(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
(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
(automatically-recover? c)See automatic-recovery-enabled?
See automatic-recovery-enabled?
(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
(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
(connect)(connect settings)Creates and returns a new connection to RabbitMQ.
Creates and returns a new connection to RabbitMQ.
(create-channel & args)Delegates to langohr.channel/open, kept for backwards compatibility
Delegates to langohr.channel/open, kept for backwards compatibility
(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 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
(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
(on-recovery target callback)Registers a network recovery callback on a (Langohr) connection or channel
Registers a network recovery callback on a (Langohr) connection or channel
(closed? this)Checks whether given entity is closed
Checks whether given entity is closed
(open? this)Checks whether given entity is open
Checks whether given entity is open
(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.
(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
(shutdown-listener f)Adds new shutdown signal listener that delegates to given function
Adds new shutdown signal listener that delegates to given function
(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
cljdoc builds & hosts documentation for Clojure/Script libraries
| Ctrl+k | Jump to recent docs |
| ← | Move to previous article |
| → | Move to next article |
| Ctrl+/ | Jump to the search field |