sqs

type Client struct {
	// contains filtered or unexported fields
}

type Consumer interface {

	// Receive will read messages from given queue in AWS SQS.
	Receive(string) ([]RawMessage, error)

	// Confirm that the message was received. This will delete this message from given queue.
	Ack(string, *string) error
}

type Publisher interface {

	// Send will marshal given message to JSON if it's not already a byte array,
	// try to send it to AWS SQS and will return the message id in case of successful delivering.
	Send(interface{}, string) (*string, error)

	// SendAttributedMessage will marshal given message to JSON if it's not already a byte array,
	// try to send it to AWS SQS using passed message attributes and will return the message id
	// in case of successful delivering.
	SendAttributedMessage(interface{}, string, map[string]string) (*string, error)
}

type RawMessage struct {

	// MessageId is the id of a message in AWS SQS.
	MessageId *string

	// ReceiptHandle is the receipt handle in AWS SQS.
	ReceiptHandle *string

	// Body contains the message body read from AWS SQS.
	Body *string
}