onyx.plugin.sqs — org.onyxplatform/onyx-amazon-sqs 0.14.0.0

change-visibility-request-async clj

(change-visibility-request-async client queue-url message-id visibility-time)

create-queue clj

(create-queue client queue-name attributes)

delete-message clj

(delete-message client queue-url receipt-handle)

delete-message-async clj

(delete-message-async client queue-url receipt-handle)

delete-message-async-batch clj

(delete-message-async-batch client queue-url receipt-handles)

delete-message-batch-request clj

(delete-message-batch-request queue-url receipt-handles)

delete-queue clj

(delete-queue client queue-name)

get-queue-url clj

(get-queue-url client queue-name)

message->clj clj

(message->clj msg)

new-async-buffered-client clj

(new-async-buffered-client region)

(new-async-buffered-client
  region
  {:keys [max-batch-open-ms max-inflight-outbound-batches
          max-inflight-receive-batches max-done-receive-batches param-long-poll
          max-batch-size-bytes visibility-timeout long-poll-timeout max-batch]})

new-async-client clj

(new-async-client region)

new-client clj

(new-client region)

queue-attributes clj

(queue-attributes client queue-url)

(queue-attributes client queue-url attrs)

receive-message clj

(receive-message client queue-url)

receive-messages clj

(receive-messages client
                  queue-url
                  max-num-messages
                  attribute-names
                  message-attribute-names
                  wait-time-secs)

receive-request clj

(receive-request client
                 queue-url
                 max-num-messages
                 attribute-names
                 message-attribute-names
                 wait-time-secs)

send-message clj

(send-message client queue-url message)

send-message-async clj

(send-message-async client queue-url message)

send-message-batch clj

(send-message-batch client queue-url messages)

send-message-batch-async clj

(send-message-batch-async client queue-url messages)

send-message-batch-request clj

(send-message-batch-request queue-url messages)