wxamqp

Feb 17, 2022

Changes in this version

type AmqpChannel

+ func (a *AmqpChannel) SendToExchangeWithType(exchangeName string, routingKey string, body string, contentType string) error

+ func (a *AmqpChannel) SendToQueueWithType(queueName string, body string, contentType string) error

Feb 10, 2022

Changes in this version

type AmqpChannel

+ func (a *AmqpChannel) DeleteExchange(exchangeName string) error

+ func (a *AmqpChannel) DeleteQueue(queueName string) error

Feb 9, 2022

Changes in this version

+ var ErrDisconnect = errors.New("channel 断线")

+ type AmqpChannel struct

+ func NewAmqpChannel(amqpConnection *AmqpConnection) *AmqpChannel

+ func (a *AmqpChannel) AddConsumer(queueName string, consumerName string, prefetch int) chan amqp.Delivery

+ func (a *AmqpChannel) Bind(queueName string, routingKey string, exchangeName string) error

+ func (a *AmqpChannel) Close()

+ func (a *AmqpChannel) DeclareExchange(exchangeName, kind string, durable, autoDelete bool) error

+ func (a *AmqpChannel) DeclareQueue(queueName string, durable bool, autoDelete bool) (string, error)

+ func (a *AmqpChannel) RemoveConsumer(consumerName string)

+ func (a *AmqpChannel) SendToExchange(exchangeName string, routingKey string, body string) error

+ func (a *AmqpChannel) SendToQueue(queueName string, body string) error

+ func (a *AmqpChannel) Unbind(queueName string, routingKey string, exchangeName string) error

+ type AmqpConnection struct

+ func NewAmqpConnection(username string, password string, host string, port int, vhost string) *AmqpConnection

+ func (a *AmqpConnection) Disconnect()

+ type WxAmqp struct

+ func NewWxAmqp(username string, password string, host string, port int) *WxAmqp

+ func NewWxAmqpWithVhost(username string, password string, host string, port int, vhost string) *WxAmqp

+ func (a *WxAmqp) DisConnect()

+ func (a *WxAmqp) GetChannel() *AmqpChannel