test-server.js

/**
 * json-server/test-server.js - Copyright 2023 Harshad Joshi and Bufferstack.IO Analytics Technology LLP, Pune
 *
 * Licensed under the GNU General Public License, Version 3.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 * https://www.gnu.org/licenses/gpl-3.0.html
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 **/



const os = require('os');
const express = require('express');
const amqp = require('amqplib/callback_api');

const RABBITMQ_SERVER = 'amqp://localhost';
const QUEUE_NAME = 'json_data_queue';

const app = express();
app.use(express.json({ limit: '50mb' }));

let channel;

    // Connect to RabbitMQ server and create a channel
    amqp.connect(RABBITMQ_SERVER, function(error0, connection) {
        if (error0) throw error0;
        connection.createChannel(function(error1, ch) {
            if (error1) throw error1;
            channel = ch;
        });
    });

    app.post('/', async (req, res) => {
        // Parse the incoming JSON data.
        const data = req.body;

        // Send data to the queue
        channel.sendToQueue(QUEUE_NAME, Buffer.from(JSON.stringify(data)));

        res.status(200).send('Data received successfully');
    });

    app.listen(8484, () => {
        console.log(`Test Server is running on port 8484 is listening...`);
    });

// Does not use cluster library