import { Logger } from '@n8n/backend-common'; import { WorkflowsConfig } from '@n8n/config'; import { WorkflowPublicationOutbox, WorkflowPublicationOutboxRepository, WorkflowRepository } from '@n8n/db'; import { ErrorReporter } from 'n8n-core'; import { ActivationErrorsService } from '../activation-errors.service'; import { ActiveWorkflowManager } from '../active-workflow-manager'; export declare class WorkflowPublicationOutboxConsumer { private readonly logger; private readonly workflowsConfig; private readonly errorReporter; private readonly outboxRepository; private readonly workflowRepository; private readonly activeWorkflowManager; private readonly activationErrorsService; private pollTimeout; private isPolling; private isShuttingDown; constructor(logger: Logger, workflowsConfig: WorkflowsConfig, errorReporter: ErrorReporter, outboxRepository: WorkflowPublicationOutboxRepository, workflowRepository: WorkflowRepository, activeWorkflowManager: ActiveWorkflowManager, activationErrorsService: ActivationErrorsService); startPolling(): void; stopPolling(): void; shutdown(): void; private schedulePollCycle; private pollCycle; private shouldKeepPolling; private tryProcessRecord; processRecord(record: WorkflowPublicationOutbox): Promise; private tearDownOldTriggers; private registerNewTriggers; private advancePublishedVersion; private finalizePublication; }