rabbitx

Documentation

Index

• type Apply
• type Config
• type ConsumeHandler
• type RabbitMQ
  • func New(addr string, cfg amqp.Config, f Apply) *RabbitMQ
  • func (r *RabbitMQ) Channel(timeout time.Duration) (*amqp.Channel, error)
  • func (r *RabbitMQ) Close() error
  • func (r *RabbitMQ) Consume(queue, consumer string, autoAck, exclusive, noLocal, noWait bool, ...)
  • func (r *RabbitMQ) Produce(exchange, key string, mandatory, immediate bool, data []byte) error

Types

type Apply

type Apply func(ch *amqp.Channel) error

Apply 应用方法

type Config

type Config struct {
	Address    string `mapstructure:"address"`     // rabbitmq连接地址
	VHost      string `mapstructure:"vhost"`       // 虚拟路径
	Heartbeat  int    `mapstructure:"heartbeat"`   // 心跳间隔时间
	Exchange   string `mapstructure:"exchange"`    // 交换机名称
	Queue      string `mapstructure:"queue"`       // 队列名称
	RoutingKey string `mapstructure:"routing_key"` // 路由
}

Config 消息队列配置信息

type ConsumeHandler

type ConsumeHandler func(d amqp.Delivery) error

ConsumeHandler 消费者监听

type RabbitMQ

type RabbitMQ struct {
	Address string      // 连接地址
	Config  amqp.Config // 连接配置
	// contains filtered or unexported fields
}

RabbitMQ 消息队列实例

func New

func New(addr string, cfg amqp.Config, f Apply) *RabbitMQ

New 创建RabbitMQ

func (*RabbitMQ) Channel

func (r *RabbitMQ) Channel(timeout time.Duration) (*amqp.Channel, error)

Channel 获取通道

func (*RabbitMQ) Close

func (r *RabbitMQ) Close() error

Close 关闭连接

func (*RabbitMQ) Consume

func (r *RabbitMQ) Consume(queue, consumer string, autoAck, exclusive, noLocal, noWait bool, args amqp.Table, handler ConsumeHandler)

Consume 消费方法

func (*RabbitMQ) Produce

func (r *RabbitMQ) Produce(exchange, key string, mandatory, immediate bool, data []byte) error

Produce 生产消息