consumer

type Consumer interface {
	Run(ctx context.Context, chResponse chan Response)
	DeleteMessage(messageReceipt *string) error
}

type Message sqs.Message

type MessageBody struct {
	Type           string `json:"Type"`
	TopicARN       string `json:"TopicArn"`
	Message        string `json:"Message"`
	MessageID      string `json:"MessageId"`
	Timestamp      string `json:"Timestamp"`
	UnsubscribeURL string `json:"UnsubscribeURL"`
}

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

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

type Options struct {
	QueueURL            *string
	MaxNumberOfMessages *int64
	Session             session.Session
	ReadMessageDelay    time.Duration
}

type Response struct {
	Error       error
	Message     *Message
	MessageBody *MessageBody
}