listener

Documentation

Index

• type SQSHandler
• type SQSListener
  • func BuildSQSListener(handler SQSHandler, pollInterval time.Duration, client sqsiface.SQSAPI) *SQSListener
  • func (l *SQSListener) Close()
  • func (l *SQSListener) Listen(qName string)

Types

type SQSHandler

type SQSHandler interface {
	Handle(*sqs.Message) error
}

type SQSListener

type SQSListener struct {
	Handler SQSHandler
	// contains filtered or unexported fields
}

func BuildSQSListener

func BuildSQSListener(handler SQSHandler, pollInterval time.Duration, client sqsiface.SQSAPI) *SQSListener

func (*SQSListener) Close

func (l *SQSListener) Close()

func (*SQSListener) Listen

func (l *SQSListener) Listen(qName string)