@@ -46,7 +46,7 @@ discard block |
||
| 46 | 46 | $key = 'example_key'; |
| 47 | 47 | $ch->expects($this->once()) |
| 48 | 48 | ->method('queue_bind') |
| 49 | - ->will($this->returnCallback(function ($d, $s, $k, $n, $a) use ($destination, $source, $key) { |
|
| 49 | + ->will($this->returnCallback(function($d, $s, $k, $n, $a) use ($destination, $source, $key) { |
|
| 50 | 50 | Assert::assertSame($destination, $d); |
| 51 | 51 | Assert::assertSame($source, $s); |
| 52 | 52 | Assert::assertSame($key, $k); |
@@ -71,7 +71,7 @@ discard block |
||
| 71 | 71 | $key = 'example_key'; |
| 72 | 72 | $ch->expects($this->once()) |
| 73 | 73 | ->method('exchange_bind') |
| 74 | - ->will($this->returnCallback(function ($d, $s, $k, $n, $a) use ($destination, $source, $key) { |
|
| 74 | + ->will($this->returnCallback(function($d, $s, $k, $n, $a) use ($destination, $source, $key) { |
|
| 75 | 75 | Assert::assertSame($destination, $d); |
| 76 | 76 | Assert::assertSame($source, $s); |
| 77 | 77 | Assert::assertSame($key, $k); |
@@ -37,7 +37,7 @@ discard block |
||
| 37 | 37 | { |
| 38 | 38 | $this->container = $container; |
| 39 | 39 | |
| 40 | - $loader = new XmlFileLoader($this->container, new FileLocator(array(__DIR__ . '/../Resources/config'))); |
|
| 40 | + $loader = new XmlFileLoader($this->container, new FileLocator(array(__DIR__.'/../Resources/config'))); |
|
| 41 | 41 | $loader->load('rabbitmq.xml'); |
| 42 | 42 | |
| 43 | 43 | $configuration = $this->getConfiguration($configs, $container); |
@@ -250,7 +250,7 @@ discard block |
||
| 250 | 250 | |
| 251 | 251 | if (empty($consumer['queues']) && empty($consumer['queues_provider'])) { |
| 252 | 252 | throw new InvalidConfigurationException( |
| 253 | - "Error on loading $key multiple consumer. " . |
|
| 253 | + "Error on loading $key multiple consumer. ". |
|
| 254 | 254 | "Either 'queues' or 'queues_provider' parameters should be defined." |
| 255 | 255 | ); |
| 256 | 256 | } |
@@ -330,7 +330,7 @@ discard block |
||
| 330 | 330 | |
| 331 | 331 | if (empty($consumer['queue_options_provider'])) { |
| 332 | 332 | throw new InvalidConfigurationException( |
| 333 | - "Error on loading $key dynamic consumer. " . |
|
| 333 | + "Error on loading $key dynamic consumer. ". |
|
| 334 | 334 | "'queue_provider' parameter should be defined." |
| 335 | 335 | ); |
| 336 | 336 | } |