snsqs

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

type Consumer interface {
	cleaner.Cleanable
	Run()
	// contains filtered or unexported methods
}

type MessageHandler func(*SNSMessage) error

type OnPublished func(message []byte, messageId string, failed error)

type Publisher interface {
	cleaner.Cleanable
	Run(OnPublished)
	PublishJson(interface{}) error
	// contains filtered or unexported methods
}

type SNSMessage struct {
	Message        string `json:"Message"`
	TopicArn       string `json:"TopicArn"`
	MessageId      string `json:"MessageId"`
	UnsubscribeURL string `json:"UnsubscribeURL"`
}