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 Connection
  • func Dial(url string) (*Connection, error)
  • func DialConfig(url string, config amqp.Config) (*Connection, error)
  • func (c *Connection) Channel() (*Channel, error)

Variables

var Debug bool

Debug debug log flag

var Delay time.Duration = 3

Delay reconnect after delay seconds

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 wrap 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 Connection

type Connection struct {
	*amqp.Connection
}

Connection amqp.Connection wrapper

func Dial

func Dial(url string) (*Connection, error)

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

func DialConfig

func DialConfig(url string, config amqp.Config) (*Connection, error)

DialConfig dial and get a reconnect connection with config

func (*Connection) Channel

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

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