scheduledPublish

scheduledPublish.php

<?php

public function scheduledPublish()
    {
        $headers = new AMQPTable();
        $delay = 60000; // 1 minute
        $headers->set('x-delay', $delay, AMQPTable::T_INT_LONG);
        $exchangeName = 'delayed';
        $routingKey = 'delayed-messages';
        $properties = [
            'content_type' => 'text/plain',
            'delivery_mode' => 2
        ];
        $payload = [
            'message' => 'A scheduled RabbitMQ message'
        ];
        $msg = new AMQPMessage(json_encode($payload, JSON_UNESCAPED_SLASHES | JSON_UNESCAPED_UNICODE), $properties);
        $msg->set('application_headers', $headers);
        try {
            $this->channel->basic_publish($msg, $exchangeName, $routingKey, true);
            $this->channel->wait_for_pending_acks();
        } catch (\Exception $e) {
            return false;
        }
        return true;
    }