Heroku clock.js process

clock.js

const CronJob = require('cron').CronJob
const amqp = require('amqp-connection-manager')

const AMQP_URL = process.env.CLOUDAMQP_URL || 'amqp://localhost';
if (!AMQP_URL) process.exit(1)

const WORKER_QUEUE = 'worker-queue'  // To consume from worker process
const CLOCK_QUEUE = 'clock-queue'  // To consume from clock process
const JOBS = [{  // You could store these jobs in a database
  name: "Cron process 1",
  message: { "taskName": "resetInboxCount", "queue": "worker-queue" },  // message in json format
  crontTime: "0 17 03 01 * *",  // Every 1st of every month at 3:17 AM
  repeat: 1
},
{ 
  name: "Cron process 2",
  message: { "taskName": "anotherTaskToRun", "queue": "worker-queue" },  // message in json format
  dateTime: new Date("Mon Sep 17 2018 14:08:00 GMT-0300"),  // At specific time. Only executed once
  repeat: 0
}]

// Create a new connection manager from AMQP
var connection = amqp.connect([AMQP_URL])
console.log('[AMQP] - Connecting...') 

connection.on('connect', function() {
  process.once('SIGINT', function() {  // Close conn on exit
    connection.close() 
  })
  console.log('[AMQP] - Connected!')
  return startCronProcess(JOBS)
})

connection.on('disconnect', function(params) {
  return console.error('[AMQP] - Disconnected.', params.err.stack) 
})

const startCronProcess = (jobs) => {
  if (jobs && jobs.length) {
    jobs.forEach(job => {
      let j = new CronJob({
        cronTime: job.cronTime ? job.cronTime : new Date(job.dateTime),
        onTick: () => {
          sendMessage(job.message)
          if (!job.repeat) j.stop()
        },
        onComplete: () => {
          console.log('Job completed! Removing now...')
        },  
        timeZone: 'America/Argentina/Buenos_Aires',
        start: true  // Start now
      })
    })
  }
}

const sendMessage = (data) => {
  let message
  try {
    message = JSON.parse(data)
  } catch(e) {
    console.error(e)
  }
  if (!message) { return }

  let queue = message.queue || WORKER_QUEUE
  let senderChannelWrapper = connection.createChannel({
    json: true,
    setup: function(channel) {
      return channel.assertQueue(queue, {durable: true});
    }
  })

  senderChannelWrapper.sendToQueue(queue, message, { contentType: 'application/json', persistent: true })
    .then(function() {
      console.log('[AMQP] - Message sent to queue =>', queue)
      senderChannelWrapper.close()
    })
    .catch(err => {
      console.error('[AMQP] - Message to queue => '+queue+ '<= was rejected! ', err.stack)
      senderChannelWrapper.close()
    })
}