queue

Documentation

Index

• type RabbitMQHandler
  • func NewRabbitMQHandler() *RabbitMQHandler
  • func (r RabbitMQHandler) Channel() *amqp.Channel
  • func (r RabbitMQHandler) Conn() *amqp.Connection
  • func (r RabbitMQHandler) Queue() amqp.Queue

Types

type RabbitMQHandler

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

RabbitMQHandler defines the RabbitMQ handler

func NewRabbitMQHandler

func NewRabbitMQHandler() *RabbitMQHandler

NewRabbitMQHandler creates new RabbitMQHandler

func (RabbitMQHandler) Channel

func (r RabbitMQHandler) Channel() *amqp.Channel

Channel returns the channel property

func (RabbitMQHandler) Conn

func (r RabbitMQHandler) Conn() *amqp.Connection

Conn returns the conn property

func (RabbitMQHandler) Queue

func (r RabbitMQHandler) Queue() amqp.Queue

Queue returns the queue property