rabbitmq

Documentation

Index

• type RabbitMQ
  • func New() *RabbitMQ
  • func (r *RabbitMQ) Close()
  • func (r *RabbitMQ) ConsumeMessages() (<-chan amqp091.Delivery, error)
  • func (r *RabbitMQ) PublishMessage(message []byte) error

Types

type RabbitMQ

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

func New

func New() *RabbitMQ

func (*RabbitMQ) Close

func (r *RabbitMQ) Close()

func (*RabbitMQ) ConsumeMessages

func (r *RabbitMQ) ConsumeMessages() (<-chan amqp091.Delivery, error)

func (*RabbitMQ) PublishMessage

func (r *RabbitMQ) PublishMessage(message []byte) error