client

Documentation

Index

• Constants
• type Conn
  • func NewConn(addr, user, pass, vhost string) (*Conn, error)
  • func NewConnWithConfig(config *rabbitmq.Config) (*Conn, error)
  • func NewConnWithDefault(addr, user, pass string) (*Conn, error)
  • func (c *Conn) Close() error

Constants

const (
	ExchangeTyeDirect   = "direct"
	ExchangeTypeFanout  = "fanout"
	ExchangeTypeTopic   = "topic"
	ExchangeTypeHeaders = "headers"
	DefaultExchangeType = ExchangeTypeTopic
)

Types

type Conn

type Conn struct {
	Config *rabbitmq.Config
	*amqp.Connection
}

func NewConn

func NewConn(addr, user, pass, vhost string) (*Conn, error)

NewConn returns a new *Conn

func NewConnWithConfig

func NewConnWithConfig(config *rabbitmq.Config) (*Conn, error)

NewConnWithConfig returns a new *Conn with given config

func NewConnWithDefault

func NewConnWithDefault(addr, user, pass string) (*Conn, error)

NewConnWithDefault returns a new *Conn with default values

func (*Conn) Close

func (c *Conn) Close() error

Close closes the connection