rabbitmq

Documentation

Index

• type Consumer
  • func NewConsumer(amqpURI string) (*Consumer, error)
  • func (p *Consumer) Close() error
  • func (p *Consumer) Consumer(ctx context.Context, exchange, exchangeType, queueName, key, tag string, ...)
• type Payload
• type Producer
  • func NewProducer(amqpURI string) (*Producer, error)
  • func (p *Producer) Close() error
  • func (p *Producer) Producer(exchange, exchangeType, queueName, routingKey, body string, reliable bool) error

Types

type Consumer

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

func NewConsumer

func NewConsumer(amqpURI string) (*Consumer, error)

func (*Consumer) Close

func (p *Consumer) Close() error

关闭

func (*Consumer) Consumer

func (p *Consumer) Consumer(ctx context.Context, exchange, exchangeType, queueName, key, tag string, handle func(string, uint64, []byte) error)

消费

type Payload

type Payload struct {
	Exchange     string
	ExchangeType string
	QueueName    string
	Key          string
	Tag          string
	Handle       func(string, uint64, []byte) error
}

type Producer

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

func NewProducer

func NewProducer(amqpURI string) (*Producer, error)

初始化

func (*Producer) Close

func (p *Producer) Close() error

关闭

func (*Producer) Producer

func (p *Producer) Producer(exchange, exchangeType, queueName, routingKey, body string, reliable bool) error

生产