rmq

Documentation

Index

• func UnmarshalMessage(data []byte, v interface{}) error
• type Client
  • func NewClient(log *logger.Logger, cfg *Config) (*Client, error)
  • func (c *Client) Channel() *amqp091.Channel
  • func (c *Client) Close() error
  • func (c *Client) Reconnect() error
• type Config
  • func (c *Config) URL() string
• type Consumer
  • func NewConsumer(log *logger.Logger, client *Client, consumerCfg *ConsumerConfig) *Consumer
  • func (c *Consumer) Start(ctx context.Context) error
  • func (c *Consumer) Stop()
• type ConsumerConfig
• type DelayQueueConfig
• type MessageHandler
• type QueueConfig

Functions

func UnmarshalMessage

func UnmarshalMessage(data []byte, v interface{}) error

Types

type Client

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

func NewClient

func NewClient(log *logger.Logger, cfg *Config) (*Client, error)

func (*Client) Channel

func (c *Client) Channel() *amqp091.Channel

func (*Client) Close

func (c *Client) Close() error

func (*Client) Reconnect

func (c *Client) Reconnect() error

type Config

type Config struct {
	Host     string
	Port     string
	User     string
	Password string
}

func (*Config) URL

func (c *Config) URL() string

type Consumer

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

func NewConsumer

func NewConsumer(log *logger.Logger, client *Client, consumerCfg *ConsumerConfig) *Consumer

func (*Consumer) Start

func (c *Consumer) Start(ctx context.Context) error

func (*Consumer) Stop

func (c *Consumer) Stop()

type ConsumerConfig

type ConsumerConfig struct {
	Main    QueueConfig
	Delay   *DelayQueueConfig
	Dead    *QueueConfig
	Handler MessageHandler
}

type DelayQueueConfig

type DelayQueueConfig struct {
	Queue    string
	MaxRetry int
	TTL      int
}

type MessageHandler

type MessageHandler func(ctx context.Context, message []byte, routingKey string) error

type QueueConfig

type QueueConfig struct {
	Queue          string
	BindingPattern string
	RoutingKey     string
	Exchange       string
	TTL            int
}