pub_sub

Documentation

Index

• Constants
• func Init()
• func Publish(topic string, data interface{}) error
• func Subscribe(topic string, onMessageReceive OnMessageReceive, args ...interface{}) <-chan struct{}
• type OnMessageReceive
• type ReSendMsg

Constants

const (
	ExchangeName       = "Go-Sub-Pub-Exchange"
	ExchangeNameBackup = "Go-Sub-Pub-Exchange-Backup"
)

Functions

func Init

func Init()

func Publish

func Publish(topic string, data interface{}) error

func Subscribe

func Subscribe(topic string, onMessageReceive OnMessageReceive, args ...interface{}) <-chan struct{}

Types

type OnMessageReceive

type OnMessageReceive func(data interface{}) bool

type ReSendMsg

type ReSendMsg struct {
	RetryTimes    uint8
	NextRetryTime int64
	Data          interface{}
}