CloudAMQP Sample

index.js

'use strict';

const amqp = require('amqplib');
const QUEUE = 'pdf-generator';

module.exports = async (request, response) => {
    
    const {projectId} = request.body;
    
    if (!url) {
		return response.status(500).json('Please provide a project ID');
    }
    
    try {
        // The URL can be found in the CLOUDAMQP account
        const connection = await amqp.connect(process.env.CLOUDAMQP_URL);
        const channel = await connection.createChannel();
		const ok = await channel.assertQueue(QUEUE);

		if (!ok) {
			throw new Error('Failed asserting queue');
		}
        
        await channel.sendToQueue(QUEUE, Buffer.from(projectId));
	    
		return response.status(200).json({success: true});

    } catch (error) {
        return response.status(500).json(`Error queueing task: ${error.message}`);
    }
}