@@ -24,23 +24,23 @@ public function testShouldImplementConfigurationInterface()
2424
2525 public function testCouldBeConstructedWithFactoriesAsFirstArgument ()
2626 {
27- new Configuration ([]);
27+ new Configuration ([], true );
2828 }
2929
3030 public function testThrowIfTransportNotConfigured ()
3131 {
3232 $ this ->expectException (InvalidConfigurationException::class);
3333 $ this ->expectExceptionMessage ('The child node "transport" at path "enqueue" must be configured. ' );
3434
35- $ configuration = new Configuration ([]);
35+ $ configuration = new Configuration ([], true );
3636
3737 $ processor = new Processor ();
3838 $ processor ->processConfiguration ($ configuration , [[]]);
3939 }
4040
4141 public function testShouldInjectFooTransportFactoryConfig ()
4242 {
43- $ configuration = new Configuration ([new FooTransportFactory ()]);
43+ $ configuration = new Configuration ([new FooTransportFactory ()], true );
4444
4545 $ processor = new Processor ();
4646 $ processor ->processConfiguration ($ configuration , [[
@@ -54,7 +54,7 @@ public function testShouldInjectFooTransportFactoryConfig()
5454
5555 public function testThrowExceptionIfFooTransportConfigInvalid ()
5656 {
57- $ configuration = new Configuration ([new FooTransportFactory ()]);
57+ $ configuration = new Configuration ([new FooTransportFactory ()], true );
5858
5959 $ processor = new Processor ();
6060
@@ -72,7 +72,7 @@ public function testThrowExceptionIfFooTransportConfigInvalid()
7272
7373 public function testShouldAllowConfigureDefaultTransport ()
7474 {
75- $ configuration = new Configuration ([new DefaultTransportFactory ()]);
75+ $ configuration = new Configuration ([new DefaultTransportFactory ()], true );
7676
7777 $ processor = new Processor ();
7878 $ processor ->processConfiguration ($ configuration , [[
@@ -84,7 +84,7 @@ public function testShouldAllowConfigureDefaultTransport()
8484
8585 public function testShouldAllowConfigureNullTransport ()
8686 {
87- $ configuration = new Configuration ([new NullTransportFactory ()]);
87+ $ configuration = new Configuration ([new NullTransportFactory ()], true );
8888
8989 $ processor = new Processor ();
9090 $ config = $ processor ->processConfiguration ($ configuration , [[
@@ -106,7 +106,7 @@ public function testShouldAllowConfigureSeveralTransportsSameTime()
106106 new NullTransportFactory (),
107107 new DefaultTransportFactory (),
108108 new FooTransportFactory (),
109- ]);
109+ ], true );
110110
111111 $ processor = new Processor ();
112112 $ config = $ processor ->processConfiguration ($ configuration , [[
@@ -128,7 +128,7 @@ public function testShouldAllowConfigureSeveralTransportsSameTime()
128128
129129 public function testShouldSetDefaultConfigurationForClient ()
130130 {
131- $ configuration = new Configuration ([new DefaultTransportFactory ()]);
131+ $ configuration = new Configuration ([new DefaultTransportFactory ()], true );
132132
133133 $ processor = new Processor ();
134134 $ config = $ processor ->processConfiguration ($ configuration , [[
@@ -149,7 +149,7 @@ public function testShouldSetDefaultConfigurationForClient()
149149 'router_topic ' => 'default ' ,
150150 'router_queue ' => 'default ' ,
151151 'default_processor_queue ' => 'default ' ,
152- 'traceable_producer ' => false ,
152+ 'traceable_producer ' => true ,
153153 'redelivered_delay_time ' => 0 ,
154154 ],
155155 ], $ config );
@@ -160,7 +160,7 @@ public function testThrowExceptionIfRouterTopicIsEmpty()
160160 $ this ->expectException (InvalidConfigurationException::class);
161161 $ this ->expectExceptionMessage ('The path "enqueue.client.router_topic" cannot contain an empty value, but got "". ' );
162162
163- $ configuration = new Configuration ([new DefaultTransportFactory ()]);
163+ $ configuration = new Configuration ([new DefaultTransportFactory ()], true );
164164
165165 $ processor = new Processor ();
166166 $ processor ->processConfiguration ($ configuration , [[
@@ -178,7 +178,7 @@ public function testThrowExceptionIfRouterQueueIsEmpty()
178178 $ this ->expectException (InvalidConfigurationException::class);
179179 $ this ->expectExceptionMessage ('The path "enqueue.client.router_queue" cannot contain an empty value, but got "". ' );
180180
181- $ configuration = new Configuration ([new DefaultTransportFactory ()]);
181+ $ configuration = new Configuration ([new DefaultTransportFactory ()], true );
182182
183183 $ processor = new Processor ();
184184 $ processor ->processConfiguration ($ configuration , [[
@@ -193,7 +193,7 @@ public function testThrowExceptionIfRouterQueueIsEmpty()
193193
194194 public function testShouldThrowExceptionIfDefaultProcessorQueueIsEmpty ()
195195 {
196- $ configuration = new Configuration ([new DefaultTransportFactory ()]);
196+ $ configuration = new Configuration ([new DefaultTransportFactory ()], true );
197197
198198 $ processor = new Processor ();
199199
@@ -211,7 +211,7 @@ public function testShouldThrowExceptionIfDefaultProcessorQueueIsEmpty()
211211
212212 public function testJobShouldBeDisabledByDefault ()
213213 {
214- $ configuration = new Configuration ([]);
214+ $ configuration = new Configuration ([], true );
215215
216216 $ processor = new Processor ();
217217 $ config = $ processor ->processConfiguration ($ configuration , [[
@@ -225,7 +225,7 @@ public function testJobShouldBeDisabledByDefault()
225225
226226 public function testCouldEnableJob ()
227227 {
228- $ configuration = new Configuration ([]);
228+ $ configuration = new Configuration ([], true );
229229
230230 $ processor = new Processor ();
231231 $ config = $ processor ->processConfiguration ($ configuration , [[
@@ -240,7 +240,7 @@ public function testCouldEnableJob()
240240
241241 public function testDoctrinePingConnectionExtensionShouldBeDisabledByDefault ()
242242 {
243- $ configuration = new Configuration ([]);
243+ $ configuration = new Configuration ([], true );
244244
245245 $ processor = new Processor ();
246246 $ config = $ processor ->processConfiguration ($ configuration , [[
@@ -256,7 +256,7 @@ public function testDoctrinePingConnectionExtensionShouldBeDisabledByDefault()
256256
257257 public function testDoctrinePingConnectionExtensionCouldBeEnabled ()
258258 {
259- $ configuration = new Configuration ([]);
259+ $ configuration = new Configuration ([], true );
260260
261261 $ processor = new Processor ();
262262 $ config = $ processor ->processConfiguration ($ configuration , [[
@@ -275,7 +275,7 @@ public function testDoctrinePingConnectionExtensionCouldBeEnabled()
275275
276276 public function testDoctrineClearIdentityMapExtensionShouldBeDisabledByDefault ()
277277 {
278- $ configuration = new Configuration ([]);
278+ $ configuration = new Configuration ([], true );
279279
280280 $ processor = new Processor ();
281281 $ config = $ processor ->processConfiguration ($ configuration , [[
@@ -291,7 +291,7 @@ public function testDoctrineClearIdentityMapExtensionShouldBeDisabledByDefault()
291291
292292 public function testDoctrineClearIdentityMapExtensionCouldBeEnabled ()
293293 {
294- $ configuration = new Configuration ([]);
294+ $ configuration = new Configuration ([], true );
295295
296296 $ processor = new Processor ();
297297 $ config = $ processor ->processConfiguration ($ configuration , [[
@@ -310,7 +310,7 @@ public function testDoctrineClearIdentityMapExtensionCouldBeEnabled()
310310
311311 public function testSignalExtensionShouldBeEnabledByDefault ()
312312 {
313- $ configuration = new Configuration ([]);
313+ $ configuration = new Configuration ([], true );
314314
315315 $ processor = new Processor ();
316316 $ config = $ processor ->processConfiguration ($ configuration , [[
@@ -326,7 +326,7 @@ public function testSignalExtensionShouldBeEnabledByDefault()
326326
327327 public function testSignalExtensionCouldBeDisabled ()
328328 {
329- $ configuration = new Configuration ([]);
329+ $ configuration = new Configuration ([], true );
330330
331331 $ processor = new Processor ();
332332 $ config = $ processor ->processConfiguration ($ configuration , [[
@@ -345,7 +345,7 @@ public function testSignalExtensionCouldBeDisabled()
345345
346346 public function testReplyExtensionShouldBeEnabledByDefault ()
347347 {
348- $ configuration = new Configuration ([]);
348+ $ configuration = new Configuration ([], true );
349349
350350 $ processor = new Processor ();
351351 $ config = $ processor ->processConfiguration ($ configuration , [[
@@ -361,7 +361,7 @@ public function testReplyExtensionShouldBeEnabledByDefault()
361361
362362 public function testReplyExtensionCouldBeDisabled ()
363363 {
364- $ configuration = new Configuration ([]);
364+ $ configuration = new Configuration ([], true );
365365
366366 $ processor = new Processor ();
367367 $ config = $ processor ->processConfiguration ($ configuration , [[
@@ -380,7 +380,7 @@ public function testReplyExtensionCouldBeDisabled()
380380
381381 public function testShouldDisableAsyncEventsByDefault ()
382382 {
383- $ configuration = new Configuration ([]);
383+ $ configuration = new Configuration ([], true );
384384
385385 $ processor = new Processor ();
386386 $ config = $ processor ->processConfiguration ($ configuration , [[
@@ -396,7 +396,7 @@ public function testShouldDisableAsyncEventsByDefault()
396396
397397 public function testShouldAllowEnableAsyncEvents ()
398398 {
399- $ configuration = new Configuration ([]);
399+ $ configuration = new Configuration ([], true );
400400
401401 $ processor = new Processor ();
402402
@@ -427,7 +427,7 @@ public function testShouldAllowEnableAsyncEvents()
427427
428428 public function testShouldSetDefaultConfigurationForConsumption ()
429429 {
430- $ configuration = new Configuration ([]);
430+ $ configuration = new Configuration ([], true );
431431
432432 $ processor = new Processor ();
433433 $ config = $ processor ->processConfiguration ($ configuration , [[
@@ -444,7 +444,7 @@ public function testShouldSetDefaultConfigurationForConsumption()
444444
445445 public function testShouldAllowConfigureConsumption ()
446446 {
447- $ configuration = new Configuration ([]);
447+ $ configuration = new Configuration ([], true );
448448
449449 $ processor = new Processor ();
450450 $ config = $ processor ->processConfiguration ($ configuration , [[
0 commit comments