EventHub Receiver

eh-receiver.js

const EventHubClient = require('azure-event-hubs').Client;
const Promise = require('bluebird');

const connectionString = '__OBFUSCATED__';
const eventHubPath = 'foo';

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

var printError = function(err) {
  console.error(err.message);
};

var receiveAfterTime = Date.now();

console.log('Connecting...');
client.open()
  .then(function() {
    console.log('Client connected');
    return client.getPartitionIds();
  })
  .then(function(partitionIds) {
    return Promise.map(partitionIds, function(partitionId) {
      return client.createReceiver('$Default', partitionId, {
        'startAfterTime': receiveAfterTime
      }).then(function(receiver) {
        receiver.on('errorReceived', printError);
        receiver.on('message', function(event) {
          console.log(`partitionId: ${partitionId}, partitionKey: ${event.partitionKey}`);
        });
      });
    });
  })
  .catch(printError);