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 fe75920

Browse filesBrowse files
GaryPEGEOTsroze
GaryPEGEOT
authored and
sroze
committed
Add a "null://" transport
1 parent 8977f74 commit fe75920
Copy full SHA for fe75920

File tree

6 files changed

+258
-0
lines changed
Filter options

6 files changed

+258
-0
lines changed

‎src/Symfony/Bundle/FrameworkBundle/CHANGELOG.md

Copy file name to clipboardExpand all lines: src/Symfony/Bundle/FrameworkBundle/CHANGELOG.md
+1Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,7 @@ CHANGELOG
2929
* Added support for PHP files with translations in translation commands.
3030
* Added support for boolean container parameters within routes.
3131
* Added the `messenger:setup-transports` command to setup messenger transports
32+
* Added a `InMemoryTransport` to Messenger. Use it with a DSN starting with `in-memory://`.
3233

3334
4.2.0
3435
-----

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

Copy file name to clipboardExpand all lines: src/Symfony/Bundle/FrameworkBundle/Resources/config/messenger.xml
+4Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -70,6 +70,10 @@
7070
<tag name="messenger.transport_factory" />
7171
</service>
7272

73+
<service id="messenger.transport.in_memory.factory" class="Symfony\Component\Messenger\Transport\InMemoryTransportFactory">
74+
<tag name="messenger.transport_factory" />
75+
</service>
76+
7377
<!-- retry -->
7478
<service id="messenger.retry_strategy_locator">
7579
<tag name="container.service_locator" />

‎src/Symfony/Component/Messenger/Tests/Transport/InMemoryTransportFactoryTest.php

Copy file name to clipboard
+62Lines changed: 62 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,62 @@
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\Tests\Transport;
13+
14+
use PHPUnit\Framework\TestCase;
15+
use Symfony\Component\Messenger\Transport\InMemoryTransport;
16+
use Symfony\Component\Messenger\Transport\InMemoryTransportFactory;
17+
use Symfony\Component\Messenger\Transport\Serialization\SerializerInterface;
18+
19+
/**
20+
* @internal
21+
*
22+
* @author Gary PEGEOT <garypegeot@gmail.com>
23+
*/
24+
class InMemoryTransportFactoryTest extends TestCase
25+
{
26+
/**
27+
* @var InMemoryTransportFactory
28+
*/
29+
private $factory;
30+
31+
protected function setUp()
32+
{
33+
$this->factory = new InMemoryTransportFactory();
34+
}
35+
36+
/**
37+
* @param string $dsn
38+
* @param bool $expected
39+
*
40+
* @dataProvider provideDSN
41+
*/
42+
public function testSupports(string $dsn, bool $expected = true)
43+
{
44+
$this->assertSame($expected, $this->factory->supports($dsn, []), 'InMemoryTransportFactory::supports returned unexpected result.');
45+
}
46+
47+
public function testCreateTransport()
48+
{
49+
/** @var SerializerInterface $serializer */
50+
$serializer = $this->createMock(SerializerInterface::class);
51+
52+
$this->assertInstanceOf(InMemoryTransport::class, $this->factory->createTransport('in-memory://', [], $serializer));
53+
}
54+
55+
public function provideDSN(): array
56+
{
57+
return [
58+
'Supported' => ['in-memory://foo'],
59+
'Unsupported' => ['amqp://bar', false],
60+
];
61+
}
62+
}

‎src/Symfony/Component/Messenger/Tests/Transport/InMemoryTransportTest.php

Copy file name to clipboard
+69Lines changed: 69 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,69 @@
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\Tests\Transport;
13+
14+
use PHPUnit\Framework\TestCase;
15+
use Symfony\Component\Messenger\Envelope;
16+
use Symfony\Component\Messenger\Transport\InMemoryTransport;
17+
18+
/**
19+
* @internal
20+
*
21+
* @author Gary PEGEOT <garypegeot@gmail.com>
22+
*/
23+
class InMemoryTransportTest extends TestCase
24+
{
25+
/**
26+
* @var InMemoryTransport
27+
*/
28+
private $transport;
29+
30+
protected function setUp()
31+
{
32+
$this->transport = new InMemoryTransport();
33+
}
34+
35+
public function testSend()
36+
{
37+
$envelope = new Envelope(new \stdClass());
38+
$this->transport->send($envelope);
39+
$this->assertSame([$envelope], $this->transport->get());
40+
}
41+
42+
public function testAck()
43+
{
44+
$envelope = new Envelope(new \stdClass());
45+
$this->transport->ack($envelope);
46+
$this->assertSame([$envelope], $this->transport->getAcknowledged());
47+
}
48+
49+
public function testReject()
50+
{
51+
$envelope = new Envelope(new \stdClass());
52+
$this->transport->reject($envelope);
53+
$this->assertSame([$envelope], $this->transport->getRejected());
54+
}
55+
56+
public function testReset()
57+
{
58+
$envelope = new Envelope(new \stdClass());
59+
$this->transport->send($envelope);
60+
$this->transport->ack($envelope);
61+
$this->transport->reject($envelope);
62+
63+
$this->transport->reset();
64+
65+
$this->assertEmpty($this->transport->get(), 'Should be empty after reset');
66+
$this->assertEmpty($this->transport->getAcknowledged(), 'Should be empty after reset');
67+
$this->assertEmpty($this->transport->getRejected(), 'Should be empty after reset');
68+
}
69+
}

‎src/Symfony/Component/Messenger/Transport/InMemoryTransport.php

Copy file name to clipboard
+95Lines changed: 95 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,95 @@
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\Transport;
13+
14+
use Symfony\Component\Messenger\Envelope;
15+
use Symfony\Contracts\Service\ResetInterface;
16+
17+
/**
18+
* Transport that stay in memory. Useful for testing purpose.
19+
*
20+
* @author Gary PEGEOT <garypegeot@gmail.com>
21+
*
22+
* @experimental in 4.3
23+
*/
24+
class InMemoryTransport implements TransportInterface, ResetInterface
25+
{
26+
/**
27+
* @var Envelope[]
28+
*/
29+
private $sent = [];
30+
31+
/**
32+
* @var Envelope[]
33+
*/
34+
private $acknowledged = [];
35+
36+
/**
37+
* @var Envelope[]
38+
*/
39+
private $rejected = [];
40+
41+
/**
42+
* {@inheritdoc}
43+
*/
44+
public function get(): iterable
45+
{
46+
return $this->sent;
47+
}
48+
49+
/**
50+
* {@inheritdoc}
51+
*/
52+
public function ack(Envelope $envelope): void
53+
{
54+
$this->acknowledged[] = $envelope;
55+
}
56+
57+
/**
58+
* {@inheritdoc}
59+
*/
60+
public function reject(Envelope $envelope): void
61+
{
62+
$this->rejected[] = $envelope;
63+
}
64+
65+
/**
66+
* {@inheritdoc}
67+
*/
68+
public function send(Envelope $envelope): Envelope
69+
{
70+
$this->sent[] = $envelope;
71+
72+
return $envelope;
73+
}
74+
75+
public function reset()
76+
{
77+
$this->sent = $this->rejected = $this->acknowledged = [];
78+
}
79+
80+
/**
81+
* @return Envelope[]
82+
*/
83+
public function getAcknowledged(): array
84+
{
85+
return $this->acknowledged;
86+
}
87+
88+
/**
89+
* @return Envelope[]
90+
*/
91+
public function getRejected(): array
92+
{
93+
return $this->rejected;
94+
}
95+
}

‎src/Symfony/Component/Messenger/Transport/InMemoryTransportFactory.php

Copy file name to clipboard
+27Lines changed: 27 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,27 @@
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\Transport;
13+
14+
use Symfony\Component\Messenger\Transport\Serialization\SerializerInterface;
15+
16+
class InMemoryTransportFactory implements TransportFactoryInterface
17+
{
18+
public function createTransport(string $dsn, array $options, SerializerInterface $serializer): TransportInterface
19+
{
20+
return new InMemoryTransport();
21+
}
22+
23+
public function supports(string $dsn, array $options): bool
24+
{
25+
return 0 === strpos($dsn, 'in-memory://');
26+
}
27+
}

0 commit comments

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