[Messenger] make all stamps final and mark stamp not meant to be sent

This commit is contained in:
Tobias Schultze 2019-06-18 04:12:48 +01:00
parent 561ad17d16
commit 013904b081
10 changed files with 22 additions and 20 deletions

View File

@ -18,7 +18,7 @@ namespace Symfony\Component\Messenger\Stamp;
*
* @author Ryan Weaver <ryan@symfonycasts.com>
*/
class BusNameStamp implements StampInterface
final class BusNameStamp implements StampInterface
{
private $busName;

View File

@ -16,7 +16,7 @@ namespace Symfony\Component\Messenger\Stamp;
*
* @experimental in 4.3
*/
class DelayStamp implements StampInterface
final class DelayStamp implements StampInterface
{
private $delay;

View File

@ -20,6 +20,6 @@ namespace Symfony\Component\Messenger\Stamp;
*
* @author Tobias Nyholm <tobias.nyholm@gmail.com>
*/
class DispatchAfterCurrentBusStamp implements StampInterface
final class DispatchAfterCurrentBusStamp implements NonSendableStampInterface
{
}

View File

@ -17,7 +17,11 @@ use Symfony\Component\Messenger\Handler\HandlerDescriptor;
* Stamp identifying a message handled by the `HandleMessageMiddleware` middleware
* and storing the handler returned value.
*
* This is used by synchronous command buses expecting a return value and the retry logic
* to only execute handlers that didn't succeed.
*
* @see \Symfony\Component\Messenger\Middleware\HandleMessageMiddleware
* @see \Symfony\Component\Messenger\HandleTrait
*
* @author Maxime Steinhausser <maxime.steinhausser@gmail.com>
*

View File

@ -25,7 +25,7 @@ use Symfony\Component\Messenger\Middleware\SendMessageMiddleware;
*
* @experimental in 4.3
*/
final class ReceivedStamp implements StampInterface
final class ReceivedStamp implements NonSendableStampInterface
{
private $transportName;

View File

@ -19,7 +19,7 @@ use Symfony\Component\Messenger\Envelope;
*
* @experimental in 4.3
*/
class RedeliveryStamp implements StampInterface
final class RedeliveryStamp implements StampInterface
{
private $retryCount;
private $senderClassOrAlias;

View File

@ -20,7 +20,7 @@ namespace Symfony\Component\Messenger\Stamp;
*
* @experimental in 4.3
*/
final class SentStamp implements StampInterface
final class SentStamp implements NonSendableStampInterface
{
private $senderClass;
private $senderAlias;

View File

@ -18,7 +18,7 @@ namespace Symfony\Component\Messenger\Stamp;
*
* @experimental in 4.3
*/
class SentToFailureTransportStamp implements StampInterface
final class SentToFailureTransportStamp implements StampInterface
{
private $originalReceiverName;

View File

@ -18,7 +18,7 @@ namespace Symfony\Component\Messenger\Stamp;
*
* @experimental in 4.3
*/
class TransportMessageIdStamp implements StampInterface
final class TransportMessageIdStamp implements StampInterface
{
private $id;

View File

@ -55,9 +55,8 @@ class EnvelopeTest extends TestCase
{
$envelope = new Envelope(new DummyMessage('dummy'), [
new ReceivedStamp('transport1'),
new DelayStamp(5000),
new DummyExtendsDelayStamp(5000),
new DummyImplementsFooBarStampInterface(),
new DummyExtendsFooBarStamp(),
new DummyImplementsFooBarStamp(),
]);
$envelope2 = $envelope->withoutStampsOfType(DummyNothingImplementsMeStampInterface::class);
@ -66,12 +65,11 @@ class EnvelopeTest extends TestCase
$envelope3 = $envelope2->withoutStampsOfType(ReceivedStamp::class);
$this->assertEmpty($envelope3->all(ReceivedStamp::class));
$envelope4 = $envelope3->withoutStampsOfType(DelayStamp::class);
$this->assertEmpty($envelope4->all(DelayStamp::class));
$this->assertEmpty($envelope4->all(DummyExtendsDelayStamp::class));
$envelope4 = $envelope3->withoutStampsOfType(DummyImplementsFooBarStamp::class);
$this->assertEmpty($envelope4->all(DummyImplementsFooBarStamp::class));
$this->assertEmpty($envelope4->all(DummyExtendsFooBarStamp::class));
$envelope5 = $envelope4->withoutStampsOfType(DummyFooBarStampInterface::class);
$this->assertEmpty($envelope5->all(DummyImplementsFooBarStampInterface::class));
$envelope5 = $envelope3->withoutStampsOfType(DummyFooBarStampInterface::class);
$this->assertEmpty($envelope5->all());
}
@ -118,15 +116,15 @@ class EnvelopeTest extends TestCase
}
}
class DummyExtendsDelayStamp extends DelayStamp
{
}
interface DummyFooBarStampInterface extends StampInterface
{
}
interface DummyNothingImplementsMeStampInterface extends StampInterface
{
}
class DummyImplementsFooBarStampInterface implements DummyFooBarStampInterface
class DummyImplementsFooBarStamp implements DummyFooBarStampInterface
{
}
class DummyExtendsFooBarStamp extends DummyImplementsFooBarStamp
{
}