queue

Documentation

Index

• func DisableLog()
• type Client
• type Message
  • func NewMessage(id int64, topic string, ty int64, data interface{}) (msg Message)
  • func (msg Message) Err() error
  • func (msg Message) GetData() interface{}
  • func (msg Message) Reply(replyMsg Message)
  • func (msg Message) ReplyErr(title string, err error)
  • func (msg Message) String() string
• type Module
• type Queue
  • func New(name string) Queue

Functions

func DisableLog

func DisableLog()

Types

type Client

type Client interface {
	Send(msg Message, waitReply bool) (err error) //同步发送消息
	SendTimeout(msg Message, waitReply bool, timeout time.Duration) (err error)
	Wait(msg Message) (Message, error)                               //等待消息处理完成
	WaitTimeout(msg Message, timeout time.Duration) (Message, error) //等待消息处理完成
	Recv() chan Message
	Sub(topic string) //订阅消息
	Close()
	CloseQueue() (*types.Reply, error)
	NewMessage(topic string, ty int64, data interface{}) (msg Message)
}

type Message

type Message struct {
	Topic string
	Ty    int64
	Id    int64
	Data  interface{}
	// contains filtered or unexported fields
}

func NewMessage

func NewMessage(id int64, topic string, ty int64, data interface{}) (msg Message)

func (Message) Err

func (msg Message) Err() error

func (Message) GetData

func (msg Message) GetData() interface{}

func (Message) Reply

func (msg Message) Reply(replyMsg Message)

func (Message) ReplyErr

func (msg Message) ReplyErr(title string, err error)

func (Message) String

func (msg Message) String() string

type Module

type Module interface {
	SetQueueClient(client Client)
	Close()
}

/ Module be used for module interface

type Queue

type Queue interface {
	Close()
	Start()
	Client() Client
	Name() string
}

/ Queue only one obj in project / Queue only generate Client and start、Close operate, / if you send massage or receive massage on Queue, please use Client.

func New

func New(name string) Queue