import { WorkerHost } from "@nestjs/bullmq"; import { Job } from "bullmq"; import { ClsService } from "nestjs-cls"; import { AppLoggingService } from "../../../core/logging/services/logging.service"; import { UserActivityModuleConfig } from "../interfaces/user-activity.config.interface"; import { UserActivityRepository } from "../repositories/user-activity.repository"; /** * Worker-side of `UserActivityService.record()`. * * The queue name must be a compile-time constant because `@Processor()` is * evaluated at class-decoration time — the same constraint every other package * processor lives with (CompanyProcessor, HowToProcessor, ChunkProcessor). The * job name, by contrast, is read from `USER_ACTIVITY_CONFIG` at construction * time, so producer and consumer always agree on it. */ export declare class UserActivityProcessor extends WorkerHost { private readonly logger; private readonly repository; private readonly cls; private readonly jobName; constructor(logger: AppLoggingService, repository: UserActivityRepository, cls: ClsService, config: Required); onError(job: Job): void; process(job: Job): Promise; } //# sourceMappingURL=user-activity.processor.d.ts.map