gistfile1.txt

module.exports = function() {
    var azure = require('azure');

    var topic = "foo-bar";
    var connectionString = "Endpoint=sb://...";

    console.log("Configuring Service Bus.");
    var serviceBusService = azure.createServiceBusService(connectionString);
    var movies = [];
    for(count = 0; count < 400000; count++) {
        movies.push({id: count});
    }

    serviceBusService.createTopicIfNotExists(topic, function(error) {
        if (error) {
            console.log(`Failed to get the Service Bus topic`);
            return;
        }

        console.log("Service Bus setup.");
        var message = {
            body: '',
            customProperties: { 
                messageNumber: 0
            }
        }

        // wait for al 400,000 to finish.
        for(index = 0; index < movies.length; index++) {
            message.customProperties.messageNumber = index;
            message.body = JSON.stringify(movies[index]);

            serviceBusService.sendTopicMessage(topic, message, function(error) {
                if (error) {
                    console.log(`Failed to send topic message for ${message.body}: ${error}`);
                    return;
                }
            });
        }
    });
}