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 DialCluster(urls []string) (*Connection, error)
  • func (c *Connection) Channel() (*Channel, error)
  • func (c *Connection) OnChannelFail(f func(e *amqp.Error))
  • func (c *Connection) OnChannelRestore(f func())
  • func (c *Connection) OnConnectionFail(f func(e *amqp.Error))
  • func (c *Connection) OnReconnect(f func())

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 Connection

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

Connection amqp.Connection wrapper

func Dial

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

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

func DialCluster

func DialCluster(urls []string) (*Connection, error)

DialCluster with reconnect

func (*Connection) Channel

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

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

func (*Connection) OnChannelFail

func (c *Connection) OnChannelFail(f func(e *amqp.Error))

func (*Connection) OnChannelRestore

func (c *Connection) OnChannelRestore(f func())

func (*Connection) OnConnectionFail

func (c *Connection) OnConnectionFail(f func(e *amqp.Error))

func (*Connection) OnReconnect

func (c *Connection) OnReconnect(f func())