simple

Documentation

Index

• type Consumer
  • func NewSimpleConsumer(url, exchangeName, queueName string, chanNumber int) (*Consumer, error)
  • func (c *Consumer) Declare()
  • func (c *Consumer) Destroy()
  • func (c *Consumer) OnConnectionErrorReConnection()
  • func (c *Consumer) Received(autoAck bool, handler func(receiveData, objectType string) error)
• type Producer
  • func NewSimpleProducer(url, exchangeName, queueName string) (*Producer, error)
  • func (p *Producer) Close()
  • func (p *Producer) OnConnectionErrorReConnection()
  • func (p *Producer) Send(data, routeKey, expire, objectType string) error

Types

type Consumer

type Consumer struct {
	// contains filtered or unexported fields
}

func NewSimpleConsumer

func NewSimpleConsumer(url, exchangeName, queueName string, chanNumber int) (*Consumer, error)

NewSimpleConsumer 创建一个新的 Consumer 实例 url 示例: amqp://user:password@addr:5672/

func (*Consumer) Declare

func (c *Consumer) Declare()

Declare 队列绑定

func (*Consumer) Destroy

func (c *Consumer) Destroy()

func (*Consumer) OnConnectionErrorReConnection

func (c *Consumer) OnConnectionErrorReConnection()

OnConnectionErrorReConnection 连接错误，自动重连

func (*Consumer) Received

func (c *Consumer) Received(autoAck bool, handler func(receiveData, objectType string) error)

Received 通过回调函数处理接收到的消息

type Producer

type Producer struct {
	// contains filtered or unexported fields
}

func NewSimpleProducer

func NewSimpleProducer(url, exchangeName, queueName string) (*Producer, error)

NewSimpleProducer 创建一个新的 Producer 实例

func (*Producer) Close

func (p *Producer) Close()

Close 手动关闭连接

func (*Producer) OnConnectionErrorReConnection

func (p *Producer) OnConnectionErrorReConnection()

OnConnectionErrorReConnection 监听连接错误，自动重连

func (*Producer) Send

func (p *Producer) Send(data, routeKey, expire, objectType string) error

Send 发送数据，channel 复用