Sending messages to a queue using Azure Service Bus

sendMessages.js

const { ServiceBusClient } = require('@azure/service-bus');
const moment = require('moment');

const connectionString = process.env.SB_CONNECTION;
const queueName = process.env.SB_QUEUE_NAME;

const listOfScientists = [
    {
        id: 1,
        name: "Einstein",
        firstName: "Albert"
    },
    {
        id: 2,
        name: "Heisenberg",
        firstName: "Werner"
    },
    {
        id: 3,
        name: "Curie",
        firstName: "Marie"
    },
    {
        id: 4,
        name: "Hawking",
        firstName: "Steven"
    },
    {
        id: 5,
        name: "Newton",
        firstName: "Isaac"
    },
    {
        id: 6,
        name: "Bohr",
        firstName: "Niels"
    },
    {
        id: 7,
        name: "Faraday",
        firstName: "Michael"
    },
    {
        id: 8,
        name: "Galilei",
        firstName: "Galileo"
    },
    {
        id: 9,
        name: "Kepler",
        firstName: "Johannes"
    },
    {
        id: 10,
        name: "Kopernikus",
        firstName: "Nikolaus"
    }
];

/**
 * Sending messages to service bus queue.
 *
 * @param {object} context The context.
 * @param {object} req The request.
 * @returns {Promise<void>} A promise.
 */
const sendMessagesHandler = async (context, req) => {
    context.log(`Sending messages to queue.`, req);
    const sbClient = ServiceBusClient.createFromConnectionString(connectionString);

    // If sending to a Topic, use `createTopicClient` instead of `createQueueClient`
    const queueClient = sbClient.createQueueClient(queueName);
    const sender = queueClient.createSender();

    try {
        for (let index = 0; index < listOfScientists.length; index++) {
            const scientist = listOfScientists[index];
            const now = moment().format();
            const message = {
                body: {
                    fullName: `${scientist.firstName} ${scientist.name}`,
                    id: scientist.id,
                    label: "Scientist",
                    time: now
                }
            };

            context.log(`Sending message: ${message.body.time}: ${message.body.id} - ${message.body.fullName} - ${message.body.label}`);
            await sender.send(message);
        }

        await queueClient.close();
    } catch (error) {
        context.log(`Caught an error trying to send messages or closing the queue.`, error);
    } finally {
        await sbClient.close();
    }
};

module.exports = sendMessagesHandler;