azsqs

Jul 10, 2018

Changes in this version

type Queue

+ func (q *Queue) GetAddQueue() *memqueue.Queue

+ func (q *Queue) GetDeleteQueue() *memqueue.Queue

Nov 7, 2017

Changes in this version

type Queue

+ func (q *Queue) Len() (int, error)

Aug 8, 2017

Changes in this version

type Queue

+ func (q *Queue) AddQueue() *memqueue.Queue

+ func (q *Queue) DeleteQueue() *memqueue.Queue

Aug 3, 2017

Changes in this version

+ func NewManager(sqs *sqs.SQS, accountId string) msgqueue.Manager

Apr 4, 2017

Changes in this version

+ type Queue struct

+ func NewQueue(sqs *sqs.SQS, accountId string, opt *msgqueue.Options) *Queue

+ func Queues() []*Queue

+ func (q *Queue) Add(msg *msgqueue.Message) error

+ func (q *Queue) Call(args ...interface{}) error

+ func (q *Queue) CallOnce(period time.Duration, args ...interface{}) error

+ func (q *Queue) Close() error

+ func (q *Queue) CloseTimeout(timeout time.Duration) error

+ func (q *Queue) Delete(msg *msgqueue.Message) error

+ func (q *Queue) DeleteBatch(msgs []*msgqueue.Message) error

+ func (q *Queue) Name() string

+ func (q *Queue) Options() *msgqueue.Options

+ func (q *Queue) Processor() *processor.Processor

+ func (q *Queue) Purge() error

+ func (q *Queue) Release(msg *msgqueue.Message, delay time.Duration) error

+ func (q *Queue) ReserveN(n int) ([]msgqueue.Message, error)

+ func (q *Queue) String() string