README
¶
gmq
Message Queue for Golang
Documentation
¶
Index ¶
Constants ¶
const ( EXCHANGE_TYPE_DIRECT string = "direct" EXCHANGE_TYPE_FANOUT string = "fanout" EXCHANGE_TYPE_TOPIC string = "topic" )
Variables ¶
This section is empty.
Functions ¶
func NewRabbitMqTransport ¶
func NewRabbitMqTransport(channelName string, option RabbitMqOption) gevent.ITransport
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ * 初始化RabbitMqTransport * ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
Types ¶
type IRabbitMessage ¶
type IRabbitMessage interface {
Publish(routingKey, body string) error
Consume(routingKey, queueName string, args ...string) (<-chan amqp_api.Delivery, error)
}
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ * IRabbitMessage消息接口 * ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
func NewRabbitMq ¶
func NewRabbitMq(option RabbitMqOption) IRabbitMessage
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ * 初始化RabbitMq Client * ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
type RabbitMqOption ¶
type RabbitMqOption struct {
Username string
Password string
Ip string
Port int
VirtualHost string
Exchange string
ExchangeType string
IsAutoAck bool
IsPersistent bool
}
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ * RabbitMqOption选项 * ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
Source Files