Use bref/symfony-messenger

Symfony/sqs/Readme.md

@@ -2,8 +2,8 @@
 
 # Pre-requests
 
-Before we start we need to setup the QUEUE. Bref works with both FIFO queues and normal queues. Try to create a new normal
-SQS queue, name it "foobar" and  click "quick create". 
+Before we start we need to setup the QUEUE. Bref works with both FIFO queues and standard queues. Try to create a new "standard
+queue", name it "foobar" and  click "quick create". 
 
 Example queue ARN: **arn:aws:sqs:us-east-1:403367587399:foobar**
 Example queue URL: **https://sqs.us-east-1.amazonaws.com/403367587399/foobar**
@@ -36,7 +36,7 @@ The last thing we need to do is to allow write access to the queue.
 
 1. Go to IAM in the AWS console
 2. Click "Roles" in the left sidebar
-3. Find the roles for this Lambda application and click on it. Probably named something like "bref-demo-sqs"
+3. Find the roles for this Lambda application and click on it. Probably named something like "bref-demo-sqs-dev-...-LambdaRole"
 4. Now click "Attach policy" and find "SQSFullAccess" in the list. After you added that policy you are good to go. 
 
 You can obviously be more restrictive with what policy to add. 

Symfony/sqs/bin/consumer.php

@@ -1,13 +1,13 @@
 <?php declare(strict_types=1);
 
-use Bref\Messenger\Sqs\SqsConsumer;
+use Bref\Messenger\Service\BrefWorker;
 
 require dirname(__DIR__) . '/config/bootstrap.php';
 
 lambda(function ($event) {
     $kernel = new \App\Kernel($_SERVER['APP_ENV'], (bool) $_SERVER['APP_DEBUG']);
     $kernel->boot();
 
-    $sqsConsumer = $kernel->getContainer()->get(SqsConsumer::class);
-    $sqsConsumer->consumeLambdaEvent($event);
+    $worker = $kernel->getContainer()->get(BrefWorker::class);
+    $worker->consumeLambdaEvent($event);
 });

Symfony/sqs/composer.json

@@ -1,12 +1,15 @@
 {
     "type": "project",
     "license": "proprietary",
+    "repositories": [
+        { "type": "vcs", "url": "https://github.com/Nyholm/bref-symfony-messenger"}
+    ],
     "require": {
         "php": "^7.1.3",
         "ext-ctype": "*",
         "ext-iconv": "*",
         "bref/bref": "^0.5.12",
-        "bref/symfony-messenger-sqs": "^0.2.0",
+        "bref/symfony-messenger": "dev-master",
         "symfony/console": "4.4.*",
         "symfony/flex": "^1.3.1",
         "symfony/framework-bundle": "4.4.*",

Symfony/sqs/config/packages/messenger.yaml

@@ -9,12 +9,17 @@ framework:
         routing:
             'App\Message\Ping': async
 
+bref_messenger:
+    sqs: true # Register the SQS transport
+
 services:
 
-    Bref\Messenger\Sqs\SqsConsumer:
-        autowire: true
-        autoconfigure: true
+    my_sqs_consumer:
+        class: Bref\Messenger\Service\Sqs\SqsConsumer
         arguments:
-            # Inject the transport name used in config/packages/messenger.yaml
-            $transportName: 'async'
-        public: true
+            - '@Bref\Messenger\Service\BusDriver'
+            - '@messenger.routable_message_bus'
+            - '@Symfony\Component\Messenger\Transport\Serialization\SerializerInterface'
+            - 'async' # Same as transport name
+        tags:
+            - { name: bref_messenger.consumer }

Symfony/sqs/symfony.lock

@@ -5,6 +5,9 @@
     "bref/bref": {
         "version": "0.5.12"
     },
+    "bref/symfony-messenger": {
+        "version": "dev-master"
+    },
     "bref/symfony-messenger-sqs": {
         "version": "0.2.0"
     },