8000 Move the adapter to the `AmqpExt` namespace instead of `PhpAmqp` · symfony/symfony@5a90272 · GitHub
[go: up one dir, main page]
Skip to content
Sign in

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 5a90272

Browse files
srozesroze
committed
Move the adapter to the AmqpExt namespace instead of PhpAmqp 
1 parent c4980b6 commit 5a90272

File tree

12 files changed

+28
-28
lines changed

12 files changed

+28
-28
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,7 @@
7878
<argument type="tagged" tag="messenger.adapter_factory" />
7979
</service>
8080

81-
<service id="messenger.adapter.amqp.factory" class="Symfony\Component\Messenger\Adapter\PhpAmqp\AmqpAdapterFactory">
81+
<service id="messenger.adapter.amqp.factory" class="Symfony\Component\Messenger\Adapter\AmqpExt\AmqpAdapterFactory">
8282
<argument type="service" id="messenger.transport.default_encoder" />
8383
<argument type="service" id="messenger.transport.default_decoder" />
8484
<argument>%kernel.debug%</argument>

‎src/Symfony/Component/Messenger/Adapter/PhpAmqp/AmqpAdapterFactory.php renamed to ‎src/Symfony/Component/Messenger/Adapter/AmqpExt/AmqpAdapterFactory.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\PhpAmqp;
12+
namespace Symfony\Component\Messenger\Adapter\AmqpExt;
1313

1414
use Symfony\Component\Messenger\Adapter\Factory\AdapterFactoryInterface;
1515
use Symfony\Component\Messenger\Transport\ReceiverInterface;

‎src/Symfony/Component/Messenger/Adapter/PhpAmqp/AmqpFactory.php renamed to ‎src/Symfony/Component/Messenger/Adapter/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\PhpAmqp;
12+
namespace Symfony\Component\Messenger\Adapter\AmqpExt;
1313

1414
class AmqpFactory
1515
{

‎src/Symfony/Component/Messenger/Adapter/PhpAmqp/AmqpReceiver.php renamed to ‎src/Symfony/Component/Messenger/Adapter/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\PhpAmqp;
12+
namespace Symfony\Component\Messenger\Adapter\AmqpExt;
1313

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

‎src/Symfony/Component/Messenger/Adapter/PhpAmqp/AmqpSender.php renamed to ‎src/Symfony/Component/Messenger/Adapter/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\PhpAmqp;
12+
namespace Symfony\Component\Messenger\Adapter\AmqpExt;
1313

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

‎src/Symfony/Component/Messenger/Adapter/PhpAmqp/Connection.php renamed to ‎src/Symfony/Component/Messenger/Adapter/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\PhpAmqp;
12+
namespace Symfony\Component\Messenger\Adapter\AmqpExt;
1313

1414
/**
1515
* An AMQP connection.

‎src/Symfony/Component/Messenger/Adapter/PhpAmqp/Exception/RejectMessageExceptionInterface.php renamed to ‎src/Symfony/Component/Messenger/Adapter/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\PhpAmqp\Exception;
12+
namespace Symfony\Component\Messenger\Adapter\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/Tests/Adapter/PhpAmqp/PhpAmqpIntegrationTest.php renamed to ‎src/Symfony/Component/Messenger/Tests/Adapter/AmqpExt/AmqpExtIntegrationTest.php

Lines changed: 5 additions & 5 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\PhpAmqp;
12+
namespace Symfony\Component\Messenger\Tests\Adapter\AmqpExt;
1313

1414
use PHPUnit\Framework\TestCase;
15-
use Symfony\Component\Messenger\Adapter\PhpAmqp\AmqpReceiver;
16-
use Symfony\Component\Messenger\Adapter\PhpAmqp\AmqpSender;
17-
use Symfony\Component\Messenger\Adapter\PhpAmqp\Connection;
15+
use Symfony\Component\Messenger\Adapter\AmqpExt\AmqpReceiver;
16+
use Symfony\Component\Messenger\Adapter\AmqpExt\AmqpSender;
17+
use Symfony\Component\Messenger\Adapter\AmqpExt\Connection;
1818
use Symfony\Component\Messenger\Tests\Fixtures\DummyMessage;
1919
use Symfony\Component\Messenger\Transport\Enhancers\MaximumCountReceiver;
2020
use Symfony\Component\Messenger\Transport\Serialization\Serializer;
@@ -27,7 +27,7 @@
2727
/**
2828
* @requires extension amqp
2929
*/
30-
class PhpAmqpIntegrationTest extends TestCase
30+
class AmqpExtIntegrationTest extends TestCase
3131
{
3232
protected function setUp()
3333
{

‎src/Symfony/Component/Messenger/Tests/Adapter/PhpAmqp/AmqpReceiverTest.php renamed to ‎src/Symfony/Component/Messenger/Tests/Adapter/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\PhpAmqp;
12+
namespace Symfony\Component\Messenger\Tests\Adapter\AmqpExt;
1313

1414
use PHPUnit\Framework\TestCase;
15-
use Symfony\Component\Messenger\Adapter\PhpAmqp\AmqpReceiver;
16-
use Symfony\Component\Messenger\Adapter\PhpAmqp\Connection;
17-
use Symfony\Component\Messenger\Adapter\PhpAmqp\Exception\RejectMessageExceptionInterface;
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;
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\PhpAmqp\InterruptException
54+
* @expectedException \Symfony\Component\Messenger\Tests\Adapter\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\PhpAmqp\WillNeverWorkException
80+
* @expectedException \Symfony\Component\Messenger\Tests\Adapter\AmqpExt\WillNeverWorkException
8181
*/
8282
public function testItRejectsTheMessageIfTheExceptionIsARejectMessageExceptionInterface()
8383
{

‎src/Symfony/Component/Messenger/Tests/Adapter/PhpAmqp/AmqpSenderTest.php renamed to ‎src/Symfony/Component/Messenger/Tests/Adapter/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\PhpAmqp;
12+
namespace Symfony\Component\Messenger\Tests\Adapter\AmqpExt;
1313

14-
use Symfony\Component\Messenger\Adapter\PhpAmqp\AmqpSender;
15-
use Symfony\Component\Messenger\Adapter\PhpAmqp\Connection;
14+
use Symfony\Component\Messenger\Adapter\AmqpExt\AmqpSender;
15+
use Symfony\Component\Messenger\Adapter\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/PhpAmqp/ConnectionTest.php renamed to ‎src/Symfony/Component/Messenger/Tests/Adapter/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\PhpAmqp;
12+
namespace Symfony\Component\Messenger\Tests\Adapter\AmqpExt;
1313

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

1818
/**
1919
* @requires extension amqp

‎src/Symfony/Component/Messenger/Tests/Adapter/PhpAmqp/Fixtures/long_receiver.php renamed to ‎src/Symfony/Component/Messenger/Tests/Adapter/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\PhpAmqp\AmqpReceiver;
16-
use Symfony\Component\Messenger\Adapter\PhpAmqp\AmqpSender;
17-
use Symfony\Component\Messenger\Adapter\PhpAmqp\Connection;
15+
use Symfony\Component\Messenger\Adapter\AmqpExt\AmqpReceiver;
16+
use Symfony\Component\Messenger\Adapter\AmqpExt\AmqpSender;
17+
use Symfony\Component\Messenger\Adapter\AmqpExt\Connection;
1818
use Symfony\Component\Messenger\MessageBusInterface;
1919
use Symfony\Component\Messenger\Transport\Serialization\Serializer;
2020
use Symfony\Component\Messenger\Worker;

0 commit comments

Comments
 (0)
0