xqueuensq

Documentation

Overview

NSQ驱动xqueue队列

Index

• func Open(get, gettopic, getchannel, set, settopic string, max_error uint16) xqueue.Queue
• type Queues
  • func (c *Queues) HandleMessage(m *nsq.Message) error
  • func (c *Queues) Listen(f func(dat []byte) error) error
  • func (c *Queues) Set(dat []byte) error
  • func (c *Queues) SetDef(dat []byte, t time.Duration) error

Functions

func Open

func Open(get, gettopic, getchannel, set, settopic string, max_error uint16) xqueue.Queue

获取NSQ的xqueue驱动

get			监听队列端口
gettopic	监听队列的通道
getchannel	监听队列的客户端
set			发送队列的端口
settopic	发送队列的通道
max_error	最大错误重试次数

Types

type Queues

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

func (*Queues) HandleMessage

func (c *Queues) HandleMessage(m *nsq.Message) error

队列消息监听

func (*Queues) Listen

func (c *Queues) Listen(f func(dat []byte) error) error

队列监听

func (*Queues) Set

func (c *Queues) Set(dat []byte) error

设置队列监听

func (*Queues) SetDef

func (c *Queues) SetDef(dat []byte, t time.Duration) error

设置延时队列监听