Documentation ¶
Overview ¶
@Description TODO @Author jiangyang @Created 2020/11/21 2:51 下午
Index ¶
- func Close()
- func Conn() *amqp.Connection
- func Consume(queueName string, msgHandler func(amqp.Delivery)) error
- func DirectPublish(excName string, key string, body []byte) error
- func DirectSubscribe(excName string, queueName string, key string, msgHandle func(amqp.Delivery)) error
- func FanoutPublish(excName string, body []byte) error
- func FanoutSubscribe(excName string, queueName string, msgHandle func(amqp.Delivery)) error
- func Init(cfg Config)
- func Produce(queueName string, body []byte) error
- func TopicPublish(excName string, key string, body []byte) error
- func TopicSubscribe(excName string, queueName string, key string, msgHandle func(amqp.Delivery)) error
- type Config
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Conn ¶
func Conn() *amqp.Connection
func DirectSubscribe ¶
func FanoutPublish ¶
func FanoutSubscribe ¶
Types ¶
Click to show internal directories.
Click to hide internal directories.