mq

Documentation

Index

• type MQHandler
• type MessageQueue

Types

type MQHandler

type MQHandler interface {
	OnMessage(interface{}) error
	OnTimeout() error
}

type MessageQueue

type MessageQueue interface {
	Subscribe(string, MQHandler)
	Publish(string, interface{}) error
	Unsubscribe(string)
	io.Closer
}