import { QueueBaseService } from './queue-base.service'; import { WorkflowInMemoryProviderService } from '../in-memory-provider'; import { IWebSocketBulkJobDto, IWebSocketJobDto } from '../../dtos/web-sockets-job.dto'; export declare class WebSocketsQueueService extends QueueBaseService { workflowInMemoryProviderService: WorkflowInMemoryProviderService; constructor(workflowInMemoryProviderService: WorkflowInMemoryProviderService); add(data: IWebSocketJobDto): Promise; addBulk(data: IWebSocketBulkJobDto[]): Promise; } //# sourceMappingURL=web-sockets-queue.service.d.ts.map