rabbitmq

Documentation

Index

• Variables
• type Channel
  • func (ch *Channel) Close() error
  • func (ch *Channel) Consume(queue, consumer string, autoAck, exclusive, noLocal, noWait bool, ...) (<-chan amqp.Delivery, error)
  • func (ch *Channel) IsClosed() bool
• type Config
• type Connection
  • func Dial(url string, conf *Config, tlsconf *tls.Config) (*Connection, error)
  • func (c *Connection) Channel() (*Channel, error)

Variables

var Debug bool

Debug debug log flag

Types

type Channel

type Channel struct {
	*amqp.Channel
	// contains filtered or unexported fields
}

Channel amqp.Channel wapper

func (*Channel) Close

func (ch *Channel) Close() error

Close ensure closed flag set

func (*Channel) Consume

func (ch *Channel) Consume(queue, consumer string, autoAck, exclusive, noLocal, noWait bool, args amqp.Table) (<-chan amqp.Delivery, error)

Consume warp amqp.Channel.Consume, the returned delivery will end only when channel closed by developer

func (*Channel) IsClosed

func (ch *Channel) IsClosed() bool

IsClosed indicate closed by developer

type Config

type Config struct {
	Qos int
}

type Connection

type Connection struct {
	*amqp.Connection
	*Config
}

Connection amqp.Connection wrapper

func Dial

func Dial(url string, conf *Config, tlsconf *tls.Config) (*Connection, error)

Dial wrap amqp.Dial / amqp.DialTLS, dial and get a reconnect connection

func (*Connection) Channel

func (c *Connection) Channel() (*Channel, error)

Channel wrap amqp.Connection.Channel, get a auto reconnect channel