Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly
Appearance settings

Commit 3945a5c

Browse filesBrowse files
fabpotfabpot
committed
feature #35422 [Messenger] Move Transports to separate packages (Nyholm)
This PR was squashed before being merged into the 5.1-dev branch (closes #35422). Discussion ---------- [Messenger] Move Transports to separate packages | Q | A | ------------- | --- | Branch? | master | Bug fix? | no | New feature? | no | Deprecations? | no | Tickets | | License | MIT | Doc PR | coming I think it is a good idea to have the transports in a separate package. The benefits a many: - It allows us to have usage statistics - The core messenger package is smaller - Transports can have dependencies specified in composer.json instead of just suggests This PR will not break BC but it requires to configure subtree split. Commits ------- 2990c8f [Messenger] Move Transports to separate packages
2 parents 1cfadb4 + 2990c8f commit 3945a5c
Copy full SHA for 3945a5c

File tree

Expand file treeCollapse file tree

94 files changed

+3065
-2050
lines changed
Filter options

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
Dismiss banner
Expand file treeCollapse file tree

94 files changed

+3065
-2050
lines changed

‎UPGRADE-5.1.md

Copy file name to clipboardExpand all lines: UPGRADE-5.1.md
+7Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,13 @@ HttpFoundation
2424
`RedirectResponse::create()`, and `StreamedResponse::create()` methods (use
2525
`__construct()` instead)
2626

27+
Messenger
28+
---------
29+
30+
* Deprecated AmqpExt transport. It has moved to a separate package. Run `composer require symfony/amqp-messenger` to use the new classes.
31+
* Deprecated Doctrine transport. It has moved to a separate package. Run `composer require symfony/doctrine-messenger` to use the new classes.
32+
* Deprecated RedisExt transport. It has moved to a separate package. Run `composer require symfony/redis-messenger` to use the new classes.
33+
2734
Routing
2835
-------
2936

‎UPGRADE-6.0.md

Copy file name to clipboardExpand all lines: UPGRADE-6.0.md
+7Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,13 @@ HttpFoundation
2424
`RedirectResponse::create()`, and `StreamedResponse::create()` methods (use
2525
`__construct()` instead)
2626

27+
Messenger
28+
---------
29+
30+
* Removed AmqpExt transport. Run `composer require symfony/amqp-messenger` to keep the transport in your application.
31+
* Removed Doctrine transport. Run `composer require symfony/doctrine-messenger` to keep the transport in your application.
32+
* Removed RedisExt transport. Run `composer require symfony/redis-messenger` to keep the transport in your application.
33+
2734
Routing
2835
-------
2936

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

Copy file name to clipboardExpand all lines: src/Symfony/Bundle/FrameworkBundle/DependencyInjection/FrameworkExtension.php
+18Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -81,6 +81,8 @@
8181
use Symfony\Component\Mailer\Bridge\Postmark\Transport\PostmarkTransportFactory;
8282
use Symfony\Component\Mailer\Bridge\Sendgrid\Transport\SendgridTransportFactory;
8383
use Symfony\Component\Mailer\Mailer;
84+
use Symfony\Component\Messenger\Bridge\Amqp\Transport\AmqpTransportFactory;
85+
use Symfony\Component\Messenger\Bridge\Redis\Transport\RedisTransportFactory;
8486
use Symfony\Component\Messenger\Handler\MessageHandlerInterface;
8587
use Symfony\Component\Messenger\MessageBus;
8688
use Symfony\Component\Messenger\MessageBusInterface;
@@ -312,6 +314,22 @@ public function load(array $configs, ContainerBuilder $container)
312314
$container->removeDefinition('console.command.messenger_failed_messages_show');
313315
$container->removeDefinition('console.command.messenger_failed_messages_remove');
314316
$container->removeDefinition('cache.messenger.restart_workers_signal');
317+
318+
if ($container->hasDefinition('messenger.transport.amqp.factory') && !class_exists(AmqpTransportFactory::class)) {
319+
if (class_exists(\Symfony\Component\Messenger\Transport\AmqpExt\AmqpTransportFactory::class)) {
320+
$container->getDefinition('messenger.transport.amqp.factory')->setClass(\Symfony\Component\Messenger\Transport\AmqpExt\AmqpTransportFactory::class);
321+
} else {
322+
$container->removeDefinition('messenger.transport.amqp.factory');
323+
}
324+
}
325+
326+
if ($container->hasDefinition('messenger.transport.redis.factory') && !class_exists(RedisTransportFactory::class)) {
327+
if (class_exists(\Symfony\Component\Messenger\Transport\RedisExt\RedisTransportFactory::class)) {
328+
$container->getDefinition('messenger.transport.redis.factory')->setClass(\Symfony\Component\Messenger\Transport\RedisExt\RedisTransportFactory::class);
329+
} else {
330+
$container->removeDefinition('messenger.transport.redis.factory');
331+
}
332+
}
315333
}
316334

317335
if ($this->httpClientConfigEnabled = $this->isConfigEnabled($container, $config['http_client'])) {

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

Copy file name to clipboardExpand all lines: src/Symfony/Bundle/FrameworkBundle/Resources/config/messenger.xml
+2-2Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -67,11 +67,11 @@
6767
<argument type="tagged_iterator" tag="messenger.transport_factory" />
6868
</service>
6969

70-
<service id="messenger.transport.amqp.factory" class="Symfony\Component\Messenger\Transport\AmqpExt\AmqpTransportFactory">
70+
<service id="messenger.transport.amqp.factory" class="Symfony\Component\Messenger\Bridge\Amqp\Transport\AmqpTransportFactory">
7171
<tag name="messenger.transport_factory" />
7272
</service>
7373

74-
<service id="messenger.transport.redis.factory" class="Symfony\Component\Messenger\Transport\RedisExt\RedisTransportFactory">
74+
<service id="messenger.transport.redis.factory" class="Symfony\Component\Messenger\Bridge\Redis\Transport\RedisTransportFactory">
7575
<tag name="messenger.transport_factory" />
7676
</service>
7777

‎src/Symfony/Component/Messenger/Bridge/Amqp/.gitattributes

Copy file name to clipboard
+3Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
/Tests export-ignore
2+
/phpunit.xml.dist export-ignore
3+
/.gitignore export-ignore

‎src/Symfony/Component/Messenger/Bridge/Amqp/.gitignore

Copy file name to clipboard
+3Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
vendor/
2+
composer.lock
3+
phpunit.xml

‎src/Symfony/Component/Messenger/Bridge/Amqp/CHANGELOG.md

Copy file name to clipboard
+7Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
CHANGELOG
2+
=========
3+
4+
5.1.0
5+
-----
6+
7+
* Introduced the AMQP bridge.

‎src/Symfony/Component/Messenger/Bridge/Amqp/LICENSE

Copy file name to clipboard
+19Lines changed: 19 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,19 @@
1+
Copyright (c) 2018-2020 Fabien Potencier
2+
3+
Permission is hereby granted, free of charge, to any person obtaining a copy
4+
of this software and associated documentation files (the "Software"), to deal
5+
in the Software without restriction, including without limitation the rights
6+
to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
7+
copies of the Software, and to permit persons to whom the Software is furnished
8+
to do so, subject to the following conditions:
9+
10+
The above copyright notice and this permission notice shall be included in all
11+
copies or substantial portions of the Software.
12+
13+
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
14+
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
15+
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
16+
AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
17+
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
18+
OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
19+
THE SOFTWARE.

‎src/Symfony/Component/Messenger/Bridge/Amqp/README.md

Copy file name to clipboard
+12Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,12 @@
1+
AMQP Messenger
2+
==============
3+
4+
Provides AMQP integration for Symfony Messenger.
5+
6+
Resources
7+
---------
8+
9+
* [Contributing](https://symfony.com/doc/current/contributing/index.html)
10+
* [Report issues](https://github.com/symfony/symfony/issues) and
11+
[send Pull Requests](https://github.com/symfony/symfony/pulls)
12+
in the [main Symfony repository](https://github.com/symfony/symfony)

‎src/Symfony/Component/Messenger/Bridge/Amqp/Tests/Fixtures/DummyMessage.php

Copy file name to clipboard
+18Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,18 @@
1+
<?php
2+
3+
namespace Symfony\Component\Messenger\Bridge\Amqp\Tests\Fixtures;
4+
5+
class DummyMessage
6+
{
7+
private $message;
8+
9+
public function __construct(string $message)
10+
{
11+
$this->message = $message;
12+
}
13+
14+
public function getMessage(): string
15+
{
16+
return $this->message;
17+
}
18+
}

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

Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Bridge/Amqp/Tests/Fixtures/long_receiver.php
+3-3Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
$componentRoot = $_SERVER['COMPONENT_ROOT'];
44

55
if (!is_file($autoload = $componentRoot.'/vendor/autoload.php')) {
6-
$autoload = $componentRoot.'/../../../../vendor/autoload.php';
6+
$autoload = $componentRoot.'/../../../../../../vendor/autoload.php';
77
}
88

99
if (!file_exists($autoload)) {
@@ -17,8 +17,8 @@
1717
use Symfony\Component\Messenger\EventListener\DispatchPcntlSignalListener;
1818
use Symfony\Component\Messenger\EventListener\StopWorkerOnSigtermSignalListener;
1919
use Symfony\Component\Messenger\MessageBusInterface;
20-
use Symfony\Component\Messenger\Transport\AmqpExt\AmqpReceiver;
21-
use Symfony\Component\Messenger\Transport\AmqpExt\Connection;
20+
use Symfony\Component\Messenger\Bridge\Amqp\Transport\AmqpReceiver;
21+
use Symfony\Component\Messenger\Bridge\Amqp\Transport\Connection;
2222
use Symfony\Component\Messenger\Transport\Serialization\Serializer;
2323
use Symfony\Component\Messenger\Worker;
2424
use Symfony\Component\Serializer as SerializerComponent;

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

Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Bridge/Amqp/Tests/Transport/AmqpExtIntegrationTest.php
+11-11Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -9,18 +9,18 @@
99
* file that was distributed with this source code.
1010
*/
1111

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

1414
use PHPUnit\Framework\TestCase;
15+
use Symfony\Component\Messenger\Bridge\Amqp\Tests\Fixtures\DummyMessage;
16+
use Symfony\Component\Messenger\Bridge\Amqp\Transport\AmqpReceivedStamp;
17+
use Symfony\Component\Messenger\Bridge\Amqp\Transport\AmqpReceiver;
18+
use Symfony\Component\Messenger\Bridge\Amqp\Transport\AmqpSender;
19+
use Symfony\Component\Messenger\Bridge\Amqp\Transport\AmqpStamp;
20+
use Symfony\Component\Messenger\Bridge\Amqp\Transport\Connection;
1521
use Symfony\Component\Messenger\Envelope;
1622
use Symfony\Component\Messenger\Stamp\DelayStamp;
1723
use Symfony\Component\Messenger\Stamp\RedeliveryStamp;
18-
use Symfony\Component\Messenger\Tests\Fixtures\DummyMessage;
19-
use Symfony\Component\Messenger\Transport\AmqpExt\AmqpReceivedStamp;
20-
use Symfony\Component\Messenger\Transport\AmqpExt\AmqpReceiver;
21-
use Symfony\Component\Messenger\Transport\AmqpExt\AmqpSender;
22-
use Symfony\Component\Messenger\Transport\AmqpExt\AmqpStamp;
23-
use Symfony\Component\Messenger\Transport\AmqpExt\Connection;
2424
use Symfony\Component\Messenger\Transport\Receiver\ReceiverInterface;
2525
use Symfony\Component\Messenger\Transport\Serialization\Serializer;
2626
use Symfony\Component\Messenger\Transport\Serialization\SerializerInterface;
@@ -148,8 +148,8 @@ public function testItReceivesSignals()
148148

149149
$amqpReadTimeout = 30;
150150
$dsn = getenv('MESSENGER_AMQP_DSN').'?read_timeout='.$amqpReadTimeout;
151-
$process = new PhpProcess(file_get_contents(__DIR__.'/Fixtures/long_receiver.php'), null, [
152-
'COMPONENT_ROOT' => __DIR__.'/../../../',
151+
$process = new PhpProcess(file_get_contents(__DIR__.'/../Fixtures/long_receiver.php'), null, [
152+
'COMPONENT_ROOT' => __DIR__.'/../../',
153153
'DSN' => $dsn,
154154
]);
155155

@@ -171,9 +171,9 @@ public function testItReceivesSignals()
171171
$this->assertFalse($process->isRunning());
172172
$this->assertLessThan($amqpReadTimeout, microtime(true) - $signalTime);
173173
$this->assertSame($expectedOutput.<<<'TXT'
174-
Get envelope with message: Symfony\Component\Messenger\Tests\Fixtures\DummyMessage
174+
Get envelope with message: Symfony\Component\Messenger\Bridge\Amqp\Tests\Fixtures\DummyMessage
175175
with stamps: [
176-
"Symfony\\Component\\Messenger\\Transport\\AmqpExt\\AmqpReceivedStamp",
176+
"Symfony\\Component\\Messenger\\Bridge\\Amqp\\Transport\\AmqpReceivedStamp",
177177
"Symfony\\Component\\Messenger\\Stamp\\ReceivedStamp",
178178
"Symfony\\Component\\Messenger\\Stamp\\ConsumedByWorkerStamp"
179179
]

‎src/Symfony/Component/Messenger/Tests/Transport/AmqpExt/AmqpReceivedStampTest.php renamed to ‎src/Symfony/Component/Messenger/Bridge/Amqp/Tests/Transport/AmqpReceivedStampTest.php

Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Bridge/Amqp/Tests/Transport/AmqpReceivedStampTest.php
+2-2Lines changed: 2 additions & 2 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\Transport\AmqpExt;
12+
namespace Symfony\Component\Messenger\Bridge\Amqp\Tests\Transport;
1313

1414
use PHPUnit\Framework\TestCase;
15-
use Symfony\Component\Messenger\Transport\AmqpExt\AmqpReceivedStamp;
15+
use Symfony\Component\Messenger\Bridge\Amqp\Transport\AmqpReceivedStamp;
1616

1717
/**
1818
* @requires extension amqp

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

Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Bridge/Amqp/Tests/Transport/AmqpReceiverTest.php
+5-5Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -9,14 +9,14 @@
99
* file that was distributed with this source code.
1010
*/
1111

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

1414
use PHPUnit\Framework\TestCase;
15+
use Symfony\Component\Messenger\Bridge\Amqp\Tests\Fixtures\DummyMessage;
16+
use Symfony\Component\Messenger\Bridge\Amqp\Transport\AmqpReceivedStamp;
17+
use Symfony\Component\Messenger\Bridge\Amqp\Transport\AmqpReceiver;
18+
use Symfony\Component\Messenger\Bridge\Amqp\Transport\Connection;
1519
use Symfony\Component\Messenger\Envelope;
16-
use Symfony\Component\Messenger\Tests\Fixtures\DummyMessage;
17-
use Symfony\Component\Messenger\Transport\AmqpExt\AmqpReceivedStamp;
18-
use Symfony\Component\Messenger\Transport\AmqpExt\AmqpReceiver;
19-
use Symfony\Component\Messenger\Transport\AmqpExt\Connection;
2020
use Symfony\Component\Messenger\Transport\Serialization\Serializer;
2121
use Symfony\Component\Messenger\Transport\Serialization\SerializerInterface;
2222
use Symfony\Component\Serializer as SerializerComponent;

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

Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Bridge/Amqp/Tests/Transport/AmqpSenderTest.php
+5-5Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -9,14 +9,14 @@
99
* file that was distributed with this source code.
1010
*/
1111

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

1414
use PHPUnit\Framework\TestCase;
15+
use Symfony\Component\Messenger\Bridge\Amqp\Tests\Fixtures\DummyMessage;
16+
use Symfony\Component\Messenger\Bridge\Amqp\Transport\AmqpSender;
17+
use Symfony\Component\Messenger\Bridge\Amqp\Transport\AmqpStamp;
18+
use Symfony\Component\Messenger\Bridge\Amqp\Transport\Connection;
1519
use Symfony\Component\Messenger\Envelope;
16-
use Symfony\Component\Messenger\Tests\Fixtures\DummyMessage;
17-
use Symfony\Component\Messenger\Transport\AmqpExt\AmqpSender;
18-
use Symfony\Component\Messenger\Transport\AmqpExt\AmqpStamp;
19-
use Symfony\Component\Messenger\Transport\AmqpExt\Connection;
2020
use Symfony\Component\Messenger\Transport\Serialization\SerializerInterface;
2121

2222
/**

‎src/Symfony/Component/Messenger/Tests/Transport/AmqpExt/AmqpStampTest.php renamed to ‎src/Symfony/Component/Messenger/Bridge/Amqp/Tests/Transport/AmqpStampTest.php

Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Bridge/Amqp/Tests/Transport/AmqpStampTest.php
+2-2Lines changed: 2 additions & 2 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\Transport\AmqpExt;
12+
namespace Symfony\Component\Messenger\Bridge\Amqp\Tests\Transport;
1313

1414
use PHPUnit\Framework\TestCase;
15-
use Symfony\Component\Messenger\Transport\AmqpExt\AmqpStamp;
15+
use Symfony\Component\Messenger\Bridge\Amqp\Transport\AmqpStamp;
1616

1717
/**
1818
* @requires extension amqp

‎src/Symfony/Component/Messenger/Tests/Transport/AmqpExt/AmqpTransportFactoryTest.php renamed to ‎src/Symfony/Component/Messenger/Bridge/Amqp/Tests/Transport/AmqpTransportFactoryTest.php

Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Bridge/Amqp/Tests/Transport/AmqpTransportFactoryTest.php
+4-4Lines 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\Transport\AmqpExt;
12+
namespace Symfony\Component\Messenger\Bridge\Amqp\Tests\Transport;
1313

1414
use PHPUnit\Framework\TestCase;
15-
use Symfony\Component\Messenger\Transport\AmqpExt\AmqpTransport;
16-
use Symfony\Component\Messenger\Transport\AmqpExt\AmqpTransportFactory;
17-
use Symfony\Component\Messenger\Transport\AmqpExt\Connection;
15+
use Symfony\Component\Messenger\Bridge\Amqp\Transport\AmqpTransport;
16+
use Symfony\Component\Messenger\Bridge\Amqp\Transport\AmqpTransportFactory;
17+
use Symfony\Component\Messenger\Bridge\Amqp\Transport\Connection;
1818
use Symfony\Component\Messenger\Transport\Serialization\SerializerInterface;
1919

2020
class AmqpTransportFactoryTest extends TestCase

‎src/Symfony/Component/Messenger/Tests/Transport/AmqpExt/AmqpTransportTest.php renamed to ‎src/Symfony/Component/Messenger/Bridge/Amqp/Tests/Transport/AmqpTransportTest.php

Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Bridge/Amqp/Tests/Transport/AmqpTransportTest.php
+4-4Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -9,13 +9,13 @@
99
* file that was distributed with this source code.
1010
*/
1111

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

1414
use PHPUnit\Framework\TestCase;
15+
use Symfony\Component\Messenger\Bridge\Amqp\Tests\Fixtures\DummyMessage;
16+
use Symfony\Component\Messenger\Bridge\Amqp\Transport\AmqpTransport;
17+
use Symfony\Component\Messenger\Bridge\Amqp\Transport\Connection;
1518
use Symfony\Component\Messenger\Envelope;
16-
use Symfony\Component\Messenger\Tests\Fixtures\DummyMessage;
17-
use Symfony\Component\Messenger\Transport\AmqpExt\AmqpTransport;
18-
use Symfony\Component\Messenger\Transport\AmqpExt\Connection;
1919
use Symfony\Component\Messenger\Transport\Serialization\SerializerInterface;
2020
use Symfony\Component\Messenger\Transport\TransportInterface;
2121

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

Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Bridge/Amqp/Tests/Transport/ConnectionTest.php
+5-5Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -9,14 +9,14 @@
99
* file that was distributed with this source code.
1010
*/
1111

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

1414
use PHPUnit\Framework\TestCase;
15+
use Symfony\Component\Messenger\Bridge\Amqp\Tests\Fixtures\DummyMessage;
16+
use Symfony\Component\Messenger\Bridge\Amqp\Transport\AmqpFactory;
17+
use Symfony\Component\Messenger\Bridge\Amqp\Transport\AmqpStamp;
18+
use Symfony\Component\Messenger\Bridge\Amqp\Transport\Connection;
1519
use Symfony\Component\Messenger\Exception\InvalidArgumentException;
16-
use Symfony\Component\Messenger\Tests\Fixtures\DummyMessage;
17-
use Symfony\Component\Messenger\Transport\AmqpExt\AmqpFactory;
18-
use Symfony\Component\Messenger\Transport\AmqpExt\AmqpStamp;
19-
use Symfony\Component\Messenger\Transport\AmqpExt\Connection;
2020

2121
/**
2222
* @requires extension amqp

‎src/Symfony/Component/Messenger/Bridge/Amqp/Transport/AmqpFactory.php

Copy file name to clipboard
+36Lines changed: 36 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,36 @@
1+
<?php
2+
3+
/*
4+
* This file is part of the Symfony package.
5+
*
6+
* (c) Fabien Potencier <fabien@symfony.com>
7+
*
8+
* For the full copyright and license information, please view the LICENSE
9+
* file that was distributed with this source code.
10+
*/
11+
12+
namespace Symfony\Component\Messenger\Bridge\Amqp\Transport;
13+
14+
class AmqpFactory
15+
{
16+
public function createConnection(array $credentials): \AMQPConnection
17+
{
18+
return new \AMQPConnection($credentials);
19+
}
20+
21+
public function createChannel(\AMQPConnection $connection): \AMQPChannel
22+
{
23+
return new \AMQPChannel($connection);
24+
}
25+
26+
public function createQueue(\AMQPChannel $channel): \AMQPQueue
27+
{
28+
return new \AMQPQueue($channel);
29+
}
30+
31+
public function createExchange(\AMQPChannel $channel): \AMQPExchange
32+
{
33+
return new \AMQPExchange($channel);
34+
}
35+
}
36+
class_alias(AmqpFactory::class, \Symfony\Component\Messenger\Transport\AmqpExt\AmqpFactory::class);

0 commit comments

Comments
0 (0)
Morty Proxy This is a proxified and sanitized view of the page, visit original site.