Amqp

Documentation

Index

• Constants
• func ConnectMq(url string) (conn *amqp.Connection, channel *amqp.Channel, err error)
• func NewExclusiveMqConsumer(url, exchange, queue, rkey, ctag string, ack, durable bool) (conn *amqp.Connection, channel *amqp.Channel, deliveries <-chan amqp.Delivery, ...)
• func NewMqConsumer(url, exchange, queue, rkey, ctag string, ack, durable bool) (conn *amqp.Connection, channel *amqp.Channel, deliveries <-chan amqp.Delivery, ...)
• func NewMqExchange(channel *amqp.Channel, name, _type string, durable bool) error
• func NewMqQueue(channel *amqp.Channel, exchange, queue, rkey string, durable, exclusive bool) error
• func PriorityPublish(channel *amqp.Channel, exchange, rkey string, savedisk, priority uint8, ...) error
• func Publish(channel *amqp.Channel, exchange, rkey string, msg []byte) error

Constants

const (
	Transient  uint8 = 1
	Persistent uint8 = 2

	PriorityMax uint8 = 9
	PriorityMin uint8 = 0
)

Functions

func ConnectMq

func ConnectMq(url string) (conn *amqp.Connection, channel *amqp.Channel, err error)

func NewExclusiveMqConsumer

func NewExclusiveMqConsumer(url, exchange, queue, rkey, ctag string, ack, durable bool) (
	conn *amqp.Connection, channel *amqp.Channel, deliveries <-chan amqp.Delivery, err error)

func NewMqConsumer

func NewMqConsumer(url, exchange, queue, rkey, ctag string, ack, durable bool) (
	conn *amqp.Connection, channel *amqp.Channel, deliveries <-chan amqp.Delivery, err error)

func NewMqExchange

func NewMqExchange(channel *amqp.Channel, name, _type string, durable bool) error

func NewMqQueue

func NewMqQueue(channel *amqp.Channel, exchange, queue, rkey string, durable, exclusive bool) error

func PriorityPublish

func PriorityPublish(channel *amqp.Channel, exchange, rkey string, savedisk, priority uint8, msg []byte) error

func Publish

func Publish(channel *amqp.Channel, exchange, rkey string, msg []byte) error