queueStorage_receiver.js

const azure = require('azure-storage');
const config = require('./config');
const Poller = require('./Poller');

const queueService = azure.createQueueService(config.azureStorageAccount, config.azureStorageAccessKey);

const poller = new Poller(1000);
poller.onPoll(() => {
  console.log(`[Queue - Receiver] Polling for messages`);

  queueService.getMessages(config.queueName, (err, results, res) => {
    if (err) {
      console.log(`[Queue - Receiver] Error while getting messages: ${err}`);
      return;
    }

    if (!results[0]) {
      console.log(`[Queue - Receiver] Queue is empty`);
      return;
    }

    // Get our top message
    const message = results[0];

    // Remove it from the queue, since else the others are hidden
    queueService.deleteMessage(config.queueName, message.messageId, message.popReceipt, (err, res) => {
      if (err) {
        console.log(`[Queue - Receiver] Error while deleting message: ${err}`);
        return;
      }

      console.log(`[Queue - Receiver] Removed message: ${JSON.stringify(message)} from queue`);
      poller.poll(); // Wait for the next message
    })
  });
});

poller.poll();