File tree Expand file tree Collapse file tree 3 files changed +20
-0
lines changed Expand file tree Collapse file tree 3 files changed +20
-0
lines changed Original file line number Diff line number Diff line change 1818use ReflectionClass ;
1919use VladimirYuldashev \LaravelQueueRabbitMQ \Queue \RabbitMQQueue ;
2020
21+ /**
22+ * RMQ connector.
23+ */
2124class RabbitMQConnector implements ConnectorInterface
2225{
2326 private const WORKER_DEFAULT = 'default ' ;
@@ -27,6 +30,9 @@ class RabbitMQConnector implements ConnectorInterface
2730 */
2831 private $ dispatcher ;
2932
33+ /**
34+ * @param Dispatcher $dispatcher
35+ */
3036 public function __construct (Dispatcher $ dispatcher )
3137 {
3238 $ this ->dispatcher = $ dispatcher ;
Original file line number Diff line number Diff line change 1313use Interop \Amqp \AmqpMessage ;
1414use VladimirYuldashev \LaravelQueueRabbitMQ \Queue \RabbitMQQueue ;
1515
16+ /**
17+ * RMQ queue job.
18+ */
1619class RabbitMQJob extends Job implements JobContract
1720{
1821 use DetectsConcurrencyErrors;
@@ -31,6 +34,12 @@ class RabbitMQJob extends Job implements JobContract
3134 /** @var AmqpMessage */
3235 protected $ message ;
3336
37+ /**
38+ * @param Container $container
39+ * @param RabbitMQQueue $connection
40+ * @param AmqpConsumer $consumer
41+ * @param AmqpMessage $message
42+ */
3443 public function __construct (
3544 Container $ container ,
3645 RabbitMQQueue $ connection ,
Original file line number Diff line number Diff line change 1818use Throwable ;
1919use VladimirYuldashev \LaravelQueueRabbitMQ \Queue \Jobs \RabbitMQJob ;
2020
21+ /**
22+ * RMQ queue consumer.
23+ */
2124class RabbitMQQueue extends Queue implements QueueContract
2225{
2326 private const SLEEP_ON_ERROR = 5 ;
@@ -398,6 +401,8 @@ protected function getRandomId(): string
398401 * @param Throwable $e
399402 *
400403 * @throws RuntimeException
404+ *
405+ * @return void
401406 */
402407 protected function reportConnectionError (string $ action , Throwable $ e ): void
403408 {
You can’t perform that action at this time.
0 commit comments