Merge pull request #4 from qpautrat/handle_serialize_publisher

feat: Chose which serializing strategy by configuration.

src/DependencyInjection/Configuration.php

@@ -2,6 +2,7 @@
 
 namespace Evaneos\BurrowBundle\DependencyInjection;
 
+use Evaneos\BurrowBundle\PublisherFactory;
 use Symfony\Component\Config\Definition\Builder\TreeBuilder;
 use Symfony\Component\Config\Definition\ConfigurationInterface;
 
@@ -48,6 +49,10 @@ public function getConfigTreeBuilder()
                         ->children()
                             ->scalarNode('driver')->end()
                             ->scalarNode('exchange')->end()
+                            ->enumNode('serializingStrategy')
+                                ->values(PublisherFactory::$SERIALIZING_STRATEGIES)
+                                ->defaultValue(PublisherFactory::DEFAULT_SERIALIZING_STRATEGY)
+                            ->end()
                         ->end()
                     ->end()
                 ->end()

src/DependencyInjection/EvaneosBurrowExtension.php

@@ -10,6 +10,7 @@
 use Burrow\Driver;
 use Burrow\Driver\DriverFactory;
 use Burrow\Publisher\AsyncPublisher;
+use Evaneos\BurrowBundle\PublisherFactory;
 use Evaneos\BurrowBundle\WorkerFactory;
 use Evaneos\Daemon\CLI\DaemonWorkerCommand;
 use Evaneos\Daemon\Worker;
@@ -49,10 +50,13 @@ public function load(array $configs, ContainerBuilder $container)
         }
 
         foreach ($config['publishers'] as $name => $value) {
-            $container
-                ->register(sprintf('evaneos_burrow.publisher.%s', $name), AsyncPublisher::class)
-                ->addArgument(new Reference(sprintf('evaneos_burrow.driver.%s', $value['driver'])))
-                ->addArgument($value['exchange']);
+            $definition = new Definition(AsyncPublisher::class, [
+                new Reference(sprintf('evaneos_burrow.driver.%s', $value['driver'])),
+                $value['exchange'],
+                $value['serializingStrategy']
+            ]);
+            $definition->setFactory([PublisherFactory::class, 'buildAsync']);
+            $container->setDefinition(sprintf('evaneos_burrow.publisher.%s', $name), $definition);
         }
 
         foreach ($config['workers'] as $name => $value) {

src/PublisherFactory.php

@@ -0,0 +1,38 @@
+<?php
+
+namespace Evaneos\BurrowBundle;
+
+use Burrow\Driver;
+use Burrow\Publisher\AsyncPublisher;
+use Burrow\Publisher\SerializingPublisher;
+use Burrow\Serializer\JsonSerializer;
+use Burrow\Serializer\PhpSerializer;
+
+class PublisherFactory
+{
+    const SERIALIZING_STRATEGY_NONE = 'none';
+    const SERIALIZING_STRATEGY_SERIALIZE = 'serialize';
+    const SERIALIZING_STRATEGY_JSON = 'json';
+    const DEFAULT_SERIALIZING_STRATEGY = self::SERIALIZING_STRATEGY_JSON;
+
+    public static $SERIALIZING_STRATEGIES = [self::SERIALIZING_STRATEGY_NONE, self::SERIALIZING_STRATEGY_SERIALIZE, self::SERIALIZING_STRATEGY_JSON];
+
+    /**
+     * @param Driver $driver
+     * @param string $exchangeName
+     * @param string $serializingStrategy
+     * @return AsyncPublisher|SerializingPublisher
+     */
+    public static function buildAsync(Driver $driver, $exchangeName, $serializingStrategy)
+    {
+        $publisher = new AsyncPublisher($driver, $exchangeName);
+
+        if (self::SERIALIZING_STRATEGY_NONE === $serializingStrategy) {
+            return $publisher;
+        } elseif (self::SERIALIZING_STRATEGY_JSON === $serializingStrategy) {
+            return new SerializingPublisher($publisher, new JsonSerializer());
+        } else {
+            return new SerializingPublisher($publisher, new PhpSerializer());
+        }
+    }
+}

tests/SomeConsumer.php

@@ -10,4 +10,4 @@ public function consume($message, array $headers = [])
     {
         // Do nothing
     }
-}
+}

tests/app/config/config.yml

@@ -20,4 +20,4 @@ evaneos_burrow:
 
 services:
     some_consumer:
-        class: Tests\SomeConsumer
+        class: Tests\SomeConsumer