From 877090ad43ae090760027ea9d0b4d99cf88e0ef7 Mon Sep 17 00:00:00 2001 From: Adam Kadlec Date: Sun, 9 Jan 2022 11:31:46 +0100 Subject: [PATCH] Fixing services registration --- redisdb_exchange_plugin/bootstrap.py | 2 +- src/Subscribers/AsyncClientSubscriber.php | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/redisdb_exchange_plugin/bootstrap.py b/redisdb_exchange_plugin/bootstrap.py index f5dae73..d4b7b79 100644 --- a/redisdb_exchange_plugin/bootstrap.py +++ b/redisdb_exchange_plugin/bootstrap.py @@ -58,7 +58,7 @@ def create_container( di[Publisher] = Publisher(redis_client=di[RedisClient]) di["fb-redisdb-exchange-plugin_publisher"] = di[Publisher] - di[RedisExchange] = RedisExchange(redis_client=di[RedisClient], logger=di[Logger]) + di[RedisExchange] = RedisExchange(redis_client=di[RedisClient], logger=di[Logger]) # type: ignore[call-arg] di["fb-redisdb-exchange-plugin_exchange"] = di[RedisExchange] di[ExchangePublisher].register_publisher(di[Publisher]) diff --git a/src/Subscribers/AsyncClientSubscriber.php b/src/Subscribers/AsyncClientSubscriber.php index 4ebe087..c02d743 100644 --- a/src/Subscribers/AsyncClientSubscriber.php +++ b/src/Subscribers/AsyncClientSubscriber.php @@ -40,7 +40,7 @@ class AsyncClientSubscriber implements EventDispatcher\EventSubscriberInterface { /** @var ExchangePluginConsumer\IConsumer */ - private ?ExchangePluginConsumer\IConsumer $consumer; + private ExchangePluginConsumer\IConsumer $consumer; /** @var ModulesMetadataLoaders\ISchemaLoader */ private ModulesMetadataLoaders\ISchemaLoader $schemaLoader; @@ -58,7 +58,7 @@ public function __construct( ModulesMetadataLoaders\ISchemaLoader $schemaLoader, ModulesMetadataSchemas\IValidator $validator, PsrEventDispatcher\EventDispatcherInterface $dispatcher, - ?ExchangePluginConsumer\IConsumer $consumer, + ExchangePluginConsumer\IConsumer $consumer, ?Log\LoggerInterface $logger = null ) { $this->schemaLoader = $schemaLoader;