rocket

Documentation

Index

• func Consumer(messages ...Message)
• func Init()
• func Producer(group, topic string, msg []byte, retry int)
• type Message

Functions

func Consumer

func Consumer(messages ...Message)

Consumer 用于注册消费端

func Init

func Init()

func Producer

func Producer(group, topic string, msg []byte, retry int)

Types

type Message

type Message struct {
	//组和主题地址映射
	Group string
	Topic string
	//实际处理方法
	Handler func(msg string)
}