queue

Documentation

Index

• type MQClient
• type MockRabbitMQClient
  • func (m *MockRabbitMQClient) Close()
  • func (m *MockRabbitMQClient) Publish(id string, msg any, priority uint8) error
• type RabbitMQClient
  • func NewRabbitMQClient(ctx context.Context, connUrl string) (*RabbitMQClient, error)
  • func (c *RabbitMQClient) Close()
  • func (c *RabbitMQClient) Publish(id string, msg any, priority uint8) error
  • func (c *RabbitMQClient) Reconnect() error

Types

type MQClient

type MQClient interface {
	Close()
	Publish(id string, msg any, priority uint8) error
}

type MockRabbitMQClient

type MockRabbitMQClient struct {
	PublishFunc func(id string, msg any, priority uint8) error
}

func (*MockRabbitMQClient) Close

func (m *MockRabbitMQClient) Close()

func (*MockRabbitMQClient) Publish

func (m *MockRabbitMQClient) Publish(id string, msg any, priority uint8) error

type RabbitMQClient

type RabbitMQClient struct {
	Ctx     context.Context
	Channel *amqp.Channel
	Queue   string
	// contains filtered or unexported fields
}

func NewRabbitMQClient

func NewRabbitMQClient(ctx context.Context, connUrl string) (*RabbitMQClient, error)

Create new RabbitMQ amqp client, using amqp:// connection string

func (*RabbitMQClient) Close

func (c *RabbitMQClient) Close()

func (*RabbitMQClient) Publish

func (c *RabbitMQClient) Publish(id string, msg any, priority uint8) error

func (*RabbitMQClient) Reconnect

func (c *RabbitMQClient) Reconnect() error

Reconnect reconnects the connection