Merge pull request #2 from sokanacademy/feature/topic

topic exchange
sokanacademy · Jun 22, 2022 · 8e87ef7 · 8e87ef7
2 parents 39a5a84 + 6a5cd6f
commit 8e87ef7
Show file tree

Hide file tree

Showing 4 changed files with 31 additions and 2 deletions.
diff --git a/src/Commands/ConsumeMessages.php b/src/Commands/ConsumeMessages.php
@@ -46,7 +46,13 @@ public function handle(RabbitMQ $rabbitmq)
             ->declare();
 
         foreach (config('rabbitmq.consumers') as $event) {
-            $queue->bindTo(class_basename($event));
+            if (is_string($event)) {
+                $queue->bindTo(class_basename($event));
+            }
+
+            if (is_array($event)) {
+                $queue->bindTo(class_basename($event[0]), $event[1]);
+            }
         }
 
         $rabbitmq

diff --git a/src/Commands/DeclareExchanges.php b/src/Commands/DeclareExchanges.php
@@ -39,7 +39,7 @@ public function handle(RabbitMQ $rabbitmq)
                 $rabbitmq
                     ->exchange()
                     ->durable()
-                    ->type('fanout')
+                    ->type($this->determineExchangeType($event))
                     ->name(class_basename($event))
                     ->declare();
 
@@ -67,4 +67,19 @@ private function getEvents(): Collection
 
         return collect($events)->keys();
     }
+
+    private function determineExchangeType(string $event): string
+    {
+        $reflection = (new ReflectionClass($event));
+
+        if (! $reflection->hasProperty('exchangeType')) {
+            return 'fanout';
+        }
+
+        $property = $reflection->getProperty('exchangeType');
+
+        $property->setAccessible(true);
+
+        return $property->getValue();
+    }
 }
diff --git a/src/RabbitMQDispatcher.php b/src/RabbitMQDispatcher.php
@@ -29,6 +29,11 @@ public function dispatch($event, $payload = [], $halt = false)
             ->message()
             ->persistent()
             ->viaExchange(class_basename($event))
+            ->when(
+                method_exists($event, 'routingKey'),
+                fn (RabbitMQMessage $message) => $message
+                ->route($event->routingKey())
+            )
             ->withPayload(
                 array_map(
                     function ($property) {

diff --git a/src/RabbitMQMessage.php b/src/RabbitMQMessage.php
@@ -2,11 +2,14 @@
 
 namespace Sokanacademy\RabbitMQ;
 
+use Illuminate\Support\Traits\Conditionable;
 use PhpAmqpLib\Channel\AMQPChannel;
 use PhpAmqpLib\Message\AMQPMessage;
 
 class RabbitMQMessage
 {
+    use Conditionable;
+
     /**
      * @var AMQPChannel
      */