msg

Documentation

Index

• type HandlerFunc
  • func (h HandlerFunc) HandlerMessage(message *Message) error
• type Message
• type Msg
  • func NewConsumer(topic, channel string, params ...interface{}) (msg Msg)
  • func NewProducer(params ...interface{}) (msg Msg)
• type Nsg
  • func (n *Nsg) MultiPub(topic string, msgs ...interface{}) error
  • func (n *Nsg) NewConsumer(topic, channel string) Msg
  • func (n *Nsg) NewProducer() Msg
  • func (n *Nsg) Pub(topic string, msg interface{}) error
  • func (n *Nsg) Stop()
  • func (n *Nsg) Sub(handler HandlerFunc) error

Types

type HandlerFunc

type HandlerFunc func(message *Message) error

func (HandlerFunc) HandlerMessage

func (h HandlerFunc) HandlerMessage(message *Message) error

HandleMessage implements the Handler interface

type Message

type Message struct {
	*nsq.Message
}

type Msg

type Msg interface {
	NewProducer() Msg                                 // new producer
	NewConsumer(topic, channel string) Msg            // new consumer
	Stop()                                            // consumer Stop
	Pub(topic string, msg interface{}) error          // pub interface{} message
	MultiPub(topic string, msgs ...interface{}) error // MultiPub ...interface{} message
	Sub(handler HandlerFunc) error                    // sub func to handle your work
}

message platform

func NewConsumer

func NewConsumer(topic, channel string, params ...interface{}) (msg Msg)

new consumer

func NewProducer

func NewProducer(params ...interface{}) (msg Msg)

new producer

type Nsg

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

nsq

func (*Nsg) MultiPub

func (n *Nsg) MultiPub(topic string, msgs ...interface{}) error

func (*Nsg) NewConsumer

func (n *Nsg) NewConsumer(topic, channel string) Msg

func (*Nsg) NewProducer

func (n *Nsg) NewProducer() Msg

func (*Nsg) Pub

func (n *Nsg) Pub(topic string, msg interface{}) error

func (*Nsg) Stop

func (n *Nsg) Stop()

func (*Nsg) Sub

func (n *Nsg) Sub(handler HandlerFunc) error