v3

package
v0.0.0-...-48c9e09 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 23, 2019 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func InitConsumer

func InitConsumer(topic string, channel string, address string)

初始化消费者

func InitProducer

func InitProducer(str string)

func Publish

func Publish(topic string, message string) error

发布消息

func RandString

func RandString(len int) string

func StartReceive

func StartReceive(topic, channel, address string)

func StartSend

func StartSend(n int)

Types

type ConsumerT

type ConsumerT struct{}

消费者

func (*ConsumerT) HandleMessage

func (*ConsumerT) HandleMessage(msg *nsq.Message) error

处理消息

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL