(:done-channel (com.climate.squeedo.sqs-consumer/start-consumer))
now returns a channel contains message-returning channels instead of messages.com.climate.squeedo.sqs-consumer/graceful-stop-consumer
to support graceful shutdown.:worker-threads?
- run workers in dedicated threads; if true, will create one thread per worker.
Calculating worker job and reporting with a blocking SQS client in core.async threads may cause dead lock, as there are only limited number of core.async threads. (default to 8).:exceptional-poll-delay-ms
, with a new default
behavior of timing out for 10 seconds if an exception occurs when dequeueing. (thanks @stephencrampton!).getStringValue
when clojurifying MessageAttributeValue objects. (thanks @danieltdt!)1.0.0-beta2
.com.climate.squeedo.sqs/enqueue
via :message-group-id
and :message-deduplication-id
.com.climate.squeedo.sqs/configure-queue
(replaces com.climate.squeedo.sqs/set-queue-attrubutes
from 0.2.2).
com.climate.squeedo.sqs/configure-queue
will create the specified
queue (and dead letter queue) if it does not exist.com.climate.squeedo.sqs/mk-connection
.
this function now only makes a connection and returns a reusable connection object.
a QueueDoesNotExistException
exception will be thrown if the queue does not exist
(for convenience, com.climate.squeedo.sqs/configure-queue
can be used
to create the queue first).com.climate.squeedo.sqs-consumer/start-consumer
.
use com.climate.squeedo.sqs/configure-queue
to set up dead letter queue.com.climate.squeedo.sqs/mk-connection
creates a new sqs queue
WARN
log when this occurscom.climate.squeedo.sqs/set-queue-attributes
, which allows ad-hoc calls to set attributes
for those who need it:nack timeout
[org.clojure/core.async "0.3.442"]
Can you improve this documentation? These fine people already did:
Matt Kipps, Matt K, Jeongbong Seo & Sam NelsonEdit on GitHub
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close