iframe-proxy | Sunbelt Computer Software

executable file

40 lines (30 loc) · 944 Bytes

#!/usr/bin/env node
const amqp = require('amqplib');
async function main() {
    const connection = await amqp.connect('amqp://localhost');
    const channel = await connection.createChannel();
    const queue = 'rpc_queue';
    await channel.assertQueue(queue, {
        durable: true,
        arguments: { 'x-queue-type': 'quorum' }
    channel.prefetch(1);
    console.log(' [x] Awaiting RPC requests');
    channel.consume(queue, function reply(msg) {
        const n = parseInt(msg.content.toString());
        console.log(" [.] fib(%d)", n);
        const r = fibonacci(n);
        channel.sendToQueue(msg.properties.replyTo,
            Buffer.from(r.toString()), {
                correlationId: msg.properties.correlationId
        channel.ack(msg);
function fibonacci(n) {
    if (n === 0 || n === 1)
        return n;
        return fibonacci(n - 1) + fibonacci(n - 2);

Sunbelt Computer Software

PL/B Language Development and Support

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Sunbelt Computer Software

PL/B Language Development and Support

Uh oh!

FilesExpand file tree

rpc_server.js

Latest commit

History

rpc_server.js

File metadata and controls