fix: remove ensureQueueExists

wavezync · Sep 10, 2024 · 5939862 · 5939862
1 parent 393cd73
commit 5939862
Showing 1 changed file with 4 additions and 11 deletions.
diff --git a/lib/pgboss.service.ts b/lib/pgboss.service.ts
@@ -21,7 +21,7 @@ export class PgBossService {
     data: TData,
     options?: PgBoss.SendOptions,
   ) {
-    await this.ensureQueueExists(name);
+    await this.pgBoss.createQueue(name);
     await this.pgBoss.send(name, data, options);
   }
 
@@ -31,7 +31,7 @@ export class PgBossService {
     data?: TData,
     options?: PgBoss.ScheduleOptions,
   ) {
-    await this.ensureQueueExists(name);
+    await this.pgBoss.createQueue(name);
     await this.pgBoss.schedule(name, cron, data ?? {}, options ?? {});
   }
 
@@ -42,7 +42,7 @@ export class PgBossService {
     data?: TData,
     options?: PgBoss.ScheduleOptions,
   ) {
-    await this.ensureQueueExists(name);
+    await this.pgBoss.createQueue(name);
     await this.pgBoss.schedule(name, cron, data ?? {}, options ?? {});
     await this.pgBoss.work<TData>(
       name,
@@ -56,18 +56,11 @@ export class PgBossService {
     handler: WorkWithMetadataHandler<TData>,
     options?: PgBoss.WorkOptions,
   ) {
-    await this.ensureQueueExists(name);
+    await this.pgBoss.createQueue(name);
     await this.pgBoss.work<TData>(
       name,
       { ...options, includeMetadata: true },
       handler,
     );
   }
-
-  async ensureQueueExists(queueName: string) {
-    const currentQueue = await this.pgBoss.getQueue(queueName);
-    if (!currentQueue) {
-      await this.pgBoss.createQueue(queueName);
-    }
-  }
 }