AmazonSqsDriver::wait() - Code Metrics - Inspection of "Merge pull request #22 from tomaj/sqs" - tomaj/hermes - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( d32768...8979ed )

by Tomas

created 2016-09-05 15:55 UTC

AmazonSqsDriver::wait() B

↳ Parent: AmazonSqsDriver

Complexity

Conditions	5
Paths	5

Size

Total Lines	26
Code Lines	15

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	1

Metric	Value
c	1
b	0
f	1
dl	0
loc	26
rs	8.439
cc	5
eloc	15
nc	5
nop	1

<?php

namespace Tomaj\Hermes\Driver;

use Closure;
use Exception;
use Tomaj\Hermes\MessageInterface;
use Tomaj\Hermes\MessageSerializer;
use Aws\Sqs\SqsClient;

class AmazonSqsDriver implements DriverInterface
{
    use SerializerAwareTrait;

    /**
     * @var SqsClient
     */
    private $client;

    /**
     * @var string
     */
    private $queueName;

    /**
     * string
     */
    private $queueUrl;

    /**
     * integer
     */
    private $sleepInterval = 0;
    
    /**
     * Create new Amazon SQS driver.
     *
     * You have to create aws client instnace and provide it to this driver.
     * You can use service builder or factory method.
     *
     * <code>
     *  use Aws\Sqs\SqsClient;
     *
     *  $client = SqsClient::factory(array(
     *    'profile' => '<profile in your aws credentials file>',
     *    'region'  => '<region name>'
     *  ));
     * </code>
     * 
     * or
     *
     * <code>
     * use Aws\Common\Aws;
     *
     * // Create a service builder using a configuration file
     * $aws = Aws::factory('/path/to/my_config.json');
     *
     * // Get the client from the builder by namespace
     * $client = $aws->get('Sqs');
     * </code>
     *
     * More examples see: https://docs.aws.amazon.com/aws-sdk-php/v2/guide/service-sqs.html
     *
     *
     * @see examples/sqs folder
     *
     * @param AMQPChannel   $client
     * @param string        $queueName
     * @param array         $queueAttributes
     */
    public function __construct(SqsClient $client, $queueName, $queueAttributes = [])
    {
        $this->client = $client;
        $this->queueName = $queueName;
        $this->serializer = new MessageSerializer();

        $result = $client->createQueue([
            'QueueName'  => $queueName,
            'Attributes' => $queueAttributes,
        ]);
        $this->queueUrl = $result->get('QueueUrl');
    }

    /**
     * {@inheritdoc}
     */
    public function send(MessageInterface $message)
    {
        $this->client->sendMessage([
            'QueueUrl'    => $this->queueUrl,
            'MessageBody' => $this->serializer->serialize($message),
        ]);
    }

    /**
     * {@inheritdoc}
     */
    public function wait(Closure $callback)
    {
        while (true) {
            $result = $this->client->receiveMessage(array(
                'QueueUrl' => $this->queueUrl,
                'WaitTimeSeconds' => 20,
            ));

            $messages = $result['Messages'];

            if ($messages) {
                foreach ($messages as $message) {
                    $hermesMessage = $this->serializer->unserialize($message['Body']);
                    $callback($hermesMessage);
                    $result = $this->client->deleteMessage(array(
$myVar = 'Value';
$higher = false;

if (rand(1, 6) > 3) {
    $higher = true;
} else {
    $higher = false;
}
                        'QueueUrl' => $this->queueUrl,
                        'ReceiptHandle' => $message['ReceiptHandle'],
                    ));
                }
            }

            if ($this->sleepInterval) {
                sleep($this->sleepInterval);
            }
        }
    }
}


1			<?php
2
3			namespace Tomaj\Hermes\Driver;
4
5			use Closure;
6			use Exception;
7			use Tomaj\Hermes\MessageInterface;
8			use Tomaj\Hermes\MessageSerializer;
9			use Aws\Sqs\SqsClient;
10
11			class AmazonSqsDriver implements DriverInterface
12			{
13			use SerializerAwareTrait;
14
15			/**
16			* @var SqsClient
17			*/
18			private $client;
19
20			/**
21			* @var string
22			*/
23			private $queueName;
24
25			/**
26			* string
27			*/
28			private $queueUrl;
29
30			/**
31			* integer
32			*/
33			private $sleepInterval = 0;
34
35			/**
36			* Create new Amazon SQS driver.
37			*
38			* You have to create aws client instnace and provide it to this driver.
39			* You can use service builder or factory method.
40			*
41			* <code>
42			* use Aws\Sqs\SqsClient;
43			*
44			* $client = SqsClient::factory(array(
45			* 'profile' => '<profile in your aws credentials file>',
46			* 'region' => '<region name>'
47			* ));
48			* </code>
49			*
50			* or
51			*
52			* <code>
53			* use Aws\Common\Aws;
54			*
55			* // Create a service builder using a configuration file
56			* $aws = Aws::factory('/path/to/my_config.json');
57			*
58			* // Get the client from the builder by namespace
59			* $client = $aws->get('Sqs');
60			* </code>
61			*
62			* More examples see: https://docs.aws.amazon.com/aws-sdk-php/v2/guide/service-sqs.html
63			*
64			*
65			* @see examples/sqs folder
66			*
67			* @param AMQPChannel $client
68			* @param string $queueName
69			* @param array $queueAttributes
70			*/
71			public function __construct(SqsClient $client, $queueName, $queueAttributes = [])
72			{
73			$this->client = $client;
74			$this->queueName = $queueName;
75			$this->serializer = new MessageSerializer();
76
77			$result = $client->createQueue([
78			'QueueName' => $queueName,
79			'Attributes' => $queueAttributes,
80			]);
81			$this->queueUrl = $result->get('QueueUrl');
82			}
83
84			/**
85			* {@inheritdoc}
86			*/
87			public function send(MessageInterface $message)
88			{
89			$this->client->sendMessage([
90			'QueueUrl' => $this->queueUrl,
91			'MessageBody' => $this->serializer->serialize($message),
92			]);
93			}
94
95			/**
96			* {@inheritdoc}
97			*/
98			public function wait(Closure $callback)
99			{
100			while (true) {
101			$result = $this->client->receiveMessage(array(
102			'QueueUrl' => $this->queueUrl,
103			'WaitTimeSeconds' => 20,
104			));
105
106			$messages = $result['Messages'];
107
108			if ($messages) {
109			foreach ($messages as $message) {
110			$hermesMessage = $this->serializer->unserialize($message['Body']);
111			$callback($hermesMessage);
112			$result = $this->client->deleteMessage(array(
			0 ignored issues – show Unused Code introduced 2016-09-05 16:12 UTC by Report Bug Copy Issue Report `$result` is not used, you could remove the assignment. This check looks for variable assignements that are either overwritten by other assignments or where the variable is not used subsequently. $myVar = 'Value'; $higher = false; if (rand(1, 6) > 3) { $higher = true; } else { $higher = false; } Both the `$myVar` assignment in line 1 and the `$higher` assignment in line 2 are dead. The first because `$myVar` is never used and the second because `$higher` is always overwritten for every possible time line. Loading history...
113			'QueueUrl' => $this->queueUrl,
114			'ReceiptHandle' => $message['ReceiptHandle'],
115			));
116			}
117			}
118
119			if ($this->sleepInterval) {
120			sleep($this->sleepInterval);
121			}
122			}
123			}
124			}
125

tomaj / hermes

Push — master ( d32768...8979ed )

AmazonSqsDriver::wait() B

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like