Software: Apache/2.4.41 (Ubuntu). PHP/8.0.30 

uname -a: Linux apirnd 5.4.0-204-generic #224-Ubuntu SMP Thu Dec 5 13:38:28 UTC 2024 x86_64 

uid=33(www-data) gid=33(www-data) groups=33(www-data) 

Safe-mode: OFF (not secure)

/var/www/html/sync/   drwxr-xr-x
Free 13.29 GB of 57.97 GB (22.93%)
                            Encoder    Tools    Proc.    FTP brute    Sec.    SQL    PHP-code    Update    Self remove    Logout    

Viewing file:     worker.js (1.49 KB)      -rw-r--r--

const Queue = require('bull');
require('dotenv').config();

const testQueue = new Queue('testQueue', {
  redis: {
    username: process.env.REDIS_USER_NAME,
    host: process.env.REDIS_HOST,
    password: process.env.REDIS_PASSWORD,
    port: process.env.REDIS_PORT,
    database: process.env.REDIS_DATABASE,
  },
  // defaultJobOptions: {
  //   attempts: 20,
  //   backoff: 5000,
  //   removeOnComplete: true,
  //   removeOnFail: false,
  // }
});
testQueue.client.on('ready', () => {
  console.log('✅ Redis connection established');
});

testQueue.client.on('error', (err) => {
  console.error('❌ Redis connection error:', err);
});
// console.log(testQueue);

// testQueue.on('ready', () => console.log('✅ Worker connected to Redis'));
// testQueue.on('error', err => console.error('❌ Redis error in worker:', err));
// testQueue.on('waiting', jobId => console.log('👀 Waiting job ID:', jobId));
// testQueue.on('active', job => console.log('🚀 Processing job:', job.id));
// testQueue.on('completed', job => console.log('✅ Completed job:', job.id));
// testQueue.on('failed', (job, err) => console.log('❌ Job failed:', job.id, err.message));

testQueue.process(async (job) => {
  console.log("job");
  
  console.log(`[${process.pid}] Processing job`, job.id, job.data);
    if (Math.random() < 0.3) throw new Error('Simulated failure');
  console.log(`[${process.pid}] Completed job`, job.data._id);
  // Simulate success
  return { success: true };
});