rmq

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

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

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

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

type DelayQueueConfig struct {
	QueueConfig
	MaxRetry int
}

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

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