Documentation ¶
Index ¶
- Constants
- type Exchange
- type Rabbitmq
- func (r *Rabbitmq) Connection() (*amqp.Connection, error)
- func (r *Rabbitmq) DeclareChannel(conn *amqp.Connection) (*amqp.Channel, error)
- func (r *Rabbitmq) DeclareConsumer(q amqp091.Queue, ch *amqp091.Channel)
- func (r *Rabbitmq) DeclareExchange(ch *amqp.Channel) error
- func (r *Rabbitmq) DeclareQueue(ch *amqp.Channel) (amqp.Queue, error)
- func (r *Rabbitmq) DeclareQueueBind(ch *amqp.Channel, q amqp.Queue, k string) error
Constants ¶
View Source
const (
Config = "config/config.yaml"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Rabbitmq ¶
func (*Rabbitmq) Connection ¶
func (r *Rabbitmq) Connection() (*amqp.Connection, error)
func (*Rabbitmq) DeclareChannel ¶
func (*Rabbitmq) DeclareConsumer ¶
func (r *Rabbitmq) DeclareConsumer(q amqp091.Queue, ch *amqp091.Channel)
func (*Rabbitmq) DeclareQueue ¶
Click to show internal directories.
Click to hide internal directories.