@@ -42,7 +42,7 @@ class RabbitMQQueue extends Queue implements QueueContract
4242
4343 /**
4444 * @param AMQPStreamConnection $amqpConnection
45- * @param array $config
45+ * @param array $config
4646 */
4747 public function __construct (AMQPStreamConnection $ amqpConnection , $ config )
4848 {
@@ -59,7 +59,8 @@ public function __construct(AMQPStreamConnection $amqpConnection, $config)
5959 /**
6060 * Get the size of the queue.
6161 *
62- * @param string $queue
62+ * @param string $queue
63+ *
6364 * @return int
6465 */
6566 public function size ($ queue = null )
@@ -71,7 +72,7 @@ public function size($queue = null)
7172 * Push a new job onto the queue.
7273 *
7374 * @param string $job
74- * @param mixed $data
75+ * @param mixed $data
7576 * @param string $queue
7677 *
7778 * @return bool
@@ -86,7 +87,7 @@ public function push($job, $data = '', $queue = null)
8687 *
8788 * @param string $payload
8889 * @param string $queue
89- * @param array $options
90+ * @param array $options
9091 *
9192 * @return mixed
9293 */
@@ -101,7 +102,7 @@ public function pushRaw($payload, $queue = null, array $options = [])
101102 }
102103
103104 $ headers = [
104- 'Content-Type ' => 'application/json ' ,
105+ 'Content-Type ' => 'application/json ' ,
105106 'delivery_mode ' => 2 ,
106107 ];
107108
@@ -125,9 +126,9 @@ public function pushRaw($payload, $queue = null, array $options = [])
125126 * Push a new job onto the queue after a delay.
126127 *
127128 * @param \DateTime|int $delay
128- * @param string $job
129- * @param mixed $data
130- * @param string $queue
129+ * @param string $job
130+ * @param mixed $data
131+ * @param string $queue
131132 *
132133 * @return mixed
133134 */
@@ -219,7 +220,7 @@ private function declareQueue($name)
219220 }
220221
221222 /**
222- * @param string $destination
223+ * @param string $destination
223224 * @param DateTime|int $delay
224225 *
225226 * @return string
@@ -229,7 +230,7 @@ private function declareDelayedQueue($destination, $delay)
229230 $ delay = $ this ->secondsUntil ($ delay );
230231 $ destination = $ this ->getQueueName ($ destination );
231232 $ destinationExchange = $ this ->configExchange ['name ' ] ?: $ destination ;
232- $ name = $ this ->getQueueName ($ destination ) . '_deferred_ ' . $ delay ;
233+ $ name = $ this ->getQueueName ($ destination ). '_deferred_ ' . $ delay ;
233234 $ exchange = $ this ->configExchange ['name ' ] ?: $ destination ;
234235
235236 // declare exchange
@@ -253,9 +254,9 @@ private function declareDelayedQueue($destination, $delay)
253254 $ this ->configQueue ['auto_delete ' ],
254255 false ,
255256 new AMQPTable ([
256- 'x-dead-letter-exchange ' => $ destinationExchange ,
257+ 'x-dead-letter-exchange ' => $ destinationExchange ,
257258 'x-dead-letter-routing-key ' => $ destination ,
258- 'x-message-ttl ' => $ delay * 1000 ,
259+ 'x-message-ttl ' => $ delay * 1000 ,
259260 ])
260261 );
261262 }
0 commit comments