[Azure][Nodejs] Event Hub Send/Receive

index.js

const EventHubClient = require("azure-event-hubs").Client;

const connectionString = '<ConnectionString>';
const eventHubPath = '<EventHubName>';

const client = EventHubClient.fromConnectionString(connectionString, eventHubPath);

// ===================================
// Open connection to the client
// ===================================
client
.open()
// ===================================
// Create Receivers
// ===================================
.then(() => client.getPartitionIds())
.then((partitions) => {
  partitions.forEach((partitionId) => {
    console.log(`[Receiver - ${partitionId}] Created`);
    client.createReceiver('$Default', partitionId, { startAfterTime: Date.now() })
    .then((receiver) => {
      receiver.on('errorReceived', (err) => console.log(err)); 
      receiver.on('message', (message) => {
        console.log(`[Receiver - ${partitionId}] ${JSON.stringify(message.body)}`);
        // See http://azure.github.io/amqpnetlite/articles/azure_sb_eventhubs.html for details on message annotation properties from EH. 
        //var enqueuedTime = Date.parse(message.systemProperties['x-opt-enqueued-time']);
      });
    })
  });

  return Promise.resolve();
})
// ===================================
// Create Sender
// ===================================
.then(() => client.createSender())
.then((sender) => {
  console.log('[Sender] Created');
  sender.on('errorSender', (err) => console.log(err)); 

  setInterval(() => {
    let clientNumber = parseInt(Math.random() * 20 + 1);
    sender.send({
      name: `client-${clientNumber}`,
      isPremium: [1, 5, 7, 13, 20].indexOf(clientNumber) > -1
    });
  }, 1000);


  //console.log(`[Sender] Sending client-${clientNumber} with isPremium: ${[1, 5, 7, 13, 20].indexOf(clientNumber) > -1}`);
})
.catch((e) => console.log(e));