re-add directPublish after remove because of no tests

jtl-software · Jul 5, 2022 · 9e70da3 · 9e70da3
1 parent b46bf65
commit 9e70da3
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/src/Transport/Amqp/AmqpTransport.php b/src/Transport/Amqp/AmqpTransport.php
@@ -108,6 +108,18 @@ public function publish(AmqpTransportableMessage $message, int $delay = 0): void
         );
     }
 
+    public function directPublish(AMQPMessage $message): void
+    {
+        $this->connect();
+        $routingKey = self::MESSAGE_QUEUE_PREFIX . $message->getRoutingKey();
+        $this->declareQueue($routingKey);
+        $this->channel->basic_publish(
+            msg: $message,
+            routing_key: $routingKey
+        );
+    }
+
+
     /**
      * @param SubscriptionSettings $subscriptionOptions
      * @param Closure $handler