rabbitmq

Documentation

Index

• type Queue
• type QueueName
• type RabbitMq
  • func New() *RabbitMq
  • func (r *RabbitMq) Connection() *amqp.Connection
  • func (r *RabbitMq) Consume(queues []string, deliveryChannel chan<- amqp.Delivery) error
  • func (r *RabbitMq) ConsumeChannel() *amqp.Channel
  • func (r *RabbitMq) DeclareQueues(queues []*Queue) error
  • func (r *RabbitMq) Publish(exchange string, key string, mandatory bool, immediate bool, ...) error
  • func (r *RabbitMq) PublishChannel() *amqp.Channel

Types

type Queue

type Queue struct {
	MaxPriority uint8
	Name        QueueName
	Ttl         time.Duration
}

type QueueName

type QueueName string

type RabbitMq

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

func New

func New() *RabbitMq

func (*RabbitMq) Connection

func (r *RabbitMq) Connection() *amqp.Connection

func (*RabbitMq) Consume

func (r *RabbitMq) Consume(queues []string, deliveryChannel chan<- amqp.Delivery) error

func (*RabbitMq) ConsumeChannel

func (r *RabbitMq) ConsumeChannel() *amqp.Channel

func (*RabbitMq) DeclareQueues

func (r *RabbitMq) DeclareQueues(queues []*Queue) error

func (*RabbitMq) Publish

func (r *RabbitMq) Publish(exchange string, key string, mandatory bool, immediate bool, msg amqp.Publishing) error

func (*RabbitMq) PublishChannel

func (r *RabbitMq) PublishChannel() *amqp.Channel