sqsrelay

type QueueProcessor struct {
	SQS                  SQSMessageReader
	QueueURL             string
	Handler              *deferred.Handler
	QueueWaitTimeSeconds int64
}

type RelayHandler struct {
	SQS      SQSMessageSender
	QueueURL string
}

type SQSMessageReader interface {
	ReceiveMessageWithContext(aws.Context, *sqs.ReceiveMessageInput, ...request.Option) (*sqs.ReceiveMessageOutput, error)
	DeleteMessageWithContext(aws.Context, *sqs.DeleteMessageInput, ...request.Option) (*sqs.DeleteMessageOutput, error)
}

type SQSMessageSender interface {
	SendMessageWithContext(aws.Context, *sqs.SendMessageInput, ...request.Option) (*sqs.SendMessageOutput, error)
}