integration

Documentation

Index

• type ConnectionRabbitMQ
  • func GetConnectionRabbit(rabbitURL string) (ConnectionRabbitMQ, error)
  • func (conn ConnectionRabbitMQ) PublishRabbitMQ(routingKey string, data []byte, exchange string) error
  • func (conn ConnectionRabbitMQ) StartQueeConsumer(queueName, routingKey string, handler func(d amqp.Delivery) bool, ...) error

Types

type ConnectionRabbitMQ

type ConnectionRabbitMQ struct {
	Conn    *amqp.Connection
	Channel *amqp.Channel
}

ConnectionRabbitMQ - connect struct rabbitMQ

func GetConnectionRabbit

func GetConnectionRabbit(rabbitURL string) (ConnectionRabbitMQ, error)

GetConnectionRabbit - get connection rabbitMQ

func (ConnectionRabbitMQ) PublishRabbitMQ

func (conn ConnectionRabbitMQ) PublishRabbitMQ(routingKey string, data []byte, exchange string) error

PublishRabbitMQ - publish rabbitMQ queue

func (ConnectionRabbitMQ) StartQueeConsumer

func (conn ConnectionRabbitMQ) StartQueeConsumer(queueName, routingKey string, handler func(d amqp.Delivery) bool, concurrency int) error

StartQueeConsumer - handle