Documentation ¶
Index ¶
Constants ¶
View Source
const ( DefaultPollWaitSeconds = 1 DefaultMaxMessages = 10 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SQSSubscriber ¶
type SQSSubscriber struct { ListenChannel chan (*sqs.Message) ErrorChannel chan (error) SQSQueueURL string SQSPollWaitSeconds int64 SQSMaxMessages int64 Exit bool // contains filtered or unexported fields }
SQSSubscriber is the event subscriber
func NewSQSSubscriber ¶
func NewSQSSubscriber(url string) (*SQSSubscriber, error)
NewSQSSubscriber returns a new instance of SQSSubscriber with default values
func (*SQSSubscriber) Delete ¶
func (s *SQSSubscriber) Delete(receiptHandle *string) error
Delete cleans up and removes messages from the SQS queue calling this from the listener handler is required to ensure you process each message
func (*SQSSubscriber) Start ¶
func (s *SQSSubscriber) Start() chan (*sqs.Message)
Start begins the listener process
Click to show internal directories.
Click to hide internal directories.