forked from vmihailenco/taskq
/
msgqueue.go
39 lines (33 loc) · 864 Bytes
/
msgqueue.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
package msgqueue
import (
"log"
"os"
"time"
"github.com/go-msgqueue/msgqueue/internal"
)
func init() {
SetLogger(log.New(os.Stderr, "msgqueue: ", log.LstdFlags))
}
func SetLogger(logger *log.Logger) {
internal.Logger = logger
}
type Queue interface {
Name() string
Processor() *Processor
Add(msg *Message) error
Call(args ...interface{}) error
CallOnce(dur time.Duration, args ...interface{}) error
Len() (int, error)
ReserveN(n int, reservationTimeout time.Duration, waitTimeout time.Duration) ([]*Message, error)
Release(*Message) error
Delete(msg *Message) error
Purge() error
Close() error
CloseTimeout(timeout time.Duration) error
}
// Manager is an interface that abstracts creation of new queues.
// It is implemented in subpackages memqueue, azsqs, and ironmq.
type Manager interface {
NewQueue(*Options) Queue
Queues() []Queue
}