Function rsmq worker

rsmq_worker.js

/* eslint-disable no-console */
const RSMQWorker = require('rsmq-worker');
const RedisSMQ = require('rsmq');

const { uploadMultipartVideo } = require('../libs/multipart_upload');
const config = require('../../config');

const rsmq = new RedisSMQ({
  url: config.get('REDIS_URL'),
  ns: 'rsmq'
});

const worker = new RSMQWorker(config.get('WORKER_TOPIC'), {
  rsmq,
  maxReceiveCount: 100, // only receive a message 2 times until delete
  autostart: true, // start worker on init
});

const listenWorker = () => {
  worker.on('message', async (msg, next, msgid) => {
    const message = JSON.parse(msg);
    const data = {
      msgid,
      message
    };
    
    uploadMultipartVideo({
      // data yang dibutuhkan
    });

    worker.del(data.msgid);
  });

  worker.start();
};

module.exports = {
  listenWorker
};