diogo/symfony
Archived
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[Messenger] changed exceptions to use component's one

Browse Source
This commit is contained in:
Fabien Potencier 2018-09-08 08:36:06 +02:00
parent f2f4cd82c3
commit 4e0e5e5fdb
4 changed files with 12 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/Symfony/Component/Messenger/Handler/ChainHandler.php
View File

@ -11,6 +11,8 @@
namespace Symfony\Component\Messenger\Handler; namespace Symfony\Component\Messenger\Handler;
use Symfony\Component\Messenger\Exception\InvalidArgumentException;
/** /**
* Represents a collection of message handlers. * Represents a collection of message handlers.
* *
@ -29,7 +31,7 @@ class ChainHandler
public function __construct(array $handlers) public function __construct(array $handlers)
{ {
if (empty($handlers)) { if (empty($handlers)) {
throw new \InvalidArgumentException('A collection of message handlers requires at least one handler.'); throw new InvalidArgumentException('A collection of message handlers requires at least one handler.');
} }
$this->handlers = $handlers; $this->handlers = $handlers;

4
src/Symfony/Component/Messenger/Transport/AmqpExt/Connection.php
View File

@ -11,6 +11,8 @@
namespace Symfony\Component\Messenger\Transport\AmqpExt; namespace Symfony\Component\Messenger\Transport\AmqpExt;
use Symfony\Component\Messenger\Exception\InvalidArgumentException;
/** /**
* An AMQP connection. * An AMQP connection.
* *
@ -51,7 +53,7 @@ class Connection
public static function fromDsn(string $dsn, array $options = array(), bool $debug = false, AmqpFactory $amqpFactory = null): self public static function fromDsn(string $dsn, array $options = array(), bool $debug = false, AmqpFactory $amqpFactory = null): self
{ {
if (false === $parsedUrl = parse_url($dsn)) { if (false === $parsedUrl = parse_url($dsn)) {
throw new \InvalidArgumentException(sprintf('The given AMQP DSN "%s" is invalid.', $dsn)); throw new InvalidArgumentException(sprintf('The given AMQP DSN "%s" is invalid.', $dsn));
} }
$pathParts = isset($parsedUrl['path']) ? explode('/', trim($parsedUrl['path'], '/')) : array(); $pathParts = isset($parsedUrl['path']) ? explode('/', trim($parsedUrl['path'], '/')) : array();

5
src/Symfony/Component/Messenger/Transport/Serialization/Serializer.php
View File

@ -12,6 +12,7 @@
namespace Symfony\Component\Messenger\Transport\Serialization; namespace Symfony\Component\Messenger\Transport\Serialization;
use Symfony\Component\Messenger\Envelope; use Symfony\Component\Messenger\Envelope;
use Symfony\Component\Messenger\Exception\InvalidArgumentException;
use Symfony\Component\Serializer\SerializerInterface; use Symfony\Component\Serializer\SerializerInterface;
/** /**
@ -36,11 +37,11 @@ class Serializer implements DecoderInterface, EncoderInterface
public function decode(array $encodedEnvelope): Envelope public function decode(array $encodedEnvelope): Envelope
{ {
if (empty($encodedEnvelope['body']) || empty($encodedEnvelope['headers'])) { if (empty($encodedEnvelope['body']) || empty($encodedEnvelope['headers'])) {
throw new \InvalidArgumentException('Encoded envelope should have at least a `body` and some `headers`.'); throw new InvalidArgumentException('Encoded envelope should have at least a "body" and some "headers".');
} }
if (empty($encodedEnvelope['headers']['type'])) { if (empty($encodedEnvelope['headers']['type'])) {
throw new \InvalidArgumentException('Encoded envelope does not have a `type` header.'); throw new InvalidArgumentException('Encoded envelope does not have a "type" header.');
} }
$envelopeItems = $this->decodeEnvelopeItems($encodedEnvelope); $envelopeItems = $this->decodeEnvelopeItems($encodedEnvelope);

4
src/Symfony/Component/Messenger/Transport/TransportFactory.php
View File

@ -11,6 +11,8 @@
namespace Symfony\Component\Messenger\Transport; namespace Symfony\Component\Messenger\Transport;
use Symfony\Component\Messenger\Exception\InvalidArgumentException;
/** /**
* @author Samuel Roze <samuel.roze@gmail.com> * @author Samuel Roze <samuel.roze@gmail.com>
*/ */
@ -34,7 +36,7 @@ class TransportFactory implements TransportFactoryInterface
} }
} }
throw new \InvalidArgumentException(sprintf('No transport supports the given DSN "%s".', $dsn)); throw new InvalidArgumentException(sprintf('No transport supports the given DSN "%s".', $dsn));
} }
public function supports(string $dsn, array $options): bool public function supports(string $dsn, array $options): bool