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/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
          */
@@ -511,7 +511,7 @@ 
         }
 
         /**
-         * @param double|integer $wait_time
+         * @param integer $wait_time
          *
          * @return iMessage|object|null
          */

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
          */

Unused Use Statements -2 removed lines

@@ -2,8 +2,6 @@
 
     namespace NokitaKaze\Queue;
 
-    use NokitaKaze\RandomString\RandomString;
-
     class Queue extends AbstractQueueTransport {
         const ProducerThreadCount = 5;
         const DefaultDBFileCount = 10;

src/QueueFactory.php

Doc Comments +1 added lines, -1 removed lines

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

src/QueueTransport.php

Doc Comments +7 added lines, -2 removed lines

@@ -11,6 +11,7 @@ 
          * @param integer     $sort
          *
          * @throws QueueException
+         * @return void
          */
         function produce_message($data, $name = null, $sort = 5);
 
@@ -27,11 +28,12 @@ 
          * @param iMessage[]|iMessage|object[]|object $stream
          *
          * @throws QueueException
+         * @return void
          */
         function push($stream);
 
         /**
-         * @param double|integer $wait_time
+         * @param integer $wait_time
          *
          * @return iMessage|object|null
          */
@@ -63,14 +65,16 @@ 
         static function get_real_key_for_message($message);
 
         /**
-         * @param double|integer $wait_time
+         * @param integer $wait_time
          *
          * @throws QueueException
+         * @return void
          */
         function listen($wait_time = -1);
 
         /**
          * @param callable $closure
+         * @return void
          */
         function set_callback_closure($closure);
 
@@ -88,6 +92,7 @@ 
 
         /**
          * Очищаем список полученных ключей, чтобы была возможность получить их заново
+         * @return void
          */
         function clear_consumed_keys();
 

src/SmallFilesQueueTransport.php

Doc Comments +3 added lines, -3 removed lines

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