fix AmqpConnectionService def (#12)

SAREhub · Jan 16, 2020 · f14f330 · f14f330
1 parent 8a632f7
commit f14f330
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/src/SAREhub/Client/DI/Amqp/AmqpDefinitionsBase.php b/src/SAREhub/Client/DI/Amqp/AmqpDefinitionsBase.php
@@ -74,8 +74,6 @@ protected abstract static function getMessageSenderExchange(): string;
 
     protected static function connectionServiceDef()
     {
-        $def = autowire(AmqpConnectionService::class)
-            ->method("addChannel", get(AmqpChannelWrapper::class));
-        return BasicLoggingDefinitions::inject($def, "Amqp.ConnectionService");
+        return BasicLoggingDefinitions::inject(autowire(AmqpConnectionService::class), "Amqp.ConnectionService");
     }
 }