III-1466: Add extra code to make amqp publisher bodyFactory return th…

…e payload only instead of whole domain message
cultuurnet · Sep 27, 2016 · 621b4c0 · 621b4c0
1 parent 8b65a82
commit 621b4c0
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/bootstrap.php b/bootstrap.php
@@ -4,6 +4,8 @@
 use CultuurNet\BroadwayAMQP\AMQPPublisher;
 use CultuurNet\BroadwayAMQP\DomainMessageJSONDeserializer;
 use CultuurNet\BroadwayAMQP\EventBusForwardingConsumerFactory;
+use CultuurNet\BroadwayAMQP\Message\Body\BodyFactoryInterface;
+use CultuurNet\BroadwayAMQP\Message\Body\PayloadOnlyBodyFactory;
 use CultuurNet\Deserializer\SimpleDeserializerLocator;
 use CultuurNet\Geocoding\CachedGeocodingService;
 use CultuurNet\Geocoding\DefaultGeocodingService;
@@ -459,6 +461,10 @@ function (Application $app) {
     ]
 );
 
+$app->extend('amqp.publisher.body_factory', function (BodyFactoryInterface $originalBodyFactory) {
+    return new PayloadOnlyBodyFactory();
+});
+
 $app->extend(
     'amqp.publisher',
     function (AMQPPublisher $amqpPublisher, Application $app) {