Gewaer\Cli\Tasks\QueueTask::notificationAction()

Complexity

Conditions	2
Paths	2

Size

Total Lines	86
Code Lines	32

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	6

Importance

Changes

0

<?php
    public function notificationAction()
    {

         /**
     * Every handler needs the below code
     */

        /**
         * The job itself
         */
    //     $jobArray = [
    //     'id' => $job_id++,
    //     'notification' => 'hello you need to pay your account',
    //     'sleep_period' => rand(0, 3)
    // ];

        /**
         * Need to convert it to rabbitmq msg
         */
        $msg = new \PhpAmqpLib\Message\AMQPMessage(

The assignment to $msg is dead and can be removed.

            json_encode($jobArray, JSON_UNESCAPED_SLASHES),

The variable $jobArray seems to be never defined.

            ['delivery_mode' => 2] // make message persistent
    );

        /**
         * Actual way to send jobs to queue
         */
        // $channel->basic_publish($msg, '', RABBITMQ_QUEUE_NAME);


        ///////////////////////////////////////////////////////////////////////

    
        $channel = $this->queue->channel();

        // Create the queue if it doesnt already exist.
        $channel->queue_declare(
            $queue = "notifications",
            $passive = false,
            $durable = true,
            $exclusive = false,
            $auto_delete = false,
            $nowait = false,
            $arguments = null,
            $ticket = null
        );

        echo ' [*] Waiting for notifications. To exit press CTRL+C', "\n";

        $callback = function ($msg) {

            /**
             * Assign  message body as an assoc array to job
             */
            $job = json_decode($msg->body, $assocForm = true);

            /**
             * Custom actions here on jobs
             */
            echo($job['notification']);
            sleep($job['sleep_period']);

            /**
             * Log the delivery info
             */
            $msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag']);
        };

        $channel->basic_qos(null, 1, null);

        $channel->basic_consume(
            $queue = "notifications",
            $consumer_tag = '',
            $no_local = false,
            $no_ack = false,
            $exclusive = false,
            $nowait = false,
            $callback
        );

        while (count($channel->callbacks)) {
            $channel->wait();
        }

        $channel->close();
        $this->queue->close();
    }