Fix initialize queue to bull

Giveth · Jan 6, 2022 · f32606d · f32606d
1 parent da10f2b
commit f32606d
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/src/analytics/segmentQueue.ts b/src/analytics/segmentQueue.ts
@@ -6,7 +6,9 @@ import { sleep } from '../utils/utils';
 import { redisConfig } from '../redis';
 const analytics = getAnalytics();
 
-const sendSegmentEventQueue = new Bull('send-segment-event', redisConfig);
+const sendSegmentEventQueue = new Bull('send-segment-event',  {
+  redis: redisConfig,
+});
 
 const numberOfVerifyDonationConcurrentJob = 1;
 

diff --git a/src/services/syncDonationsWithNetwork.ts b/src/services/syncDonationsWithNetwork.ts
@@ -9,7 +9,9 @@ import Bull from 'bull';
 import config from '../config';
 import { redisConfig } from '../redis';
 
-const verifyDonationsQueue = new Bull('verify-donations-queue', redisConfig);
+const verifyDonationsQueue = new Bull('verify-donations-queue', {
+  redis: redisConfig,
+});
 const TWO_MINUTES = 1000 * 60 * 2;
 setInterval(async () => {
   const verifyDonationsQueueCount = await verifyDonationsQueue.count();