fix(core): Initialize queue in the webhook server as well

This commit is contained in:
कारतोफ्फेलस्क्रिप्ट™ 2023-03-23 20:17:02 +01:00
parent 5dd92c6b94
commit 163859b87a

View file

@ -3,6 +3,7 @@ import { LoggerProxy, sleep } from 'n8n-workflow';
import config from '@/config';
import { ActiveExecutions } from '@/ActiveExecutions';
import { WebhookServer } from '@/WebhookServer';
import { Queue } from '@/Queue';
import { BaseCommand } from './BaseCommand';
import { Container } from 'typedi';
@ -79,6 +80,7 @@ export class Webhook extends BaseCommand {
}
async run() {
await Container.get(Queue).init();
await new WebhookServer().start();
this.logger.info('Webhook listener waiting for requests.');