Laravel / RabbitMQ => How to listen and handle jobs emitted by external services ?

To listen and handle jobs emitted by external services using RabbitMQ in a Laravel application, you can follow these steps:

1. Install the Package: Make sure you have the vladimir-yuldashev/laravel-queue-rabbitmq package installed and configured in your Laravel application.

2. Configure RabbitMQ Connection: Ensure that your config/queue.php file has the RabbitMQ connection properly set up, including the correct queue names that the external services will be using.

3. Create a Listener: Since the jobs are not dispatched by Laravel, you won't have a job class to handle them. Instead, you'll need to create a listener that can process the incoming data.

4. Process the Message: In your listener, you will need to manually handle the message payload and perform the necessary actions.

Here's an example of how you might set up a listener to handle incoming messages from RabbitMQ:

use Illuminate\Support\Facades\Queue;
use VladimirYuldashev\LaravelQueueRabbitMQ\Queue\Connectors\RabbitMQConnector;

// Assuming you have already set up the RabbitMQ connection in config/queue.php

Queue::connection('rabbitmq')->before(function ($event) {
    // You can perform some action before consuming the message
});

Queue::connection('rabbitmq')->after(function ($event) {
    // You can perform some action after consuming the message
});

Queue::connection('rabbitmq')->looping(function ($event) {
    // This is where you can consume the message
    $message = $event->message;

    // Decode the message if it's in JSON format or process it as needed
    $data = json_decode($message->body, true);

    // Now you can handle the data from the message
    // For example, you might have a switch or if-else block to handle different types of jobs
    switch ($data['type']) {
        case 'jobTypeA':
            // Handle job type A
            break;
        case 'jobTypeB':
            // Handle job type B
            break;
        // Add more cases as needed for different job types
    }

    // Acknowledge the message so it is removed from the queue
    $message->ack();
});

Queue::connection('rabbitmq')->failing(function ($event) {
    // Log the failed job or perform some other action
});

In this example, we're using the looping method to listen for incoming messages. When a message is received, we decode it and handle it according to its type. After processing the message, we acknowledge it to remove it from the queue.

Remember to replace 'rabbitmq' with the actual name of your RabbitMQ connection as defined in your config/queue.php.

Finally, you will need to run the Laravel queue worker to start listening to the RabbitMQ queue:

php artisan queue:work rabbitmq --queue=your_queue_name

Replace your_queue_name with the name of the queue you want to listen to.

This setup allows your Laravel application to consume and process messages sent to RabbitMQ by external services, even when those messages do not correspond to Laravel job classes.