rabbitmq

Documentation

Index

• type Consumer
• type Option
• type Options
• type Producer
• type Queue
• type RabbitMQ
  • func (mq *RabbitMQ) Destroy() error

Types

type Consumer

type Consumer interface {
	Consumer(msg string) error
}

Consumer 消费者

type Option

type Option func(*Options)

type Options

type Options struct {
	User   string
	Pwd    string
	Host   string
	Port   int
	Queues []*Queue
}

type Producer

type Producer interface {
	Publish() interface{}
}

Producer 生产者

type Queue

type Queue struct {
	Name     string
	Exchange string
	Key      string
}

type RabbitMQ

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

func (*RabbitMQ) Destroy

func (mq *RabbitMQ) Destroy() error