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
Source Files
Click to show internal directories.
Click to hide internal directories.