nokitakaze / php-queue

src/AbstractQueueTransport.php

Doc Comments +1 added lines, -1 removed lines

@@ -83,7 +83,7 @@
         }
 
         /**
-         * @param double|integer $wait_time
+         * @param integer $wait_time
          *
          * @throws QueueException
          */

src/Queue.php

Doc Comments +1 added lines, -1 removed lines

@@ -28,7 +28,7 @@
         /**
          * SmartQueue constructor.
          *
-         * @param GeneralQueueConstructionSettings|object $settings
+         * @param GeneralQueueConstructionSettings $settings
          *
          * @throws QueueException
          */

src/QueueTransport.php

Doc Comments +3 added lines, -2 removed lines

@@ -34,7 +34,7 @@ 
         function push($stream);
 
         /**
-         * @param double|integer $wait_time
+         * @param integer $wait_time
          *
          * @return iMessage|object|null
          */
@@ -66,7 +66,7 @@ 
         static function get_real_key_for_message($message);
 
         /**
-         * @param double|integer $wait_time
+         * @param integer $wait_time
          *
          * @throws QueueException
          * @return void
@@ -75,6 +75,7 @@ 
 
         /**
          * @param callable $closure
+         * @return void
          */
         function set_callback_closure($closure);
 

src/FileDBQueueTransport.php

Doc Comments +2 added lines, -2 removed lines

@@ -125,7 +125,7 @@ 
         /**
          * Блокируем index mutex
          *
-         * @param double|integer $time
+         * @param integer $time
          *
          * @return boolean
          * @throws \NokitaKaze\Mutex\MutexException
@@ -523,7 +523,7 @@ 
         }
 
         /**
-         * @param double|integer $wait_time
+         * @param integer $wait_time
          *
          * @return iMessage|object|null
          * @throws \NokitaKaze\Mutex\MutexException

src/SmallFilesQueueTransport.php

Doc Comments +2 added lines, -2 removed lines

@@ -97,7 +97,7 @@ 
         }
 
         /**
-         * @param double|integer $wait_time
+         * @param integer $wait_time
          *
          * @return iMessage|object|null
          * @throws QueueException
@@ -134,7 +134,7 @@ 
         }
 
         /**
-         * @param double|integer $wait_time
+         * @param integer $wait_time
          *
          * @return iMessage|object|null
          */

src/QueueFactory.php

Doc Comments +1 added lines, -1 removed lines

@@ -63,7 +63,7 @@
         /**
          * @param GeneralQueueConstructionSettings $settings
          *
-         * @return Queue[]
+         * @return SmallFilesQueueConstructionSettingsForGeneral[]
          */
         protected static function get_scenario_write_small_files($settings) {
             /**