Documentation ¶
Index ¶
- Variables
- func Connect() error
- func Disconnect() error
- func Init(opts ...mq.Option) error
- func NewMQ(opts ...mq.Option) mq.MQ
- func Publish(topic string, msg *mq.Message, opts ...mq.PublishOption) error
- func String() string
- func Subscribe(topic string, handler mq.Handler, opts ...mq.SubscribeOption) (mq.Subscriber, error)
- func ValidateConnectingAddress(addr []string) error
Constants ¶
This section is empty.
Variables ¶
View Source
var (
DefaultMQ = NewMQ()
)
Functions ¶
func Disconnect ¶
func Disconnect() error
func Subscribe ¶
func Subscribe(topic string, handler mq.Handler, opts ...mq.SubscribeOption) (mq.Subscriber, error)
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.