Documentation
¶
Index ¶
- type AMQP
- func (ai *AMQP) Close() error
- func (ai *AMQP) CreateConsumer(exchange, key, kind, queue string, durable bool, ...) (<-chan amqp.Delivery, error)
- func (ai *AMQP) NotifyClose(c chan *amqp.Error) chan *amqp.Error
- func (ai *AMQP) Publish(exchange, key string, opts amqp.Publishing) error
- func (ai *AMQP) WithExchange(exchange, kind string, durable bool) error
- func (ai *AMQP) WithQos(count, size int, global bool) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AMQP ¶
type AMQP struct {
// contains filtered or unexported fields
}
AMQP interpret (implement) AMQP interface definition
func New ¶
New returns a new AMQP configured, or returning an non-nil err if an error occurred while creating connection or channel.
func (*AMQP) CreateConsumer ¶
func (ai *AMQP) CreateConsumer(exchange, key, kind, queue string, durable bool, declareArgs, bindArgs amqp.Table) (<-chan amqp.Delivery, error)
CreateConsumer creates a amqp consumer. Most interesting declare args are:
func (*AMQP) NotifyClose ¶
NotifyClose wrapper over notifyClose method
func (*AMQP) Publish ¶
func (ai *AMQP) Publish(exchange, key string, opts amqp.Publishing) error
Publish wraps amqp.Publish method
func (*AMQP) WithExchange ¶
WithExchange creates a amqp exchange
Source Files
Click to show internal directories.
Click to hide internal directories.