assign _findAndLockNextJob to findAndLockNextJob

Signed-off-by: Haris Sulaiman <[email protected]>

Author: harisvsulaiman

lib/agenda/index.ts

@@ -1,13 +1,13 @@
-import humanInterval from "human-interval";
 import { EventEmitter } from "events";
+import humanInterval from "human-interval";
 import {
-  MongoClient,
-  Db as MongoDb,
+  AnyError,
   Collection,
+  Db as MongoDb,
+  MongoClient,
   MongoClientOptions,
-  AnyError,
 } from "mongodb";
-import { JobProcessingQueue } from "./job-processing-queue";
+import { Job } from "../job";
 import { cancel } from "./cancel";
 import { close } from "./close";
 import { create } from "./create";
@@ -20,6 +20,8 @@ import { define } from "./define";
 import { disable } from "./disable";
 import { enable } from "./enable";
 import { every } from "./every";
+import { findAndLockNextJob } from "./find-and-lock-next-job";
+import { JobProcessingQueue } from "./job-processing-queue";
 import { jobs } from "./jobs";
 import { lockLimit } from "./lock-limit";
 import { maxConcurrency } from "./max-concurrency";
@@ -33,8 +35,6 @@ import { schedule } from "./schedule";
 import { sort } from "./sort";
 import { start } from "./start";
 import { stop } from "./stop";
-import { findAndLockNextJob } from "./find-and-lock-next-job";
-import { Job } from "../job";
 
 export interface AgendaConfig {
   name?: string;
@@ -79,7 +79,7 @@ class Agenda extends EventEmitter {
   _defaultLockLifetime: any;
   _defaultLockLimit: any;
   _definitions: any;
-  _findAndLockNextJob: any;
+  _findAndLockNextJob = findAndLockNextJob;
   _indices: any;
   _isLockingOnTheFly: boolean;
   _isJobQueueFilling: Map<string, boolean>;
@@ -192,7 +192,6 @@ class Agenda extends EventEmitter {
   }
 }
 
-Agenda.prototype._findAndLockNextJob = findAndLockNextJob;
 Agenda.prototype.cancel = cancel;
 Agenda.prototype.close = close;
 Agenda.prototype.create = create;