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

<? clj macro

(<? channel)

Same as <! but throws error if an error is returned from channel

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)

delete-queue! clj

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

purge-queue! clj

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

receive-messages clj

(receive-messages sqs-client queue-url)

(receive-messages sqs-client
                  queue-url
                  {:keys [wait-time-in-seconds] :or {wait-time-in-seconds 20}})

receive-to-channel clj

(receive-to-channel sqs-client queue-url 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 sqs-ext-config)

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

(wait-and-receive-messages-from-sqs sqs-client queue-url wait-time-in-seconds)