rabbitmq

Documentation

Index

• Variables
• type Channel
  • func (ch *Channel) Ack(tag uint64, multiple bool) error
  • func (ch *Channel) Cancel(consumer string, noWait bool) error
  • func (ch *Channel) Close() error
  • func (ch *Channel) Confirm(noWait bool) error
  • func (ch *Channel) Consume(queue, consumer string, autoAck, exclusive, noLocal, noWait bool, ...) (<-chan amqp.Delivery, error)
  • func (ch *Channel) ExchangeBind(destination, key, source string, noWait bool, args amqp.Table) error
  • func (ch *Channel) ExchangeDeclare(name, kind string, durable, autoDelete, internal, noWait bool, args amqp.Table) error
  • func (ch *Channel) ExchangeDeclarePassive(name, kind string, durable, autoDelete, internal, noWait bool, args amqp.Table) error
  • func (ch *Channel) ExchangeDelete(name string, ifUnused, noWait bool) error
  • func (ch *Channel) ExchangeUnbind(destination, key, source string, noWait bool, args amqp.Table) error
  • func (ch *Channel) Flow(active bool) error
  • func (ch *Channel) Get(queue string, autoAck bool) (msg amqp.Delivery, ok bool, err error)
  • func (ch *Channel) Nack(tag uint64, multiple bool, requeue bool) error
  • func (ch *Channel) NotifyCancel(c chan string) chan string
  • func (ch *Channel) NotifyClose(c chan *amqp.Error) chan *amqp.Error
  • func (ch *Channel) NotifyConfirm(ack, nack chan uint64) (chan uint64, chan uint64)
  • func (ch *Channel) NotifyFlow(c chan bool) chan bool
  • func (ch *Channel) NotifyPublish(confirm chan amqp.Confirmation) chan amqp.Confirmation
  • func (ch *Channel) NotifyReturn(c chan amqp.Return) chan amqp.Return
  • func (ch *Channel) Publish(exchange, key string, mandatory, immediate bool, msg amqp.Publishing) error
  • func (ch *Channel) Qos(prefetchCount, prefetchSize int, global bool) error
  • func (ch *Channel) QueueBind(name, key, exchange string, noWait bool, args amqp.Table) error
  • func (ch *Channel) QueueDeclare(name string, durable, autoDelete, exclusive, noWait bool, args amqp.Table) (amqp.Queue, error)
  • func (ch *Channel) QueueDeclarePassive(name string, durable, autoDelete, exclusive, noWait bool, args amqp.Table) (amqp.Queue, error)
  • func (ch *Channel) QueueDelete(name string, ifUnused, ifEmpty, noWait bool) (int, error)
  • func (ch *Channel) QueueInspect(name string) (amqp.Queue, error)
  • func (ch *Channel) QueuePurge(name string, noWait bool) (int, error)
  • func (ch *Channel) QueueUnbind(name, key, exchange string, args amqp.Table) error
  • func (ch *Channel) Recover(requeue bool) error
  • func (ch *Channel) Reject(tag uint64, requeue bool) error
  • func (ch *Channel) Tx() error
  • func (ch *Channel) TxCommit() error
  • func (ch *Channel) TxRollback() error
• type Connection
  • func Dial(url string) (*Connection, error)
  • func DialConfig(url string, config amqp.Config) (*Connection, error)
  • func (c *Connection) Channel() (*Channel, error)
  • func (c *Connection) Close() error
  • func (c *Connection) ConnectionState() tls.ConnectionState
  • func (c *Connection) IsClosed() bool
  • func (c *Connection) LocalAddr() net.Addr
  • func (c *Connection) NotifyBlocked(receiver chan amqp.Blocking) chan amqp.Blocking
  • func (c *Connection) NotifyClose(receiver chan *amqp.Error) chan *amqp.Error

Variables

var Debug bool

var ReconnectDelay = time.Second * 3

Types

type Channel

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

func (*Channel) Ack

func (ch *Channel) Ack(tag uint64, multiple bool) error

func (*Channel) Cancel

func (ch *Channel) Cancel(consumer string, noWait bool) error

func (*Channel) Close

func (ch *Channel) Close() error

func (*Channel) Confirm

func (ch *Channel) Confirm(noWait bool) error

func (*Channel) Consume

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

func (*Channel) ExchangeBind

func (ch *Channel) ExchangeBind(destination, key, source string, noWait bool, args amqp.Table) error

func (*Channel) ExchangeDeclare

func (ch *Channel) ExchangeDeclare(name, kind string, durable, autoDelete, internal, noWait bool, args amqp.Table) error

func (*Channel) ExchangeDeclarePassive

func (ch *Channel) ExchangeDeclarePassive(name, kind string, durable, autoDelete, internal, noWait bool, args amqp.Table) error

func (*Channel) ExchangeDelete

func (ch *Channel) ExchangeDelete(name string, ifUnused, noWait bool) error

func (*Channel) ExchangeUnbind

func (ch *Channel) ExchangeUnbind(destination, key, source string, noWait bool, args amqp.Table) error

func (*Channel) Flow

func (ch *Channel) Flow(active bool) error

func (*Channel) Get

func (ch *Channel) Get(queue string, autoAck bool) (msg amqp.Delivery, ok bool, err error)

func (*Channel) Nack

func (ch *Channel) Nack(tag uint64, multiple bool, requeue bool) error

func (*Channel) NotifyCancel

func (ch *Channel) NotifyCancel(c chan string) chan string

func (*Channel) NotifyClose

func (ch *Channel) NotifyClose(c chan *amqp.Error) chan *amqp.Error

func (*Channel) NotifyConfirm

func (ch *Channel) NotifyConfirm(ack, nack chan uint64) (chan uint64, chan uint64)

func (*Channel) NotifyFlow

func (ch *Channel) NotifyFlow(c chan bool) chan bool

func (*Channel) NotifyPublish

func (ch *Channel) NotifyPublish(confirm chan amqp.Confirmation) chan amqp.Confirmation

func (*Channel) NotifyReturn

func (ch *Channel) NotifyReturn(c chan amqp.Return) chan amqp.Return

func (*Channel) Publish

func (ch *Channel) Publish(exchange, key string, mandatory, immediate bool, msg amqp.Publishing) error

func (*Channel) Qos

func (ch *Channel) Qos(prefetchCount, prefetchSize int, global bool) error

func (*Channel) QueueBind

func (ch *Channel) QueueBind(name, key, exchange string, noWait bool, args amqp.Table) error

func (*Channel) QueueDeclare

func (ch *Channel) QueueDeclare(name string, durable, autoDelete, exclusive, noWait bool, args amqp.Table) (amqp.Queue, error)

func (*Channel) QueueDeclarePassive

func (ch *Channel) QueueDeclarePassive(name string, durable, autoDelete, exclusive, noWait bool, args amqp.Table) (amqp.Queue, error)

func (*Channel) QueueDelete

func (ch *Channel) QueueDelete(name string, ifUnused, ifEmpty, noWait bool) (int, error)

func (*Channel) QueueInspect

func (ch *Channel) QueueInspect(name string) (amqp.Queue, error)

func (*Channel) QueuePurge

func (ch *Channel) QueuePurge(name string, noWait bool) (int, error)

func (*Channel) QueueUnbind

func (ch *Channel) QueueUnbind(name, key, exchange string, args amqp.Table) error

func (*Channel) Recover

func (ch *Channel) Recover(requeue bool) error

func (*Channel) Reject

func (ch *Channel) Reject(tag uint64, requeue bool) error

func (*Channel) Tx

func (ch *Channel) Tx() error

func (*Channel) TxCommit

func (ch *Channel) TxCommit() error

func (*Channel) TxRollback

func (ch *Channel) TxRollback() error

type Connection

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

func Dial

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

func DialConfig

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

func (*Connection) Channel

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

func (*Connection) Close

func (c *Connection) Close() error

func (*Connection) ConnectionState

func (c *Connection) ConnectionState() tls.ConnectionState

func (*Connection) IsClosed

func (c *Connection) IsClosed() bool

func (*Connection) LocalAddr

func (c *Connection) LocalAddr() net.Addr

func (*Connection) NotifyBlocked

func (c *Connection) NotifyBlocked(receiver chan amqp.Blocking) chan amqp.Blocking

func (*Connection) NotifyClose

func (c *Connection) NotifyClose(receiver chan *amqp.Error) chan *amqp.Error