Managed RabbitMQ for your application

import os
import pika

connection = pika.BlockingConnection(
    pika.URLParameters(os.environ["RABBITMQ_URL"])
)
channel = connection.channel()
channel.queue_declare(queue="tasks", durable=True)
channel.confirm_delivery()

channel.basic_publish(
    exchange="",
    routing_key="tasks",
    body='{"task": "send_email"}',
    properties=pika.BasicProperties(delivery_mode=2),
    mandatory=True
)
connection.close()

const amqp = require('amqplib');

const connection = await amqp.connect(
    process.env.RABBITMQ_URL
);
const channel = await connection.createConfirmChannel();
await channel.assertQueue('tasks', { durable: true });

channel.sendToQueue('tasks',
    Buffer.from(JSON.stringify({ task: 'process_order' })),
    { persistent: true }
);
await channel.waitForConfirms();

channel.consume('tasks', (message) => {
    if (!message) return;
    console.log(message.content.toString());
    channel.ack(message);
}, { noAck: false });

<?php
use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;

$connection = new AMQPStreamConnection(
    getenv('RABBITMQ_HOST'),
    (int) getenv('RABBITMQ_PORT'),
    getenv('RABBITMQ_USERNAME'),
    getenv('RABBITMQ_PASSWORD'),
    getenv('RABBITMQ_VHOST') ?: '/'
);
$channel = $connection->channel();
$channel->queue_declare('tasks', false, true, false, false);
$channel->confirm_select();

$message = new AMQPMessage(
    json_encode(['task' => 'generate_report']),
    ['delivery_mode' => AMQPMessage::DELIVERY_MODE_PERSISTENT]
);
$channel->basic_publish($message, '', 'tasks');
$channel->wait_for_pending_acks();
$channel->close();
$connection->close();