SQS messages not consumed

[QuietImprovement]

Hi All,

With this current YAML config

version: "2.7"
#
# RPC is required for tasks dispatching (client)
#
rpc:
  listen: tcp://127.0.0.1:6001

#
# This section configures the task consumer (server)
#
server:
  command: php consumer.php
  relay: pipes

sqs:
  # Required AccessKey ID.
  # Default: empty
  key: mykey

  # Required secret access key.
  # Default: empty
  secret: mysecret

  # Required AWS region.
  # Default: empty
  region: eu-central-1

  # Required AWS SQS endpoint to connect.
  # Default: http://127.0.0.1:9324
  endpoint: https://sqs.eu-central-1.amazonaws.com

#
# In this section, the jobs themselves are configured
#
jobs:
  num_pollers: 10
  pipeline_size: 100000
  pool:
    num_workers: 10
    max_jobs: 0
    allocate_timeout: 60s
    destroy_timeout: 60s
  consume: ["my-queue-name"]
  pipelines:
    test-sqs-pipeline:
      # Required section.
      # Should be "sqs" for the Amazon SQS driver.
      driver: sqs

      config:
        # Optional section.
        # Default: 10
        prefetch: 10

        # Consume any payload type (not only Jobs structured)
        # Default: false
        consume_all: true

        # Get queue URL only
        # Default: false
        skip_queue_declaration: true

        # Optional section.
        # Default: 0
        #visibility_timeout: 0

        # Optional section.
        # Default: 0
        #wait_time_seconds: 0

        # Optional section.
        # Default: default
        queue: "my-queue-name"

        # Message group ID: https://docs.aws.amazon.com/AWSSimpleQueueService/latest/APIReference/API_SendMessage.html#SQS-SendMessage-request-MessageGroupId
        # Default: empty, should be set if FIFO queue is used
        # message_group_id: "test"

        # Optional section.
        # Default: empty
        #attributes:
        #  DelaySeconds: 42
        # etc... see https://docs.aws.amazon.com/AWSSimpleQueueService/latest/APIReference/API_SetQueueAttributes.html

        # Optional section.
        # Default: empty
        #tags:
        #  test: "tag"
logs:
  level: debug

and this consumer.php

<?php

declare(strict_types=1);

use Spiral\RoadRunner\Environment;
use Spiral\RoadRunner\Environment\Mode;
use Spiral\RoadRunner\Jobs\Consumer;
use Spiral\RoadRunner\Jobs\Task\ReceivedTaskInterface;
use Spiral\RoadRunner\Jobs\Jobs;
use Spiral\Goridge\RPC\RPC;

require_once 'vendor/autoload.php';

(static function (): void {

    $env = Environment::fromGlobals();
    $isJobsMode = $env->getMode() === Mode::MODE_JOBS;
    $shouldBeRestarted = false;
    if ($isJobsMode) {
        $consumer = new Consumer();
        /** @var Spiral\RoadRunner\Jobs\Task\ReceivedTaskInterface $task*/
        while ($task = $consumer->waitTask()) {
            try {
                var_dump($task);
                $task->complete();
            } catch (\Throwable $e) {
                $task->fail($e, $shouldBeRestarted);
            }
        }
    }
})();

I can see in the logs

  [============================] 100% (14,247.30Kb/14,247.30Kb)2024-02-06T11:07:56.205Z DEBUG   jobs            driver ready    {"pipeline": "test-sqs-pipeline", "driver": "sqs", "start": "2024-02-06T11:07:55.015Z", "elapsed": "1.190328024s"}
2024-02-06T11:07:56.206Z        DEBUG   rpc             plugin was started      {"address": "tcp://127.0.0.1:6001", "list of the plugins with RPC methods:": ["app", "jobs", "informer", "resetter"]}
[INFO] RoadRunner server started; version: 2.12.3, buildtime: 2023-02-16T13:08:41+0000
2024-02-06T11:07:56.271Z        DEBUG   server          worker is allocated     {"pid": 69, "internal_event_name": "EventWorkerConstruct"}
2024-02-06T11:07:56.272Z        DEBUG   server          worker is allocated     {"pid": 67, "internal_event_name": "EventWorkerConstruct"}
2024-02-06T11:07:56.273Z        DEBUG   server          worker is allocated     {"pid": 70, "internal_event_name": "EventWorkerConstruct"}
2024-02-06T11:07:56.274Z        DEBUG   server          worker is allocated     {"pid": 66, "internal_event_name": "EventWorkerConstruct"}
2024-02-06T11:07:56.274Z        DEBUG   server          worker is allocated     {"pid": 68, "internal_event_name": "EventWorkerConstruct"}
2024-02-06T11:07:56.284Z        DEBUG   server          worker is allocated     {"pid": 71, "internal_event_name": "EventWorkerConstruct"}
2024-02-06T11:07:56.290Z        DEBUG   server          worker is allocated     {"pid": 72, "internal_event_name": "EventWorkerConstruct"}
2024-02-06T11:07:56.291Z        DEBUG   server          worker is allocated     {"pid": 63, "internal_event_name": "EventWorkerConstruct"}
2024-02-06T11:07:56.308Z        DEBUG   server          worker is allocated     {"pid": 73, "internal_event_name": "EventWorkerConstruct"}
2024-02-06T11:07:56.309Z        DEBUG   server          worker is allocated     {"pid": 74, "internal_event_name": "EventWorkerConstruct"}

There are some messages on the queue

Messages are sent by aws cli

But there is no reaction from RR in the logs ...

[rustatian]

Hey @QuietImprovement 👋
You're using a super outdated RR version. Please update to at least 2023.3.10 and retry.

[rustatian]

Moreover, there is an error in your config. You should consume pipelines, not queues.

consume: ["my-queue-name"] # not queue, incorrect
consume: ["test-sqs-pipeline"] # pipeline name, correct