Refactoring: yaml to php di, fix directory struct
This commit is contained in:
@ -14,7 +14,7 @@ class NsqExtension extends Extension
|
|||||||
*/
|
*/
|
||||||
public function load(array $configs, ContainerBuilder $container): void
|
public function load(array $configs, ContainerBuilder $container): void
|
||||||
{
|
{
|
||||||
$loader = new Loader\YamlFileLoader($container, new FileLocator(__DIR__.'/../Resources/config'));
|
$loader = new Loader\PhpFileLoader($container, new FileLocator(__DIR__.'/../config'));
|
||||||
$loader->load('services.yml');
|
$loader->load('services.php');
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -1,8 +1,9 @@
|
|||||||
<?php
|
<?php
|
||||||
declare(strict_types=1);
|
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\EventDispatcher\EventSubscriberInterface;
|
||||||
use Symfony\Component\Messenger\Event\WorkerMessageFailedEvent;
|
use Symfony\Component\Messenger\Event\WorkerMessageFailedEvent;
|
||||||
use function Amp\Promise\wait;
|
use function Amp\Promise\wait;
|
@ -1,9 +0,0 @@
|
|||||||
services:
|
|
||||||
Nsq\NsqBundle\Messenger\NsqTransportFactory:
|
|
||||||
tags:
|
|
||||||
- 'messenger.transport_factory'
|
|
||||||
- 'container.no_preload'
|
|
||||||
|
|
||||||
Nsq\NsqBundle\Messenger\AckUnrecoverableMessageListener:
|
|
||||||
tags:
|
|
||||||
- { name: kernel.event_subscriber }
|
|
18
src/config/services.php
Normal file
18
src/config/services.php
Normal file
@ -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')
|
||||||
|
;
|
||||||
|
};
|
Reference in New Issue
Block a user