AWSSQS.sqs_arn
— Methodsqs_arn(::AWSQueue)
ARN of a queue.
AWSSQS.sqs_busy_count
— Methodsqs_busy_count(::AWSQueue)
Approximate number of messages not visible in a queue.
AWSSQS.sqs_change_message_visibility
— Methodsqs_change_message_visibility(::AWSQueue, message, visibility_timeout)
Change the amount of time before a message can be re-read from a queue. Default message visibility timeout is 30 seconds, minimum is 0 seconds, maximum is 12 hours.
AWSSQS.sqs_count
— Methodsqs_count(::AWSQueue)
Approximate number of messages in a queue.
AWSSQS.sqs_create_queue
— Methodsqs_create_queue([::AWSConfig], name; options...)
Create new queue with name
. Returns ::AWSQueue
.
options
: VisibilityTimeout
, MessageRetentionPeriod
, DelaySeconds
etc...
See SQS API Reference for detail.
q = sqs_create_queue("my-queue")
sqs_send_message(q, "my message")
AWSSQS.sqs_delete_message
— Methodsqs_delete_message(::AWSQueue, message)
Delete a message
from a queue.
AWSSQS.sqs_delete_queue
— Methodsqs_delete_queue(::AWSQueue)
Delete a queue.
AWSSQS.sqs_flush
— Methodsqs_flush(::AWSQueue)
Delete all messages from a queue.
AWSSQS.sqs_get_queue
— Methodsqs_get_queue([::AWSConfig], name)
Look up a queue by name. Returns ::AWSQueue
.
q = sqs_get_queue("my-queue")
sqs_send_message(q, "my message")
AWSSQS.sqs_get_queue_attributes
— Methodsqs_get_queue_attributes(::AWSQueue)
Get Queue Attributes for a queue.
AWSSQS.sqs_list_queues
— Functionsqs_list_queues([::AWSConfig], prefix="")
Returns a list of ::AWSQueue
.
for q in sqs_list_queues()
println("$(sqs_name(q)) has ~$(sqs_count(q)) messages.")
end
AWSSQS.sqs_messages
— Methodsqs_messages(::AWSQueue)
Returns an iterator that retrieves messages from a queue.
for m in sqs_messages(q)
println(m[:message])
sqs_delete_message(m)
end
AWSSQS.sqs_name
— Methodsqs_name(::AWSQueue)
Name of a queue.
AWSSQS.sqs_receive_message
— Methodsqs_receive_message(::AWSQueue)
Returns a Dict
containing :message
, :id
and :handle
or nothing
if the queue is empty.
m = sqs_receive_message(q)
println(m[:message])
sqs_delete_message(m)
AWSSQS.sqs_send_message
— Methodsqs_send_message(::AWSQueue, message)
Send a message
to a queue.
sqs_send_message(queue, "Hello!", Dict(:MessageGroupId=>"Some_UUID"))
AWSSQS.sqs_send_message_batch
— Methodsqs_send_message_batch(::AWSQueue, messages)
Send a collection of messages
to a queue.
AWSSQS.sqs_set_policy
— Methodsqs_set_policy(::AWSQueue, policy)
Set access policy
for a queue.