fix: remove celery url and default to amqp url (#2051)
This commit is contained in:
@@ -7,7 +7,7 @@ export class CeleryProducer {
|
||||
private mq: MQ | undefined;
|
||||
|
||||
private initQueue = async (options: TMQEntityOptions) => {
|
||||
this.mq = new MQ(options, env.CELERY_AMQP_URL);
|
||||
this.mq = new MQ(options, env.AMQP_URL);
|
||||
await this.mq.connect();
|
||||
logger.info(`Message Queue ${options.queueName} connected successfully 🐇🐇🐰`);
|
||||
};
|
||||
|
||||
@@ -10,7 +10,6 @@ const envSchema = z.object({
|
||||
DEDUP_INTERVAL: z.string().optional().default("2"),
|
||||
DB_URL: z.string().default("postgres://postgres:password@localhost:5432/silo"),
|
||||
AMQP_URL: z.string().default("amqp://guest:guest@localhost:5672"),
|
||||
CELERY_AMQP_URL: z.string().default("amqp://guest:guest@localhost:5672"),
|
||||
REDIS_URL: z.string().default("redis://localhost:6379"),
|
||||
SENTRY_DSN: z.string().optional(),
|
||||
PG_SCHEMA: z.string().optional(),
|
||||
|
||||
Reference in New Issue
Block a user