(handle-queue sqs-config queue-url handler-fn)(handle-queue sqs-config
queue-url
handler-fn
{:keys [num-handler-threads auto-delete visibility-timeout]
:or
{num-handler-threads 4 auto-delete true visibility-timeout 60}
:as opts})Set up a loop that listens to a queue and process incoming messages.
Arguments:
sqs-config - A map of the following keys, used for interacting with SQS:
access-key - AWS access key ID
secret-key - AWS secret access key
endpoint - SQS queue endpoint - usually an HTTPS based URL
region - AWS region
queue-url - URL of the queue
handler-fn - a function which will be passed the incoming message. If
auto-delete is false, a second argument will be passed a done
function to call when finished processing.
opts - an optional map containing the following keys:
num-handler-threads - how many threads to run (defaults: 4)
auto-delete - boolean, if true, immediately delete the message,
if false, forward a `done` function and leave the
message intact. (defaults: true)
visibility-timeout - how long (in seconds) a message can go unacknowledged
before delivery is retried. (defaults: 60)
See http://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-visibility-timeout.html for more information about visibility timeout.
Returns: a kill function - call the function to terminate the loop.
Set up a loop that listens to a queue and process incoming messages.
Arguments:
sqs-config - A map of the following keys, used for interacting with SQS:
access-key - AWS access key ID
secret-key - AWS secret access key
endpoint - SQS queue endpoint - usually an HTTPS based URL
region - AWS region
queue-url - URL of the queue
handler-fn - a function which will be passed the incoming message. If
auto-delete is false, a second argument will be passed a `done`
function to call when finished processing.
opts - an optional map containing the following keys:
num-handler-threads - how many threads to run (defaults: 4)
auto-delete - boolean, if true, immediately delete the message,
if false, forward a `done` function and leave the
message intact. (defaults: true)
visibility-timeout - how long (in seconds) a message can go unacknowledged
before delivery is retried. (defaults: 60)
See http://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-visibility-timeout.html
for more information about visibility timeout.
Returns:
a kill function - call the function to terminate the loop.(receive-loop! sqs-config queue-url out-chan)(receive-loop!
sqs-config
queue-url
out-chan
{:keys [auto-delete visibility-timeout restart-delay-seconds]
:or {auto-delete true visibility-timeout 60 restart-delay-seconds 1}
:as opts})A background loop to receive SQS messages from a queue indefinitely.
Arguments: sqs-config - A map of the following keys, used for interacting with SQS: access-key - AWS access key ID secret-key - AWS secret access key endpoint - SQS queue endpoint - usually an HTTPS based URL region - AWS region queue-url - URL of the queue out-chan - async channel where messages will be passed into opts - an optional map containing the following keys:
auto-delete - boolean, if true, immediately delete the message,
if false, forward a `done` function and leave the
message intact.
visibility-timeout - how long (in seconds) a message can go unacknowledged
before delivery is retried.
auto-delete defaults to true, visibility-timeout defaults to 60 seconds.
Returns a kill function - call the function to terminate the loop.
A background loop to receive SQS messages from a queue indefinitely.
Arguments:
sqs-config - A map of the following keys, used for interacting with SQS:
access-key - AWS access key ID
secret-key - AWS secret access key
endpoint - SQS queue endpoint - usually an HTTPS based URL
region - AWS region
queue-url - URL of the queue
out-chan - async channel where messages will be passed into
opts - an optional map containing the following keys:
auto-delete - boolean, if true, immediately delete the message,
if false, forward a `done` function and leave the
message intact.
visibility-timeout - how long (in seconds) a message can go unacknowledged
before delivery is retried.
auto-delete defaults to true, visibility-timeout defaults to 60 seconds.
Returns a kill function - call the function to terminate the loop.(send-fifo-message sqs-config
queue-url
payload
{message-group-id :message-group-id
deduplication-id :deduplication-id
:as options})Send a message to a FIFO queue.
Arguments: message-group-id - a tag that specifies the group that this message belongs to. Messages belonging to the same group are guaranteed FIFO
Options: deduplication-id - token used for deduplication of sent messages
Send a message to a FIFO queue.
Arguments:
message-group-id - a tag that specifies the group that this message
belongs to. Messages belonging to the same group
are guaranteed FIFO
Options:
deduplication-id - token used for deduplication of sent messages(send-message sqs-config queue-url payload)Send a message to a standard queue.
Send a message to a standard queue.
(send-message* sqs-config
queue-url
payload
{:keys [message-group-id deduplication-id]})Send a message to a queue.
Send a message to a queue.
cljdoc builds & hosts documentation for Clojure/Script libraries
| Ctrl+k | Jump to recent docs |
| ← | Move to previous article |
| → | Move to next article |
| Ctrl+/ | Jump to the search field |