utils.rabbit-service — clientsuccess/utils 1.5.48

bind->exchange clj

(bind->exchange &
                {:keys [x-name x-type x-options queue-name queue-options topics
                        sub-options handler]
                 :or {queue-name "" topics [""]}})

connection-settings clj

(connection-settings host-env username-env password-env)

correlation-id-equals? clj

(correlation-id-equals? correlation-id d)

default-exchange-name clj

deliveries-seq clj

(deliveries-seq qcs timeoutms)

Builds a lazy seq of delivery instances from a queueing consumer.

make-mdc-headers clj

(make-mdc-headers)

message-handler-wrapper clj

(message-handler-wrapper
  raw-handler
  ch
  {:keys [content-type delivery-tag type routing-key headers] :as meta}
  payload)

message-rpc-handler-wrapper clj

(message-rpc-handler-wrapper raw-handler
                             ch
                             {:keys [content-type type delivery-tag reply-to
                                     correlation-id headers]
                              :as meta}
                             payload)

message-topic-handler-wrapper clj

(message-topic-handler-wrapper
  raw-handler
  ch
  {:keys [content-type delivery-tag type routing-key headers] :as meta}
  payload)

nil-or-body clj

(nil-or-body d)

nil-or-correlation-id-equals? clj

(nil-or-correlation-id-equals? correlation-id d)

parse-rabbit-payload clj

(parse-rabbit-payload payload)

publish clj

(publish message queue-name)

publish->exchange clj

(publish->exchange type exchange-name routing-key message)

(publish->exchange type exchange-name routing-key message headers)

(publish->exchange type exchange-name routing-key message headers x-options)

publish-rpc clj

(publish-rpc message queue-name timeoutms)

q-connection-setting clj

RABBIT_TRANS clj

start-consumer clj

(start-consumer queue-name message-handler)

start-rpc-consumer clj

(start-rpc-consumer queue-name message-handler)

write-context-headers clj

(write-context-headers headers)