8000 Rename Messenger adapters to Transports · symfony/symfony@68208f3 · GitHub
[go: up one dir, main page]
Skip to content

Commit 68208f3

Browse files
srozesroze
committed
Rename Messenger adapters to Transports
1 parent daf7ac0 commit 68208f3

26 files changed

+62
-67
lines changed

‎src/Symfony/Bundle/FrameworkBundle/DependencyInjection/Configuration.php

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -971,7 +971,7 @@ private function addMessengerSection(ArrayNodeDefinition $rootNode)
971971
->arrayNode('messenger')
972972
->info('Messenger configuration')
973973
->{!class_exists(FullStack::class) && interface_exists(MessageBusInterface::class) ? 'canBeDisabled' : 'canBeEnabled'}()
974-
->fixXmlConfig('adapter')
974+
->fixXmlConfig('transport')
975975
->fixXmlConfig('bus', 'buses')
976976
->children()
977977
->arrayNode('routing')
@@ -1024,7 +1024,7 @@ function ($a) {
10241024
->end()
10251025
->scalarNode('encoder')->defaultValue('messenger.transport.serializer')->end()
10261026
->scalarNode('decoder')->defaultValue('messenger.transport.serializer')->end()
1027-
->arrayNode('adapters')
1027+
->arrayNode('transports')
10281028
->useAttributeAsKey('name')
10291029
->arrayPrototype()
10301030
->beforeNormalization()

‎src/Symfony/Bundle/FrameworkBundle/DependencyInjection/FrameworkExtension.php

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1449,7 +1449,7 @@ private function registerMessengerConfiguration(array $config, ContainerBuilder
14491449
$loader->load('messenger.xml');
14501450

14511451
if ($this->isConfigEnabled($container, $config['serializer'])) {
1452-
if (\count($config['adapters']) > 0 && !$this->isConfigEnabled($container, $serializerConfig)) {
1452+
if (\count($config['transports']) > 0 && !$this->isConfigEnabled($container, $serializerConfig)) {
14531453
throw new LogicException('Using the default encoder/decoder, Symfony Messenger requires the Serializer. Enable it or install it by running "composer require symfony/serializer-pack".');
14541454
}
14551455

@@ -1505,17 +1505,17 @@ private function registerMessengerConfiguration(array $config, ContainerBuilder
15051505

15061506
$container->getDefinition('messenger.asynchronous.routing.sender_locator')->replaceArgument(1, $messageToSenderIdsMapping);
15071507

1508-
foreach ($config['adapters'] as $name => $adapter) {
1508+
foreach ($config['transports'] as $name => $transport) {
15091509
$senderDefinition = (new Definition(SenderInterface::class))
1510-
->setFactory(array(new Reference('messenger.adapter_factory'), 'createSender'))
1511-
->setArguments(array($adapter['dsn'], $adapter['options']))
1510+
->setFactory(array(new Reference('messenger.transport_factory'), 'createSender'))
1511+
->setArguments(array($transport['dsn'], $transport['options']))
15121512
->addTag('messenger.sender', array('name' => $name))
15131513
;
15141514
$container->setDefinition('messenger.sender.'.$name, $senderDefinition);
15151515

15161516
$receiverDefinition = (new Definition(ReceiverInterface::class))
1517-
->setFactory(array(new Reference('messenger.adapter_factory'), 'createReceiver'))
1518-
->setArguments(array($adapter['dsn'], $adapter['options']))
1517+
->setFactory(array(new Reference('messenger.transport_factory'), 'createReceiver'))
1518+
->setArguments(array($transport['dsn'], $transport['options']))
15191519
->addTag('messenger.receiver', array('name' => $name))
15201520
;
15211521
$container->setDefinition('messenger.receiver.'.$name, $receiverDefinition);

‎src/Symfony/Bundle/FrameworkBundle/Resources/config/messenger.xml

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -60,16 +60,16 @@
6060
</service>
6161

6262
<!-- Adapters -->
63-
<service id="messenger.adapter_factory" class="Symfony\Component\Messenger\Adapter\Factory\ChainAdapterFactory">
64-
<argument type="tagged" tag="messenger.adapter_factory" />
63+
<service id="messenger.transport_factory" class="Symfony\Component\Messenger\Transport\Factory\ChainTransportFactory">
64+
<argument type="tagged" tag="messenger.transport_factory" />
6565
</service>
6666

67-
<service id="messenger.adapter.amqp.factory" class="Symfony\Component\Messenger\Adapter\AmqpExt\AmqpAdapterFactory">
67+
<service id="messenger.adapter.amqp.factory" class="Symfony\Component\Messenger\Transport\AmqpExt\AmqpTransportFactory">
6868
<argument type="service" id="messenger.transport.encoder" />
6969
<argument type="service" id="messenger.transport.decoder" />
7070
<argument>%kernel.debug%</argument>
7171

72-
<tag name="messenger.adapter_factory" />
72+
<tag name="messenger.transport_factory" />
7373
</service>
7474
</services>
7575
</container>

‎src/Symfony/Bundle/FrameworkBundle/Resources/config/schema/symfony-1.0.xsd

Lines changed: 2 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -356,7 +356,7 @@
356356
<xsd:element name="encoder" type="xsd:string" minOccurs="0" />
357357
<xsd:element name="decoder" type="xsd:string" minOccurs="0" />
358358
<xsd:element name="routing" type="messenger_routing" minOccurs="0" maxOccurs="unbounded" />
359-
<xsd:element name="adapter" type="messenger_adapter" minOccurs="0" maxOccurs="unbounded" />
359+
<xsd:element name="transport" type="messenger_transport" minOccurs="0" maxOccurs="unbounded" />
360360
<xsd:element name="bus" type="messenger_bus" minOccurs="0" maxOccurs="unbounded" />
361361
</xsd:sequence>
362362
<xsd:attribute name="default-bus" type="xsd:string" />
@@ -381,19 +381,14 @@
381381
<xsd:attribute name="service" type="xsd:string" use="required"/>
382382
</xsd:complexType>
383383

384-
<xsd:complexType name="messenger_adapter">
384+
<xsd:complexType name="messenger_transport">
385385
<xsd:sequence>
386386
<xsd:element name="options" type="metadata" minOccurs="0" maxOccurs="unbounded" />
387387
</xsd:sequence>
388388
<xsd:attribute name="name" type="xsd:string" />
389389
<xsd:attribute name="dsn" type="xsd:string" />
390390
</xsd:complexType>
391391

392-
<xsd:complexType name="messenger_adapter_option">
393-
<xsd:attribute name="name" type="xsd:string" />
394-
<xsd:attribute name="value" type="xsd:string" />
395-
</xsd:complexType>
396-
397392
<xsd:complexType name="messenger_bus">
398393
<xsd:sequence>
399394
<xsd:element name="middleware" type="xsd:string" minOccurs="0" maxOccurs="unbounded" />

‎src/Symfony/Bundle/FrameworkBundle/Tests/DependencyInjection/ConfigurationTest.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -254,7 +254,7 @@ class_exists(SemaphoreStore::class) && SemaphoreStore::isSupported() ? 'semaphor
254254
'messenger' => array(
255255
'enabled' => !class_exists(FullStack::class) && interface_exists(MessageBusInterface::class),
256256
'routing' => array(),
257-
'adapters' => array(),
257+
'transports' => array(),
258258
'serializer' => array(
259259
'enabled' => true,
260260
'format' => 'json',

‎src/Symfony/Bundle/FrameworkBundle/Tests/DependencyInjection/Fixtures/php/messenger_transport_no_serializer.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@
88
'serializer' => array(
99
'enabled' => true,
1010
),
11-
'adapters' => array(
11+
'transports' => array(
1212
'default' => 'amqp://localhost/%2f/messages',
1313
),
1414
),

‎src/Symfony/Bundle/FrameworkBundle/Tests/DependencyInjection/Fixtures/php/messenger_adapter.php renamed to ‎src/Symfony/Bundle/FrameworkBundle/Tests/DependencyInjection/Fixtures/php/messenger_transports.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
$container->loadFromExtension('framework', array(
44
'serializer' => true,
55
'messenger' => array(
6-
'adapters' => array(
6+
'transports' => array(
77
'default' => 'amqp://localhost/%2f/messages',
88
'customised' => array(
99
'dsn' => 'amqp://localhost/%2f/messages?exchange_name=exchange_name',

‎src/Symfony/Bundle/FrameworkBundle/Tests/DependencyInjection/Fixtures/xml/messenger_transport_no_serializer.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@
99
<framework:serializer enabled="false" />
1010
<framework:messenger>
1111
<framework:serializer enabled="true" />
12-
<framework:adapter name="default" dsn="amqp://localhost/%2f/messages" />
12+
<framework:transport name="default" dsn="amqp://localhost/%2f/messages" />
1313
</framework:messenger>
1414
</framework:config>
1515
</container>

‎src/Symfony/Bundle/FrameworkBundle/Tests/DependencyInjection/Fixtures/xml/messenger_adapter.xml renamed to ‎src/Symfony/Bundle/FrameworkBundle/Tests/DependencyInjection/Fixtures/xml/messenger_transports.xml

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -8,14 +8,14 @@
88
<framework:config>
99
<framework:serializer enabled="true" />
1010
<framework:messenger>
11-
<framework:adapter name="default" dsn="amqp://localhost/%2f/messages" />
12-
<framework:adapter name="customised" dsn="amqp://localhost/%2f/messages?exchange_name=exchange_name">
11+
<framework:transport name="default" dsn="amqp://localhost/%2f/messages" />
12+
<framework:transport name="customised" dsn="amqp://localhost/%2f/messages?exchange_name=exchange_name">
1313
<framework:options>
1414
<framework:queue>
1515
<framework:name>Queue</framework:name>
1616
</framework:queue>
1717
</framework:options>
18-
</framework:adapter>
18+
</framework:transport>
1919
</framework:messenger>
2020
</framework:config>
2121
</container>

‎src/Symfony/Bundle/FrameworkBundle/Tests/DependencyInjection/Fixtures/yml/messenger_transport_no_serializer.yml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,5 +4,5 @@ framework:
44
messenger:
55
serializer:
66
enabled: true
7-
adapters:
7+
transports:
88
default: 'amqp://localhost/%2f/messages'

‎src/Symfony/Bundle/FrameworkBundle/Tests/DependencyInjection/Fixtures/yml/messenger_adapter.yml renamed to ‎src/Symfony/Bundle/FrameworkBundle/Tests/DependencyInjection/Fixtures/yml/messenger_transports.yml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
framework:
22
serializer: true
33
messenger:
4-
adapters:
4+
transports:
55
default: 'amqp://localhost/%2f/messages'
66
customised:
77
dsn: 'amqp://localhost/%2f/messages?exchange_name=exchange_name'

‎src/Symfony/Bundle/FrameworkBundle/Tests/DependencyInjection/FrameworkExtensionTest.php

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -529,9 +529,9 @@ public function testMessenger()
529529
$this->assertTrue($container->has('message_bus'));
530530
}
531531

532-
public function testMessengerAdapter()
532+
public function testMessengerTransports()
533533
{
534-
$container = $this->createContainerFromFile('messenger_adapter');
534+
$container = $this->createContainerFromFile('messenger_transports');
535535
$this->assertTrue($container->hasDefinition('messenger.sender.default'));
536536
$this->assertTrue($container->getDefinition('messenger.sender.default')->hasTag('messenger.sender'));
537537
$this->assertEquals(array(array('name' => 'default')), $container->getDefinition('messenger.sender.default')->getTag('messenger.sender'));
@@ -543,7 +543,7 @@ public function testMessengerAdapter()
543543
$senderFactory = $container->getDefinition('messenger.sender.customised')->getFactory();
544544
$senderArguments = $container->getDefinition('messenger.sender.customised')->getArguments();
545545

546-
$this->assertEquals(array(new Reference('messenger.adapter_factory'), 'createSender'), $senderFactory);
546+
$this->assertEquals(array(new Reference('messenger.transport_factory'), 'createSender'), $senderFactory);
547547
$this->assertCount(2, $senderArguments);
548548
$this->assertSame('amqp://localhost/%2f/messages?exchange_name=exchange_name', $senderArguments[0]);
549549
$this->assertSame(array('queue' => array('name' => 'Queue')), $senderArguments[1]);
@@ -552,7 +552,7 @@ public function testMessengerAdapter()
552552
$receiverFactory = $container->getDefinition('messenger.receiver.customised')->getFactory();
553553
$receiverArguments = $container->getDefinition('messenger.receiver.customised')->getArguments();
554554

555-
$this->assertEquals(array(new Reference('messenger.adapter_factory'), 'createReceiver'), $receiverFactory);
555+
$this->assertEquals(array(new Reference('messenger.transport_factory'), 'createReceiver'), $receiverFactory);
556556
$this->assertCount(2, $receiverArguments);
557557
$this->assertSame('amqp://localhost/%2f/messages?exchange_name=exchange_name', $receiverArguments[0]);
558558
$this->assertSame(array('queue' => array('name' => 'Queue')), $receiverArguments[1]);

‎src/Symfony/Component/Messenger/Tests/DependencyInjection/MessengerPassTest.php

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -16,8 +16,8 @@
1616
use Symfony\Component\DependencyInjection\ContainerBuilder;
1717
use Symfony\Component\DependencyInjection\Reference;
1818
use Symfony\Component\DependencyInjection\ServiceLocator;
19-
use Symfony\Component\Messenger\Adapter\AmqpExt\AmqpReceiver;
20-
use Symfony\Component\Messenger\Adapter\AmqpExt\AmqpSender;
19+
use Symfony\Component\Messenger\Transport\AmqpExt\AmqpReceiver;
20+
use Symfony\Component\Messenger\Transport\AmqpExt\AmqpSender;
2121
use Symfony\Component\Messenger\ContainerHandlerLocator;
2222
use Symfony\Component\Messenger\DataCollector\MessengerDataCollector;
2323
use Symfony\Component\Messenger\DependencyInjection\MessengerPass;

‎src/Symfony/Component/Messenger/Tests/Adapter/AmqpExt/AmqpExtIntegrationTest.php renamed to ‎src/Symfony/Component/Messenger/Tests/Transport/AmqpExt/AmqpExtIntegrationTest.php

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -9,12 +9,12 @@
99
* file that was distributed with this source code.
1010
*/
1111

12-
namespace Symfony\Component\Messenger\Tests\Adapter\AmqpExt;
12+
namespace Symfony\Component\Messenger\Tests\Transport\AmqpExt;
1313

1414
use PHPUnit\Framework\TestCase;
15-
use Symfony\Component\Messenger\Adapter\AmqpExt\AmqpReceiver;
16-
use Symfony\Component\Messenger\Adapter\AmqpExt\AmqpSender;
17-
use Symfony\Component\Messenger\Adapter\AmqpExt\Connection;
15+
use Symfony\Component\Messenger\Transport\AmqpExt\AmqpReceiver;
16+
use Symfony\Component\Messenger\Transport\AmqpExt\AmqpSender;
17+
use Symfony\Component\Messenger\Transport\AmqpExt\Connection;
1818
use Symfony\Component\Messenger\Tests\Fixtures\DummyMessage;
1919
use Symfony\Component\Messenger\Transport\Serialization\Serializer;
2020
use Symfony\Component\Process\PhpProcess;

‎src/Symfony/Component/Messenger/Tests/Adapter/AmqpExt/AmqpReceiverTest.php renamed to ‎src/Symfony/Component/Messenger/Tests/Transport/AmqpExt/AmqpReceiverTest.php

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -9,12 +9,12 @@
99
* file that was distributed with this source code.
1010
*/
1111

12-
namespace Symfony\Component\Messenger\Tests\Adapter\AmqpExt;
12+
namespace Symfony\Component\Messenger\Tests\Transport\AmqpExt;
1313

1414
use PHPUnit\Framework\TestCase;
15-
use Symfony\Component\Messenger\Adapter\AmqpExt\AmqpReceiver;
16-
use Symfony\Component\Messenger\Adapter\AmqpExt\Connection;
17-
use Symfony\Component\Messenger\Adapter\AmqpExt\Exception\RejectMessageExceptionInterface;
15+
use Symfony\Component\Messenger\Transport\AmqpExt\AmqpReceiver;
16+
use Symfony\Component\Messenger\Transport\AmqpExt\Connection;
17+
use Symfony\Component\Messenger\Transport\AmqpExt\Exception\RejectMessageExceptionInterface;
1818
use Symfony\Component\Messenger\Tests\Fixtures\DummyMessage;
1919
use Symfony\Component\Messenger\Transport\Serialization\Serializer;
2020
use Symfony\Component\Serializer as SerializerComponent;
@@ -51,7 +51,7 @@ public function testItSendTheDecodedMessageToTheHandlerAndAcknowledgeIt()
5151
}
5252

5353
/**
54-
* @expectedException \Symfony\Component\Messenger\Tests\Adapter\AmqpExt\InterruptException
54+
* @expectedException \Symfony\Component\Messenger\Tests\Transport\AmqpExt\InterruptException
5555
*/
5656
public function testItNonAcknowledgeTheMessageIfAnExceptionHappened()
5757
{
@@ -77,7 +77,7 @@ public function testItNonAcknowledgeTheMessageIfAnExceptionHappened()
7777
}
7878

7979
/**
80-
* @expectedException \Symfony\Component\Messenger\Tests\Adapter\AmqpExt\WillNeverWorkException
80+
* @expectedException \Symfony\Component\Messenger\Tests\Transport\AmqpExt\WillNeverWorkException
8181
*/
8282
public function testItRejectsTheMessageIfTheExceptionIsARejectMessageExceptionInterface()
8383
{

‎src/Symfony/Component/Messenger/Tests/Adapter/AmqpExt/AmqpSenderTest.php renamed to ‎src/Symfony/Component/Messenger/Tests/Transport/AmqpExt/AmqpSenderTest.php

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -9,10 +9,10 @@
99
* file that was distributed with this source code.
1010
*/
1111

12-
namespace Symfony\Component\Messenger\Tests\Adapter\AmqpExt;
12+
namespace Symfony\Component\Messenger\Tests\Transport\AmqpExt;
1313

14-
use Symfony\Component\Messenger\Adapter\AmqpExt\AmqpSender;
15-
use Symfony\Component\Messenger\Adapter\AmqpExt\Connection;
14+
use Symfony\Component\Messenger\Transport\AmqpExt\AmqpSender;
15+
use Symfony\Component\Messenger\Transport\AmqpExt\Connection;
1616
use Symfony\Component\Messenger\Tests\Fixtures\DummyMessage;
1717
use PHPUnit\Framework\TestCase;
1818
use Symfony\Component\Messenger\Transport\Serialization\EncoderInterface;

‎src/Symfony/Component/Messenger/Tests/Adapter/AmqpExt/ConnectionTest.php renamed to ‎src/Symfony/Component/Messenger/Tests/Transport/AmqpExt/ConnectionTest.php

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -9,11 +9,11 @@
99
* file that was distributed with this source code.
1010
*/
1111

12-
namespace Symfony\Component\Messenger\Tests\Adapter\AmqpExt;
12+
namespace Symfony\Component\Messenger\Tests\Transport\AmqpExt;
1313

1414
use PHPUnit\Framework\TestCase;
15-
use Symfony\Component\Messenger\Adapter\AmqpExt\AmqpFactory;
16-
use Symfony\Component\Messenger\Adapter\AmqpExt\Connection;
15+
use Symfony\Component\Messenger\Transport\AmqpExt\AmqpFactory;
16+
use Symfony\Component\Messenger\Transport\AmqpExt\Connection;
1717

1818
/**
1919
* @requires extension amqp

‎src/Symfony/Component/Messenger/Tests/Adapter/AmqpExt/Fixtures/long_receiver.php renamed to ‎src/Symfony/Component/Messenger/Tests/Transport/AmqpExt/Fixtures/long_receiver.php

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -12,9 +12,9 @@
1212

1313
require_once $autoload;
1414

15-
use Symfony\Component\Messenger\Adapter\AmqpExt\AmqpReceiver;
16-
use Symfony\Component\Messenger\Adapter\AmqpExt\AmqpSender;
17-
use Symfony\Component\Messenger\Adapter\AmqpExt\Connection;
15+
use Symfony\Component\Messenger\Transport\AmqpExt\AmqpReceiver;
16+
use Symfony\Component\Messenger\Transport\AmqpExt\AmqpSender;
17+
use Symfony\Component\Messenger\Transport\AmqpExt\Connection;
1818
use Symfony\Component\Messenger\MessageBusInterface;
1919
use Symfony\Component\Messenger\Transport\Serialization\Serializer;
2020
use Symfony\Component\Messenger\Worker;

‎src/Symfony/Component/Messenger/Adapter/AmqpExt/AmqpFactory.php renamed to ‎src/Symfony/Component/Messenger/Transport/AmqpExt/AmqpFactory.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@
99
* file that was distributed with this source code.
1010
*/
1111

12-
namespace Symfony\Component\Messenger\Adapter\AmqpExt;
12+
namespace Symfony\Component\Messenger\Transport\AmqpExt;
1313

1414
class AmqpFactory
1515
{

‎src/Symfony/Component/Messenger/Adapter/AmqpExt/AmqpReceiver.php renamed to ‎src/Symfony/Component/Messenger/Transport/AmqpExt/AmqpReceiver.php

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -9,9 +9,9 @@
99
* file that was distributed with this source code.
1010
*/
1111

12-
namespace Symfony\Component\Messenger\Adapter\AmqpExt;
12+
namespace Symfony\Component\Messenger\Transport\AmqpExt;
1313

14-
use Symfony\Component\Messenger\Adapter\AmqpExt\Exception\RejectMessageExceptionInterface;
14+
use Symfony\Component\Messenger\Transport\AmqpExt\Exception\RejectMessageExceptionInterface;
1515
use Symfony\Component\Messenger\Transport\ReceiverInterface;
1616
use Symfony\Component\Messenger\Transport\Serialization\DecoderInterface;
1717

‎src/Symfony/Component/Messenger/Adapter/AmqpExt/AmqpSender.php renamed to ‎src/Symfony/Component/Messenger/Transport/AmqpExt/AmqpSender.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@
99
* file that was distributed with this source code.
1010
*/
1111

12-
namespace Symfony\Component\Messenger\Adapter\AmqpExt;
12+
namespace Symfony\Component\Messenger\Transport\AmqpExt;
1313

1414
use Symfony\Component\Messenger\Transport\SenderInterface;
1515
use Symfony\Component\Messenger\Transport\Serialization\EncoderInterface;

‎src/Symfony/Component/Messenger/Adapter/AmqpExt/AmqpAdapterFactory.php renamed to ‎src/Symfony/Component/Messenger/Transport/AmqpExt/AmqpTransportFactory.php

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -9,9 +9,9 @@
99
* file that was distributed with this source code.
1010
*/
1111

12-
namespace Symfony\Component\Messenger\Adapter\AmqpExt;
12+
namespace Symfony\Component\Messenger\Transport\AmqpExt;
1313

14-
use Symfony\Component\Messenger\Adapter\Factory\AdapterFactoryInterface;
14+
use Symfony\Component\Messenger\Transport\Factory\TransportFactoryInterface;
1515
use Symfony\Component\Messenger\Transport\ReceiverInterface;
1616
use Symfony\Component\Messenger\Transport\SenderInterface;
1717
use Symfony\Component\Messenger\Transport\Serialization\DecoderInterface;
@@ -20,7 +20,7 @@
2020
/**
2121
* @author Samuel Roze <samuel.roze@gmail.com>
2222
*/
23-
class AmqpAdapterFactory implements AdapterFactoryInterface
23+
class AmqpTransportFactory implements TransportFactoryInterface
2424
{
2525
private $encoder;
2626
private $decoder;

‎src/Symfony/Component/Messenger/Adapter/AmqpExt/Connection.php renamed to ‎src/Symfony/Component/Messenger/Transport/AmqpExt/Connection.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@
99
* file that was distributed with this source code.
1010
*/
1111

12-
namespace Symfony\Component\Messenger\Adapter\AmqpExt;
12+
namespace Symfony\Component\Messenger\Transport\AmqpExt;
1313

1414
/**
1515
* An AMQP connection.

‎src/Symfony/Component/Messenger/Adapter/AmqpExt/Exception/RejectMessageExceptionInterface.php renamed to ‎src/Symfony/Component/Messenger/Transport/AmqpExt/Exception/RejectMessageExceptionInterface.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@
99
* file that was distributed with this source code.
1010
*/
1111

12-
namespace Symfony\Component\Messenger\Adapter\AmqpExt\Exception;
12+
namespace Symfony\Component\Messenger\Transport\AmqpExt\Exception;
1313

1414
/**
1515
* If something goes wrong while consuming and handling a message from the AMQP broker, there are two choices: rejecting

‎src/Symfony/Component/Messenger/Adapter/Factory/ChainAdapterFactory.php renamed to ‎src/Symfony/Component/Messenger/Transport/Factory/ChainTransportFactory.php

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -9,20 +9,20 @@
99
* file that was distributed with this source code.
1010
*/
1111

12-
namespace Symfony\Component\Messenger\Adapter\Factory;
12+
namespace Symfony\Component\Messenger\Transport\Factory;
1313

1414
use Symfony\Component\Messenger\Transport\ReceiverInterface;
1515
use Symfony\Component\Messenger\Transport\SenderInterface;
1 9860 616

1717
/**
1818
* @author Samuel Roze <samuel.roze@gmail.com>
1919
*/
20-
class ChainAdapterFactory implements AdapterFactoryInterface
20+
class ChainTransportFactory implements TransportFactoryInterface
2121
{
2222
private $factories;
2323

2424
/**
25-
* @param iterable|AdapterFactoryInterface[] $factories
25+
* @param iterable|TransportFactoryInterface[] $factories
2626
*/
2727
public function __construct(iterable $factories)
2828
{

0 commit comments

Comments
 (0)
0