Documentation
¶
Index ¶
- type RabbitMQ
- func NewRabbitMQ(url string, exchange string, queue string, key string) (*RabbitMQ, error)
- func NewRabbitMQWithExchange(url string, exchangeName string) (*RabbitMQ, error)
- func NewRabbitMQWithExchangeRoutingKey(url string, exchangeName string, routingKey string) (*RabbitMQ, error)
- func NewRabbitMQWithQueue(url string, queue string) (*RabbitMQ, error)
- func (r *RabbitMQ) ConsumeSimple(do func(m <-chan amqp.Delivery)) (err error)
- func (r *RabbitMQ) PublishPub(msg string) error
- func (r *RabbitMQ) PublishRouting(message string) error
- func (r *RabbitMQ) PublishSimple(msg string) error
- func (r *RabbitMQ) PublishTopic(message string) error
- func (r *RabbitMQ) RecieveRouting(do func(m <-chan amqp.Delivery)) error
- func (r *RabbitMQ) RecieveSub(do func(m <-chan amqp.Delivery)) error
- func (r *RabbitMQ) RecieveTopic(do func(m <-chan amqp.Delivery)) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RabbitMQ ¶
type RabbitMQ struct {
Exchange string //exchange name
Queue string //queue name
Url string //mq url
Key string //bind key
// contains filtered or unexported fields
}
func NewRabbitMQ ¶
create simple type rabbitmq
func NewRabbitMQWithExchange ¶ added in v0.0.19
订阅模式创建RabbitMQ实例
func NewRabbitMQWithExchangeRoutingKey ¶ added in v0.0.19
func NewRabbitMQWithExchangeRoutingKey(url string, exchangeName string, routingKey string) (*RabbitMQ, error)
路由模式 创建RabbitMQ实例
func NewRabbitMQWithQueue ¶ added in v0.0.19
func (*RabbitMQ) ConsumeSimple ¶
func (*RabbitMQ) PublishPub ¶ added in v0.0.19
订阅模式生产
func (*RabbitMQ) PublishRouting ¶ added in v0.0.19
路由模式发送消息
func (*RabbitMQ) PublishSimple ¶
simple type publish msg
func (*RabbitMQ) PublishTopic ¶ added in v0.0.19
话题模式 话题模式发送消息
func (*RabbitMQ) RecieveRouting ¶ added in v0.0.19
路由模式接受消息
func (*RabbitMQ) RecieveSub ¶ added in v0.0.19
订阅模式消费端代码
Source Files
Click to show internal directories.
Click to hide internal directories.