memqueue

package

v1.8.2 Latest Latest Go to latest Published: Aug 27, 2018 License: BSD-2-Clause Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

func NewManager() msgqueue.Manager

type Queue struct {
	// contains filtered or unexported fields
}

func NewQueue(opt *msgqueue.Options) *Queue

func Queues() []*Queue

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

Add adds message to the queue.

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

Call creates a message using the args and adds it to the queue.

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

CallOnce works like Call, but it returns ErrDuplicate if message with such args was already added in a period.

func (q *Queue) Close() error

Close is CloseTimeout with 30 seconds timeout.

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

Close closes the queue waiting for pending messages to be processed.

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

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

func (q *Queue) Len() (int, 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, reservationTimeout time.Duration, waitTimeout time.Duration) ([]*msgqueue.Message, error)

func (q *Queue) SetNoDelay(noDelay bool)

func (q *Queue) SetSync(sync bool)

func (q *Queue) String() string