Documentation ¶
Index ¶
- Constants
- func CreateExchange(exchangeName string, kind string, conn *amqp.Connection) error
- func CreateQueueWithEx(queueName string, exchangeName string, routingKey string, ...) error
- func Receive(handler func(msg string), queueName string, conn *amqp.Connection) error
- func SendMsg(msg string, exchangeName string, routingKey string, conn *amqp.Connection) error
- type ConfigRabbitMQ
Constants ¶
View Source
const (
KIND_FANOUT = "fanout"
)
Variables ¶
This section is empty.
Functions ¶
func CreateExchange ¶
func CreateExchange(exchangeName string, kind string, conn *amqp.Connection) error
创建exchange交换机
func CreateQueueWithEx ¶
func CreateQueueWithEx(queueName string, exchangeName string, routingKey string, conn *amqp.Connection) error
创建队列并与exchange绑定
Types ¶
type ConfigRabbitMQ ¶
func (ConfigRabbitMQ) Build ¶
func (stdConfig ConfigRabbitMQ) Build() (*amqp.Connection, error)
创建 mq 连接
Click to show internal directories.
Click to hide internal directories.