rabbitmqgo

README

rabbitmq-go

A simple repository to use rabbitmq in go

Documentation

Index

• type RabbitMQ
  • func NewRabbitMq(cnf RabbitMQConfig) RabbitMQ
• type RabbitMQConfig

Types

type RabbitMQ

type RabbitMQ interface {
	Publish(message []byte) error
	Consume(name string, prefetch int, handler func([]byte) error) error
	GetStats() (amqp.Queue, error)
	// contains filtered or unexported methods
}

func NewRabbitMq

func NewRabbitMq(cnf RabbitMQConfig) RabbitMQ

type RabbitMQConfig

type RabbitMQConfig struct {
	// contains filtered or unexported fields
}