WillRy / rabbitrun

demo/pubsub/Process.php

<?php

use PhpAmqpLib\Message\AMQPMessage;

class Process implements \WillRy\RabbitRun\PubSub\WorkerInterface

The type WillRy\RabbitRun\PubSub\WorkerInterface was not found. Maybe you did not declare it correctly or list all dependencies?

{

    public function handle(\WillRy\RabbitRun\PubSub\Task $data)

The type WillRy\RabbitRun\PubSub\Task was not found. Maybe you did not declare it correctly or list all dependencies?

    {
        $body = $data->getData();

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

        /**
         * Fazer o processamento que for necessário
         */

        //simulando um erro qualquer para exemplo
        // $fakeException = rand() % 2 === 0;
        // if ($fakeException) throw new \Exception("=== Erro ===");

        echo "Processado".PHP_EOL;


        /** Marca o item como erro */
        //$data->nackError();

        /** Marca o item como cancelado */
        //$data->nackCancel();
    }


    public function error(array $databaseData, Exception $error = null)
    {

    }
}