rabbitmq

README

rabbitmq

rabbitmq client based on amqp

Documentation

Index

• Constants
• func NewTlsConfig(caFile, certFile, keyFile, keyFilePassword string) *tls.Config
• type Client
  • func NewClient(cfg *Config) *Client
  • func (c *Client) AddMessageConsumer(consumer func(msg amqp.Delivery))
  • func (c *Client) AddReplyConsumer(consumer func(msg amqp.Delivery))
  • func (c *Client) GetQueueName() string
  • func (c *Client) Publish(exchange, routeKey string, msg amqp.Publishing, confirm bool) (err error)
  • func (c *Client) Start() (err error)
• type Config
  • func NewConfig() *Config
• type Confirm
• type Exchange

Constants

const (
	TYPE_REPLY  = "REPLY"
	TYPE_SIMPLE = "SIMPLE"
)

Functions

func NewTlsConfig

func NewTlsConfig(caFile, certFile, keyFile, keyFilePassword string) *tls.Config

Types

type Client

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

func NewClient

func NewClient(cfg *Config) *Client

func (*Client) AddMessageConsumer

func (c *Client) AddMessageConsumer(consumer func(msg amqp.Delivery))

func (*Client) AddReplyConsumer

func (c *Client) AddReplyConsumer(consumer func(msg amqp.Delivery))

func (*Client) GetQueueName

func (c *Client) GetQueueName() string

func (*Client) Publish

func (c *Client) Publish(exchange, routeKey string,
	msg amqp.Publishing, confirm bool) (err error)

func (*Client) Start

func (c *Client) Start() (err error)

type Config

type Config struct {
	HostPort            string
	Username            string
	Password            string
	Prefetch            int
	Exchanges           []Exchange
	QueuePrefix         string
	QueueName           string
	QueueAutoDelete     bool
	QueueEnable         bool
	UseTls              bool
	ReplyConfirmTimeout time.Duration
	Amqp                amqp.Config
}

func NewConfig

func NewConfig() *Config

type Confirm

type Confirm struct {
	NeedConfirm bool
	ReplyTo     []string
	Timeout     time.Duration
}

type Exchange

type Exchange struct {
	Name string
	Kind string
}