mq

type ConsumerHandlerImpl struct {
	MysqlManager   *dao.MysqlManagerImpl
	MinioClient    *minio.Client
	SummaryManager *eino.BotManagerImpl
}

type ConsumerManager interface {
	Consume(ctx context.Context, topic string, handler *ConsumerHandlerImpl) error
}

type DLQConsumerManager struct {
	DeadLetterExchange string
	Exchange           string
	// contains filtered or unexported fields
}

type PublisherManagerImpl struct {
	Exchange string
	// contains filtered or unexported fields
}

type SubscriberManagerImpl struct {
	Exchange           string
	DeadLetterExchange string
	// contains filtered or unexported fields
}