(build-create-queue-request-with-attributes
name
{:keys [fifo visibility-timeout-in-seconds kms-master-key-id
kms-data-key-reuse-period]})
(create-fifo-queue! sqs-client queue-name)
(create-fifo-queue! sqs-client
queue-name
{:keys [visibility-timeout-in-seconds kms-master-key-id
kms-data-key-reuse-period]
:as opts})
(create-standard-queue! sqs-client queue-name)
(create-standard-queue! sqs-client
queue-name
{:keys [visibility-timeout-in-seconds kms-master-key-id
kms-data-key-reuse-period]
:as opts})
(queue-attributes sqs-client queue-url)
(queue-attributes sqs-client queue-url attribute-names)
(receive-messages sqs-client queue-url)
(receive-messages sqs-client
queue-url
{:keys [wait-time-in-seconds max-number-of-receiving-messages]
:or {wait-time-in-seconds 20}})
(send-fifo-message sqs-client queue-url message group-id)
(send-fifo-message sqs-client
queue-url
message
group-id
{:keys [format deduplication-id] :or {format :transit}})
Send a message to a FIFO queue.
Argments: sqs-client - The extended sqs-client via which the request shall be sent queue-url - the queue's URL message - The actual message/data to be sent message-group-id - A value that will be parsed as string to specify the group that this message belongs to. Messages belonging to the same group are guaranteed FIFO
Options: format - The format (currently :json or :transit) to serialize the outgoing message with (default: :transit) deduplication-id - A string used for deduplication of sent messages
Send a message to a FIFO queue. Argments: sqs-client - The extended sqs-client via which the request shall be sent queue-url - the queue's URL message - The actual message/data to be sent message-group-id - A value that will be parsed as string to specify the group that this message belongs to. Messages belonging to the same group are guaranteed FIFO Options: format - The format (currently :json or :transit) to serialize the outgoing message with (default: :transit) deduplication-id - A string used for deduplication of sent messages
(send-message sqs-client queue-url message)
(send-message sqs-client
queue-url
message
{:keys [format] :or {format :transit}})
Send a message to a standard queue.
Argments: sqs-client - The extended sqs-client via which the request shall be sent queue-url - the queue's URL message - The actual message/data to be sent
Options: format - The format (currently :json or :transit) to serialize the outgoing message with (default: :transit)
Send a message to a standard queue. Argments: sqs-client - The extended sqs-client via which the request shall be sent queue-url - the queue's URL message - The actual message/data to be sent Options: format - The format (currently :json or :transit) to serialize the outgoing message with (default: :transit)
(sqs-ext-client {:keys [access-key secret-key s3-endpoint s3-bucket-name
sqs-endpoint region cleanup-s3-payload?]
:or {cleanup-s3-payload? true}
:as sqs-ext-config})
Takes a map of configuration and returns a client object.
Arguments:
A map of the following optional keys used for accessing AWS services: access-key - AWS access key ID secret-key - AWS secret access key s3-endpoint - AWS S3 endpoint (protocol://service-code.region-code.amazonaws.com) s3-bucket-name - AWS S3 bucket to use to store messages larger than 256kb (optional) sqs-endpoint - AWS SQS endpoint (protocol://service-code.region-code.amazonaws.com) region - AWS region
Takes a map of configuration and returns a client object. Arguments: A map of the following optional keys used for accessing AWS services: access-key - AWS access key ID secret-key - AWS secret access key s3-endpoint - AWS S3 endpoint (protocol://service-code.region-code.amazonaws.com) s3-bucket-name - AWS S3 bucket to use to store messages larger than 256kb (optional) sqs-endpoint - AWS SQS endpoint (protocol://service-code.region-code.amazonaws.com) region - AWS region
(wait-and-receive-messages-from-sqs sqs-client
queue-url
{wait-time-in-seconds :wait-time-in-seconds
max-number-of-receiving-messages
:max-number-of-receiving-messages})
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close