diff --git a/src/DependencyInjection/NsqExtension.php b/src/DependencyInjection/NsqExtension.php index bc486d3..c1f3ce3 100644 --- a/src/DependencyInjection/NsqExtension.php +++ b/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'); } } diff --git a/src/Messenger/AckUnrecoverableMessageListener.php b/src/EventListener/AckUnrecoverableMessageListener.php similarity index 90% rename from src/Messenger/AckUnrecoverableMessageListener.php rename to src/EventListener/AckUnrecoverableMessageListener.php index eee6ca7..3a51966 100644 --- a/src/Messenger/AckUnrecoverableMessageListener.php +++ b/src/EventListener/AckUnrecoverableMessageListener.php @@ -1,8 +1,9 @@ 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') + ; +};