Merge d46404e into 9b19fcd

bootstrap.php

@@ -7,6 +7,7 @@
 use Broadway\Serializer\SimpleInterfaceSerializer;
 use CommerceGuys\Intl\Currency\CurrencyRepository;
 use CommerceGuys\Intl\NumberFormat\NumberFormatRepository;
+use CultuurNet\Broadway\EventHandling\ReplayFilteringEventListener;
 use CultuurNet\BroadwayAMQP\DomainMessageJSONDeserializer;
 use CultuurNet\BroadwayAMQP\EventBusForwardingConsumerFactory;
 use CultuurNet\Deserializer\SimpleDeserializerLocator;
@@ -480,18 +481,20 @@ function (Application $app) {
 
 $app['saga_manager'] = $app->share(
     function (Application $app) {
-        return new MultipleSagaManager(
-            $app['saga_repository'],
-            [
-                'uitpas_sync' => $app['uitpas_event_saga'],
-            ],
-            new StateManager(
+        return new ReplayFilteringEventListener(
+            new MultipleSagaManager(
                 $app['saga_repository'],
-                $app['uuid_generator']
-            ),
-            new StaticallyConfiguredSagaMetadataFactory(),
-            new EventDispatcher(),
-            $app['state_copier']
+                [
+                    'uitpas_sync' => $app['uitpas_event_saga'],
+                ],
+                new StateManager(
+                    $app['saga_repository'],
+                    $app['uuid_generator']
+                ),
+                new StaticallyConfiguredSagaMetadataFactory(),
+                new EventDispatcher(),
+                $app['state_copier']
+            )
         );
     }
 );

composer.json

@@ -7,6 +7,7 @@
     "require": {
         "silex/silex": "~1.3",
         "cultuurnet/udb3": "~0.1",
+        "cultuurnet/broadway-tools": "dev-feature/III-1777 as 0.1",
         "deralex/yaml-config-service-provider": "~1.0",
         "knplabs/console-service-provider": "~1.0",
         "jdesrosiers/silex-cors-provider": "~0.1.4",