import { QueueBaseService } from './queue-base.service';
import { WorkflowInMemoryProviderService } from '../in-memory-provider';
import { IProcessSubscriberBulkJobDto, IProcessSubscriberJobDto } from '../../dtos/process-subscriber-job.dto';
export declare class SubscriberProcessQueueService extends QueueBaseService {
    workflowInMemoryProviderService: WorkflowInMemoryProviderService;
    private readonly LOG_CONTEXT;
    constructor(workflowInMemoryProviderService: WorkflowInMemoryProviderService);
    add(data: IProcessSubscriberJobDto): Promise<void>;
    addBulk(data: IProcessSubscriberBulkJobDto[]): Promise<void>;
}
//# sourceMappingURL=subscriber-process-queue.service.d.ts.map