sqs-consumer.utils
auto-json-decoderclj
(auto-json-decoder)(auto-json-decoder json-fn)Returns a decoder determines whether the message was from SQS or SNS and decodes the message appropriately.
Adds :sqs-consumer.core/metadata :message-envelope as :sns or :sqs ()depending on the envelope) to the decoded message for use by downstream handlers.
Not required if RawMessageDelivery is true on the SNS topic.
If no json-fn is provided, will load clojure.data.json.
Returns a decoder determines whether the message was from SQS or SNS and decodes the message appropriately. Adds :sqs-consumer.core/metadata :message-envelope as :sns or :sqs ()depending on the envelope) to the decoded message for use by downstream handlers. Not required if RawMessageDelivery is true on the SNS topic. If no json-fn is provided, will load clojure.data.json.
sns-encoded-json-decoderclj
(sns-encoded-json-decoder)(sns-encoded-json-decoder json-fn)Returns a decoder which decodes the external SNS message and the internal "Message" property on the message, as well as parsing any message attributes which may be in the message body.
Adds :sqs-consumer.core/metadata :message-envelope as :sns to the decoded message for use by downstream handlers.
Not required if RawMessageDelivery is true on the SNS topic.
If no json-fn is provided, will load clojure.data.json.
Returns a decoder which decodes the external SNS message and the internal "Message" property on the message, as well as parsing any message attributes which may be in the message body. Adds :sqs-consumer.core/metadata :message-envelope as :sns to the decoded message for use by downstream handlers. Not required if RawMessageDelivery is true on the SNS topic. If no json-fn is provided, will load clojure.data.json.
sqs-encoded-json-decoderclj
(sqs-encoded-json-decoder)(sqs-encoded-json-decoder json-fn)Returns a decoder which decodes the sqs message as json.
Adds :sqs-consumer.core/metadata :message-envelope as :sqs to the decoded message for use by downstream handlers.
If no json-fn is provided, will load clojure.data.json.
Returns a decoder which decodes the sqs message as json. Adds :sqs-consumer.core/metadata :message-envelope as :sqs to the decoded message for use by downstream handlers. If no json-fn is provided, will load clojure.data.json.
uuidclj
(uuid)Generates a V4 UUID and converts it to a string.
Generates a V4 UUID and converts it to a string.
with-handlerclj
(with-handler process-fn handler)Calls the given handler and passes it down the chain. Useful when threading a process-fn.
Calls the given handler and passes it down the chain. Useful when threading a process-fn.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close