ziggurat.messaging.rabbitmq.consumer — tech.gojek/ziggurat 3.4.2-alpha.1

consume-message clj

(consume-message ch {:keys [delivery-tag]} payload ack?)

De-serializes the message payload (payload) using nippy/thaw and acks the message if ack? is true.

get-messages-from-queue clj

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

process-message-from-queue clj

(process-message-from-queue ch meta payload processing-fn)

process-messages-from-queue clj

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

start-subscriber clj

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