fix: to squash

BedrockStreaming · Jul 28, 2023 · 2d938a1 · 2d938a1
1 parent f635d19
commit 2d938a1
Show file tree

Hide file tree

Showing 4 changed files with 10 additions and 9 deletions.
diff --git a/src/AmqpBundle/Amqp/AbstractAmqp.php b/src/AmqpBundle/Amqp/AbstractAmqp.php
@@ -23,9 +23,9 @@ abstract class AbstractAmqp
      * @param string $command   The command name
      * @param array  $arguments Args of the command
      * @param mixed  $return    Return value of the command
-     * @param int $time      Exec time
+     * @param float $time      Exec time
      */
-    protected function notifyEvent(string $command, array $arguments, $return, int $time = 0)
+    protected function notifyEvent(string $command, array $arguments, $return, float $time = 0)
     {
         if ($this->eventDispatcher) {
             $event = new $this->eventClass();

diff --git a/src/AmqpBundle/Amqp/Consumer.php b/src/AmqpBundle/Amqp/Consumer.php
@@ -34,15 +34,16 @@ public function __construct(\AMQPQueue $queue, array $queueOptions)
     public function getMessage(int $flags = AMQP_AUTOACK): ?\AMQPEnvelope
     {
         $envelope = $this->call($this->queue, 'get', [$flags]);
+        $envelope = $envelope === false ? null : $envelope;
 
         if ($this->eventDispatcher) {
             $preRetrieveEvent = new PreRetrieveEvent($envelope);
-            $this->eventDispatcher->dispatch( $preRetrieveEvent, PreRetrieveEvent::NAME);
+            $this->eventDispatcher->dispatch($preRetrieveEvent, PreRetrieveEvent::NAME);
 
             return $preRetrieveEvent->getEnvelope();
         }
 
-        return $envelope === false ? null : $envelope;
+        return $envelope;
     }
 
     /**

diff --git a/src/AmqpBundle/Event/Command.php b/src/AmqpBundle/Event/Command.php
@@ -9,7 +9,7 @@
  */
 class Command extends Event implements DispatcherInterface
 {
-    protected int $executionTime = 0;
+    protected float $executionTime = 0.0;
     protected string $command;
     protected array $arguments;
 

diff --git a/src/AmqpBundle/Event/PreRetrieveEvent.php b/src/AmqpBundle/Event/PreRetrieveEvent.php
@@ -12,19 +12,19 @@ class PreRetrieveEvent extends Event
 {
     const NAME = 'amqp.pre_retrieve';
 
-    private AMQPEnvelope $envelope;
+    private ?AMQPEnvelope $envelope;
 
-    public function __construct(AMQPEnvelope $envelope)
+    public function __construct(?AMQPEnvelope $envelope)
     {
         $this->envelope = $envelope;
     }
 
-    public function getEnvelope(): AMQPEnvelope
+    public function getEnvelope(): ?AMQPEnvelope
     {
         return $this->envelope;
     }
 
-    public function setEnvelope(AMQPEnvelope $envelope)
+    public function setEnvelope(?AMQPEnvelope $envelope)
     {
         $this->envelope = $envelope;
     }