mainmq

Documentation

Index

• type RabbitMq
  • func NewRabbitMqQueue(url string) (*RabbitMq, error)
  • func (r *RabbitMq) BindQueue(ctx context.Context, qName, routingKey, exchange string, durable bool) error
  • func (r *RabbitMq) Close(ctx context.Context)
  • func (r *RabbitMq) ConsumeTasksFromQueue(ctx context.Context, qName, consumer string, autoAck bool, ...) error
  • func (r *RabbitMq) DeclareExchange(ctx context.Context, name, kind string, durable bool) error
  • func (r *RabbitMq) DeclareQueue(ctx context.Context, qName string, durable bool) error
  • func (r *RabbitMq) SendTaskToQueue(ctx context.Context, exchange, routingKey string, event *models.Event) error
  • func (r *RabbitMq) SetQos(ctx context.Context, prefetchCount, prefetchSize int, global bool) error

Types

type RabbitMq

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

func NewRabbitMqQueue

func NewRabbitMqQueue(url string) (*RabbitMq, error)

func (*RabbitMq) BindQueue

func (r *RabbitMq) BindQueue(ctx context.Context, qName, routingKey, exchange string, durable bool) error

func (*RabbitMq) Close

func (r *RabbitMq) Close(ctx context.Context)

func (*RabbitMq) ConsumeTasksFromQueue

func (r *RabbitMq) ConsumeTasksFromQueue(ctx context.Context, qName, consumer string, autoAck bool, task func(ctx context.Context, event *models.Event) error) error

func (*RabbitMq) DeclareExchange

func (r *RabbitMq) DeclareExchange(ctx context.Context, name, kind string, durable bool) error

func (*RabbitMq) DeclareQueue

func (r *RabbitMq) DeclareQueue(ctx context.Context, qName string, durable bool) error

func (*RabbitMq) SendTaskToQueue

func (r *RabbitMq) SendTaskToQueue(ctx context.Context, exchange, routingKey string, event *models.Event) error

func (*RabbitMq) SetQos

func (r *RabbitMq) SetQos(ctx context.Context, prefetchCount, prefetchSize int, global bool) error