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) (<-chan amqp.Delivery, error)
CreateConsumer creates a amqp consumer
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.