clj-sqs-extended.aws.sqs — motiva/clj-sqs-extended 0.3.0

build-create-queue-request-with-attributes clj

(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! clj

(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! clj

(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})

delete-message! clj

(delete-message! sqs-client queue-url message-or-receipt-handle)

delete-queue! clj

(delete-queue! sqs-client queue-url)

purge-queue! clj

(purge-queue! sqs-client queue-url)

queue-attributes clj

(queue-attributes sqs-client queue-url)

(queue-attributes sqs-client queue-url attribute-names)

receive-messages clj

(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}})

receive-to-channel clj

(receive-to-channel sqs-client
                    queue-url
                    {:keys [max-number-of-receiving-messages] :as opts})

send-fifo-message clj

(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-message clj

(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)

sqs-ext-client clj

(sqs-ext-client {:keys [access-key secret-key s3-endpoint s3-bucket-name
                        sqs-endpoint region]
                 :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

wait-and-receive-messages-from-sqs clj

(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})