consumer

Documentation

Index

• Constants
• type MQConsumer
  • func (c *MQConsumer) Init(options ...Option)
• type Option
  • func Addr(addr string) Option
  • func QueueName(queueName string) Option
  • func TagConsumer(tagConsumer string) Option
  • func VirtualHost(virtualHost string) Option
• type Options

Constants

const (
	DefaultAddr        = "amqp://root:123456@127.0.0.1:5672"
	DefaultVirtualHost = "rmq"
	DefaultQueueName   = "rmq-queue"
	DefaultTagConsumer = "rmq-tag"
)

Types

type MQConsumer

type MQConsumer struct {
	Consumer *consumer
}

func (*MQConsumer) Init

func (c *MQConsumer) Init(options ...Option)

Init

that has been initialized properly essentially don't touch conn, channel, or done, and you can create Consumer manually

type Option

type Option func(*Options)

func Addr

func Addr(addr string) Option

func QueueName

func QueueName(queueName string) Option

func TagConsumer

func TagConsumer(tagConsumer string) Option

func VirtualHost

func VirtualHost(virtualHost string) Option

type Options

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