queue

type Config struct {
	ExchangeName    string
	ExchangeType    string // "direct", "topic", "fanout", "headers" - defaults to "direct"
	QueueName       string
	RoutingKey      string
	DLXExchangeName string
	DLQName         string
	DLQRoutingKey   string
}

type ConnectionConfig struct {
	Host     string
	Port     string
	Username string
	Password string
	VHost    string
}

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

type MessageHandler func(msg amqp.Delivery) error

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

type RetryConfig struct {
	MaxRetries     int
	RetryDelayBase int
	MaxRetryDelay  int
}