ziggurat.messaging.rabbitmq-wrapper — tech.gojek/ziggurat 3.3.1-alpha.2

connection clj

consume-message clj

(consume-message ch meta payload ack?)

create-and-bind-queue clj

(create-and-bind-queue queue-name exchange-name)

(create-and-bind-queue queue-name exchange-name dead-letter-exchange)

get-messages-from-queue clj

(get-messages-from-queue queue-name ack?)

(get-messages-from-queue queue-name ack? count)

process-messages-from-queue clj

(process-messages-from-queue queue-name count processing-fn)

publish clj

(publish exchange message-payload)

(publish exchange message-payload expiration)

start-connection clj

(start-connection config stream-routes)

start-subscriber clj

(start-subscriber prefetch-count wrapped-mapper-fn queue-name)

stop-connection clj

(stop-connection connection config stream-routes)