producer

Documentation

Index

• Constants
• type MQProducer
  • func (p *MQProducer) Init(options ...Option)
• type Option
  • func Addr(addr string) Option
  • func Args(args map[string]interface{}) Option
  • func ExchangeName(exchangeName string) Option
  • func ExchangeType(exchangeType string) Option
  • func QueueName(queueName string) Option
  • func RoutingKey(routingKey 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"
	DefaultRoutingKey   = "rmq-key"
	DefaultExchangeName = "rmq-ex"
	DefaultExchangeType = "direct"
)

Types

type MQProducer

type MQProducer struct {
	Producer *producer
}

func (*MQProducer) Init

func (p *MQProducer) Init(options ...Option)

Init creates a new consumer state instance, and automatically attempts to connect to the server.

type Option

type Option func(*Options)

func Addr

func Addr(addr string) Option

func Args

func Args(args map[string]interface{}) Option

func ExchangeName

func ExchangeName(exchangeName string) Option

func ExchangeType

func ExchangeType(exchangeType string) Option

func QueueName

func QueueName(queueName string) Option

func RoutingKey

func RoutingKey(routingKey string) Option

func VirtualHost

func VirtualHost(virtualHost string) Option

type Options

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