Publisher interface

solcloud · Jun 8, 2022 · d127ee7 · d127ee7
1 parent ed49053
commit d127ee7
Show file tree

Hide file tree

Showing 3 changed files with 23 additions and 1 deletion.
diff --git a/src/IPublisher.php b/src/IPublisher.php
@@ -0,0 +1,9 @@
+<?php
+
+namespace Solcloud\Consumer;
+
+interface IPublisher
+{
+    public function send(array $data, QueueRoute $route, array $meta = []): void;
+
+}
diff --git a/src/NullPublisher.php b/src/NullPublisher.php
@@ -0,0 +1,13 @@
+<?php
+
+namespace Solcloud\Consumer;
+
+class NullPublisher implements IPublisher
+{
+
+    public function send(array $data, QueueRoute $route, array $meta = []): void
+    {
+        // do nothing
+    }
+
+}
diff --git a/src/Publisher.php b/src/Publisher.php
@@ -7,7 +7,7 @@
 use PhpAmqpLib\Connection\AbstractConnection as Connection;
 use PhpAmqpLib\Message\AMQPMessage as Message;
 
-class Publisher
+class Publisher implements IPublisher
 {
 
     /**