queue

Mar 5, 2019

Changes in this version

+ var ErrTimeout = errors.New("consumer get message timeout")

Dec 29, 2018

Changes in this version

type Consumer

+ Dequeue func(subject, group string, timeout time.Duration, msg proto.Message) (*message.Meta, error)

+ Subscribe func(subject, group string) (Subscriber, error)

type Publisher

+ Enqueue func(subject string, msg *message.Message) error

+ Publish func(subject string, msg *message.Message) error

Dec 25, 2018

Changes in this version

+ func Drivers() []string

+ func Register(name string, d driver)

+ type Conn interface

+ Ping func() error

+ type Consumer interface

+ func NewConsumer(driverName, queueAddrs string) (Consumer, error)

+ type Publisher interface

+ func NewPublisher(driverName, queueAddrs string) (Publisher, error)

+ type Subscriber interface

+ NextMessage func(timeout time.Duration) (*message.Message, error)