queues

Documentation

Overview

Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved. SPDX-License-Identifier: Apache-2.0

Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved. SPDX-License-Identifier: Apache-2.0

Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved. SPDX-License-Identifier: Apache-2.0

Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved. SPDX-License-Identifier: Apache-2.0

Index

• func Delete(queue, receiptHandle string) error
• func DeleteMessage(sess *session.Session, queueURL *string, messageHandle *string) error
• func GetMessages(sess *session.Session, queueURL *string, timeout *int64) (*sqs.ReceiveMessageOutput, error)
• func GetQueueURL(sess *session.Session, queue *string) (*sqs.GetQueueUrlOutput, error)
• func Receive(queue string, timeout int64) (*sqs.ReceiveMessageOutput, error)
• func Update(queue string, timeout int64, receiptHandle string)

Functions

func Delete

func Delete(queue, receiptHandle string) error

func DeleteMessage

func DeleteMessage(sess *session.Session, queueURL *string, messageHandle *string) error

DeleteMessage deletes a message from an Amazon SQS queue Inputs:

sess is the current session, which provides configuration for the SDK's service clients
queueURL is the URL of the queue
messageID is the ID of the message

Output:

If success, nil
Otherwise, an error from the call to DeleteMessage

func GetMessages

func GetMessages(sess *session.Session, queueURL *string, timeout *int64) (*sqs.ReceiveMessageOutput, error)

GetMessages gets the messages from an Amazon SQS queue Inputs:

sess is the current session, which provides configuration for the SDK's service clients
queueURL is the URL of the queue
timeout is how long, in seconds, the message is unavailable to other consumers

Output:

If success, the latest message and nil
Otherwise, nil and an error from the call to ReceiveMessage

func GetQueueURL

func GetQueueURL(sess *session.Session, queue *string) (*sqs.GetQueueUrlOutput, error)

GetQueueURL gets the URL of an Amazon SQS queue Inputs:

sess is the current session, which provides configuration for the SDK's service clients
queueName is the name of the queue

Output:

If success, the URL of the queue and nil
Otherwise, an empty string and an error from the call to

func Receive

func Receive(queue string, timeout int64) (*sqs.ReceiveMessageOutput, error)

func Update

func Update(queue string, timeout int64, receiptHandle string)