Refactoring: yaml to php di, fix directory struct

src/DependencyInjection/NsqExtension.php

@@ -14,7 +14,7 @@ class NsqExtension extends Extension
      */
     public function load(array $configs, ContainerBuilder $container): void
     {
-        $loader = new Loader\YamlFileLoader($container, new FileLocator(__DIR__.'/../Resources/config'));
-        $loader->load('services.yml');
+        $loader = new Loader\PhpFileLoader($container, new FileLocator(__DIR__.'/../config'));
+        $loader->load('services.php');
     }
 }

src/Messenger/AckUnrecoverableMessageListener.php → src/EventListener/AckUnrecoverableMessageListener.php

@@ -1,8 +1,9 @@
 <?php
 declare(strict_types=1);
 
-namespace Nsq\NsqBundle\Messenger;
+namespace Nsq\NsqBundle\EventListener;
 
+use Nsq\NsqBundle\Messenger\NsqReceivedStamp;
 use Symfony\Component\EventDispatcher\EventSubscriberInterface;
 use Symfony\Component\Messenger\Event\WorkerMessageFailedEvent;
 use function Amp\Promise\wait;

src/config/services.php

@@ -0,0 +1,18 @@
+<?php
+
+declare(strict_types=1);
+
+use Symfony\Component\DependencyInjection\Loader\Configurator\ContainerConfigurator;
+
+return static function (ContainerConfigurator $configurator): void {
+    $services = $configurator->services();
+
+    $services->set(Nsq\NsqBundle\Messenger\NsqTransportFactory::class)
+        ->tag('messenger.transport_factory')
+        ->tag('container.no_preload')
+        ;
+
+    $services->set(\Nsq\NsqBundle\EventListener\AckUnrecoverableMessageListener::class)
+        ->tag('kernel.event_subscriber')
+        ;
+};