Documentation ¶
Index ¶
- func NewManager(sqs *sqs.SQS, accountId string) msgqueue.Manager
- type 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) Name() string
- func (q *Queue) Options() *msgqueue.Options
- func (q *Queue) Processor() *msgqueue.Processor
- func (q *Queue) Purge() error
- func (q *Queue) Release(msg *msgqueue.Message) error
- func (q *Queue) ReserveN(n int) ([]*msgqueue.Message, error)
- func (q *Queue) String() string
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Queue ¶
type Queue struct {
// contains filtered or unexported fields
}
func (*Queue) CallOnce ¶
CallOnce works like Call, but it adds message with same args only once in a period.
func (*Queue) CloseTimeout ¶
Close closes the queue waiting for pending messages to be processed.
Click to show internal directories.
Click to hide internal directories.