diff --git a/pkg/amqp-bunny/AmqpProducer.php b/pkg/amqp-bunny/AmqpProducer.php index 9a19cd970..9d701bbe2 100644 --- a/pkg/amqp-bunny/AmqpProducer.php +++ b/pkg/amqp-bunny/AmqpProducer.php @@ -92,6 +92,10 @@ public function send(PsrDestination $destination, PsrMessage $message) */ public function setDeliveryDelay($deliveryDelay) { + if (null === $deliveryDelay) { + return; + } + throw DeliveryDelayNotSupportedException::providerDoestNotSupportIt(); } diff --git a/pkg/amqp-ext/AmqpProducer.php b/pkg/amqp-ext/AmqpProducer.php index 4ed1845c9..04d96bbb5 100644 --- a/pkg/amqp-ext/AmqpProducer.php +++ b/pkg/amqp-ext/AmqpProducer.php @@ -99,6 +99,10 @@ public function send(PsrDestination $destination, PsrMessage $message) */ public function setDeliveryDelay($deliveryDelay) { + if (null === $deliveryDelay) { + return; + } + throw DeliveryDelayNotSupportedException::providerDoestNotSupportIt(); } diff --git a/pkg/amqp-lib/AmqpProducer.php b/pkg/amqp-lib/AmqpProducer.php index c5d8c0927..c31b4a23b 100644 --- a/pkg/amqp-lib/AmqpProducer.php +++ b/pkg/amqp-lib/AmqpProducer.php @@ -94,6 +94,10 @@ public function send(PsrDestination $destination, PsrMessage $message) */ public function setDeliveryDelay($deliveryDelay) { + if (null === $deliveryDelay) { + return; + } + throw DeliveryDelayNotSupportedException::providerDoestNotSupportIt(); } diff --git a/pkg/dbal/DbalProducer.php b/pkg/dbal/DbalProducer.php index 99657041c..4d125bb10 100644 --- a/pkg/dbal/DbalProducer.php +++ b/pkg/dbal/DbalProducer.php @@ -91,6 +91,10 @@ public function send(PsrDestination $destination, PsrMessage $message) */ public function setDeliveryDelay($deliveryDelay) { + if (null === $deliveryDelay) { + return; + } + throw new \LogicException('Not implemented'); } @@ -107,6 +111,10 @@ public function getDeliveryDelay() */ public function setPriority($priority) { + if (null === $priority) { + return; + } + throw new \LogicException('Not implemented'); } @@ -123,6 +131,10 @@ public function getPriority() */ public function setTimeToLive($timeToLive) { + if (null === $timeToLive) { + return; + } + throw new \LogicException('Not implemented'); } diff --git a/pkg/fs/FsProducer.php b/pkg/fs/FsProducer.php index 5ab27db22..a8dbac925 100644 --- a/pkg/fs/FsProducer.php +++ b/pkg/fs/FsProducer.php @@ -73,6 +73,10 @@ public function send(PsrDestination $destination, PsrMessage $message) */ public function setDeliveryDelay($deliveryDelay) { + if (null === $deliveryDelay) { + return; + } + throw DeliveryDelayNotSupportedException::providerDoestNotSupportIt(); } @@ -89,6 +93,10 @@ public function getDeliveryDelay() */ public function setPriority($priority) { + if (null === $priority) { + return; + } + throw PriorityNotSupportedException::providerDoestNotSupportIt(); } diff --git a/pkg/gearman/GearmanProducer.php b/pkg/gearman/GearmanProducer.php index a891ecd43..73a2c073b 100644 --- a/pkg/gearman/GearmanProducer.php +++ b/pkg/gearman/GearmanProducer.php @@ -47,6 +47,10 @@ public function send(PsrDestination $destination, PsrMessage $message) */ public function setDeliveryDelay($deliveryDelay) { + if (null === $deliveryDelay) { + return; + } + throw new \LogicException('Not implemented'); } @@ -63,6 +67,10 @@ public function getDeliveryDelay() */ public function setPriority($priority) { + if (null === $priority) { + return; + } + throw new \LogicException('Not implemented'); } @@ -79,6 +87,10 @@ public function getPriority() */ public function setTimeToLive($timeToLive) { + if (null === $timeToLive) { + return; + } + throw new \LogicException('Not implemented'); } diff --git a/pkg/pheanstalk/PheanstalkProducer.php b/pkg/pheanstalk/PheanstalkProducer.php index d9fe8912d..08255e170 100644 --- a/pkg/pheanstalk/PheanstalkProducer.php +++ b/pkg/pheanstalk/PheanstalkProducer.php @@ -57,6 +57,10 @@ public function send(PsrDestination $destination, PsrMessage $message) */ public function setDeliveryDelay($deliveryDelay) { + if (null === $deliveryDelay) { + return; + } + throw new \LogicException('Not implemented'); } @@ -73,6 +77,10 @@ public function getDeliveryDelay() */ public function setPriority($priority) { + if (null === $priority) { + return; + } + throw new \LogicException('Not implemented'); } @@ -89,6 +97,10 @@ public function getPriority() */ public function setTimeToLive($timeToLive) { + if (null === $timeToLive) { + return; + } + throw new \LogicException('Not implemented'); } diff --git a/pkg/rdkafka/RdKafkaProducer.php b/pkg/rdkafka/RdKafkaProducer.php index 780f72646..ffad80075 100644 --- a/pkg/rdkafka/RdKafkaProducer.php +++ b/pkg/rdkafka/RdKafkaProducer.php @@ -48,6 +48,10 @@ public function send(PsrDestination $destination, PsrMessage $message) */ public function setDeliveryDelay($deliveryDelay) { + if (null === $deliveryDelay) { + return; + } + throw new \LogicException('Not implemented'); } @@ -64,6 +68,10 @@ public function getDeliveryDelay() */ public function setPriority($priority) { + if (null === $priority) { + return; + } + throw new \LogicException('Not implemented'); } @@ -80,6 +88,10 @@ public function getPriority() */ public function setTimeToLive($timeToLive) { + if (null === $timeToLive) { + return; + } + throw new \LogicException('Not implemented'); } diff --git a/pkg/redis/RedisProducer.php b/pkg/redis/RedisProducer.php index 1860288d0..e34506b3a 100644 --- a/pkg/redis/RedisProducer.php +++ b/pkg/redis/RedisProducer.php @@ -42,6 +42,10 @@ public function send(PsrDestination $destination, PsrMessage $message) */ public function setDeliveryDelay($deliveryDelay) { + if (null === $deliveryDelay) { + return; + } + throw new \LogicException('Not implemented'); } @@ -58,6 +62,10 @@ public function getDeliveryDelay() */ public function setPriority($priority) { + if (null === $priority) { + return; + } + throw new \LogicException('Not implemented'); } @@ -74,6 +82,10 @@ public function getPriority() */ public function setTimeToLive($timeToLive) { + if (null === $timeToLive) { + return; + } + throw new \LogicException('Not implemented'); } diff --git a/pkg/sqs/SqsProducer.php b/pkg/sqs/SqsProducer.php index ad334e100..3acdce608 100644 --- a/pkg/sqs/SqsProducer.php +++ b/pkg/sqs/SqsProducer.php @@ -108,6 +108,10 @@ public function getDeliveryDelay() */ public function setPriority($priority) { + if (null === $priority) { + return; + } + throw PriorityNotSupportedException::providerDoestNotSupportIt(); } @@ -124,6 +128,10 @@ public function getPriority() */ public function setTimeToLive($timeToLive) { + if (null === $timeToLive) { + return; + } + throw TimeToLiveNotSupportedException::providerDoestNotSupportIt(); } diff --git a/pkg/stomp/StompProducer.php b/pkg/stomp/StompProducer.php index e5206419c..8e386fc3b 100644 --- a/pkg/stomp/StompProducer.php +++ b/pkg/stomp/StompProducer.php @@ -50,6 +50,10 @@ public function send(PsrDestination $destination, PsrMessage $message) */ public function setDeliveryDelay($deliveryDelay) { + if (null === $deliveryDelay) { + return; + } + throw new \LogicException('Not implemented'); } @@ -66,6 +70,10 @@ public function getDeliveryDelay() */ public function setPriority($priority) { + if (null === $priority) { + return; + } + throw new \LogicException('Not implemented'); } @@ -82,6 +90,10 @@ public function getPriority() */ public function setTimeToLive($timeToLive) { + if (null === $timeToLive) { + return; + } + throw new \LogicException('Not implemented'); }