Documentation ¶
Index ¶
Constants ¶
View Source
const ( DefaultAddr = "amqp://root:123456@127.0.0.1:5672" DefaultVirtualHost = "rmq" DefaultQueueName = "rmq-queue" DefaultRoutingKey = "rmq-key" DefaultExchangeName = "rmq-ex" DefaultExchangeType = "direct" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MQProducer ¶
type MQProducer struct {
Producer *producer
}
func (*MQProducer) Init ¶
func (p *MQProducer) Init(options ...Option)
Init creates a new consumer state instance, and automatically attempts to connect to the server.
type Option ¶
type Option func(*Options)
func ExchangeName ¶
func ExchangeType ¶
func RoutingKey ¶
func VirtualHost ¶
Click to show internal directories.
Click to hide internal directories.