Function NewSQS

pkg/async-gateway/queue.go:36–40

NewSQS creates a new SQS client that satisfies the Queue interface

(queueURL string, sess *session.Session)

// NewSQS creates a new SQS client that satisfies the Queue interface
func NewSQS(queueURL string, sess *session.Session) Queue {
	client := awssqs.New(sess)

	return &sqs{queueURL: queueURL, client: client}
}

// SendMessage sends a string
func (q *sqs) SendMessage(message string, uniqueID string) error {