Queue::__resp2meta__() - Code Metrics - freyo/laravel-queue-cmq - Measure and Improve Code Quality continuously with Scrutinizer

Queue::resp2meta() F
last analyzed 2021-08-19 05:17 UTC

↳ Parent: Queue

Complexity

Conditions	15
Paths	16384

Size

Total Lines	43
Code Lines	28

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	240

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
cc	15
eloc	28
c	1
b	0
f	0
nc	16384
nop	2
dl	0
loc	43
ccs	0
cts	43
cp	0
crap	240
rs	1.7499

How to fix Complexity

<?php

namespace Freyo\LaravelQueueCMQ\Queue\Driver;

class Queue
{
    private $queue_name;
    private $cmq_client;
    private $encoding;

    public function __construct($queue_name, CMQClient $cmq_client, $encoding = false)
    {
        $this->queue_name = $queue_name;
        $this->cmq_client = $cmq_client;
        $this->encoding = $encoding;
    }

    /**
     * @return mixed
     */
    public function getQueueName()
    {
        return $this->queue_name;
    }

    /* 设置是否对消息体进行base64编码

        @type encoding: bool
        @param encoding: 是否对消息体进行base64编码

    */
    public function set_encoding($encoding)
    {
        $this->encoding = $encoding;
    }

    /* 创建队列

        @type queue_meta: QueueMeta object
        @param queue_meta: QueueMeta对象，设置队列的属性

    */
    public function create($queue_meta)
    {
        $params = [
            'queueName'           => $this->queue_name,
            'pollingWaitSeconds'  => $queue_meta->pollingWaitSeconds,
            'visibilityTimeout'   => $queue_meta->visibilityTimeout,
            'maxMsgSize'          => $queue_meta->maxMsgSize,
            'msgRetentionSeconds' => $queue_meta->msgRetentionSeconds,
            'rewindSeconds'       => $queue_meta->rewindSeconds,
        ];
        if ($queue_meta->maxMsgHeapNum > 0) {
            $params['maxMsgHeapNum'] = $queue_meta->maxMsgHeapNum;
        }
        $this->cmq_client->create_queue($params);
    }

    /* 获取队列属性

        @rtype: QueueMeta object
        @return 队列的属性

    */
    public function get_attributes()
    {
        $params = [
            'queueName' => $this->queue_name,
        ];
        $resp = $this->cmq_client->get_queue_attributes($params);
        $queue_meta = new QueueMeta();
        $queue_meta->queueName = $this->queue_name;
        $this->__resp2meta__($queue_meta, $resp);

        return $queue_meta;
    }

    /* 设置队列属性

        @type queue_meta: QueueMeta object
        @param queue_meta: QueueMeta对象，设置队列的属性

    */

    protected function __resp2meta__($queue_meta, $resp)
    {
        if (isset($resp['queueName'])) {
            $queue_meta->queueName = $resp['queueName'];
        }
        if (isset($resp['maxMsgHeapNum'])) {
            $queue_meta->maxMsgHeapNum = $resp['maxMsgHeapNum'];
        }
        if (isset($resp['pollingWaitSeconds'])) {
            $queue_meta->pollingWaitSeconds = $resp['pollingWaitSeconds'];
        }
        if (isset($resp['visibilityTimeout'])) {
            $queue_meta->visibilityTimeout = $resp['visibilityTimeout'];
        }
        if (isset($resp['maxMsgSize'])) {
            $queue_meta->maxMsgSize = $resp['maxMsgSize'];
        }
        if (isset($resp['msgRetentionSeconds'])) {
            $queue_meta->msgRetentionSeconds = $resp['msgRetentionSeconds'];
        }
        if (isset($resp['createTime'])) {
            $queue_meta->createTime = $resp['createTime'];
        }
        if (isset($resp['lastModifyTime'])) {
            $queue_meta->lastModifyTime = $resp['lastModifyTime'];
        }
        if (isset($resp['activeMsgNum'])) {
            $queue_meta->activeMsgNum = $resp['activeMsgNum'];
        }
        if (isset($resp['rewindSeconds'])) {
            $queue_meta->rewindSeconds = $resp['rewindSeconds'];
        }
        if (isset($resp['inactiveMsgNum'])) {
            $queue_meta->inactiveMsgNum = $resp['inactiveMsgNum'];
        }
        if (isset($resp['rewindmsgNum'])) {
            $queue_meta->rewindmsgNum = $resp['rewindmsgNum'];
        }
        if (isset($resp['minMsgTime'])) {
            $queue_meta->minMsgTime = $resp['minMsgTime'];
        }
        if (isset($resp['delayMsgNum'])) {
            $queue_meta->delayMsgNum = $resp['delayMsgNum'];
        }
    }

    public function set_attributes($queue_meta)
    {
        $params = [
            'queueName'           => $this->queue_name,
            'pollingWaitSeconds'  => $queue_meta->pollingWaitSeconds,
            'visibilityTimeout'   => $queue_meta->visibilityTimeout,
            'maxMsgSize'          => $queue_meta->maxMsgSize,
            'msgRetentionSeconds' => $queue_meta->msgRetentionSeconds,
            'rewindSeconds'       => $queue_meta->rewindSeconds,
        ];
        if ($queue_meta->maxMsgHeapNum > 0) {
            $params['maxMsgHeapNum'] = $queue_meta->maxMsgHeapNum;
        }

        $this->cmq_client->set_queue_attributes($params);
    }

    /* 删除队列

    */

    public function rewindQueue($backTrackingTime)
    {
        $params = [
            'queueName'        => $this->queue_name,
            'startConsumeTime' => $backTrackingTime,
        ];
        $this->cmq_client->rewindQueue($params);
    }

    /* 发送消息

        @type message: Message object
        @param message: 发送的Message object


        @rtype: Message object
        @return 消息发送成功的返回属性，包含MessageId


    */

    public function delete()
    {
        $params = ['queueName' => $this->queue_name];
        $this->cmq_client->delete_queue($params);
    }

    /* 批量发送消息

       @type messages: list of Message object
       @param messages: 发送的Message object list


       @rtype: list of Message object
       @return 多条消息发送成功的返回属性，包含MessageId

    */

    public function send_message($message, $delayTime = 0)
    {
        if ($this->encoding) {
            $msgBody = base64_encode($message->msgBody);
        } else {
            $msgBody = $message->msgBody;
        }
        $params = [
            'queueName'    => $this->queue_name,
            'msgBody'      => $msgBody,
            'delaySeconds' => $delayTime,
        ];
        $msgId = $this->cmq_client->send_message($params);
        $retmsg = new Message();
        $retmsg->msgId = $msgId;

        return $retmsg;
    }

    /* 消费消息

        @type polling_wait_seconds: int
        @param polling_wait_seconds: 本次请求的长轮询时间，单位：秒


        @rtype: Message object
        @return Message object中包含基本属性、临时句柄
    */

    public function batch_send_message($messages, $delayTime = 0)
    {
        $params = [
            'queueName'    => $this->queue_name,
            'delaySeconds' => $delayTime,
        ];
        $n = 1;
        foreach ($messages as $message) {
            $key = 'msgBody.'.$n;
            if ($this->encoding) {
                $params[$key] = base64_encode($message->msgBody);
            } else {
                $params[$key] = $message->msgBody;
            }
            $n += 1;
        }
        $msgList = $this->cmq_client->batch_send_message($params);
        $retMessageList = [];
        foreach ($msgList as $msg) {
            $retmsg = new Message();
            $retmsg->msgId = $msg['msgId'];
            $retMessageList[] = $retmsg;
        }

        return $retMessageList;

    }

    /* 批量消费消息

        @type num_of_msg: int
        @param num_of_msg: 本次请求最多获取的消息条数


        @type polling_wait_seconds: int
        @param polling_wait_seconds: 本次请求的长轮询时间，单位：秒

        @rtype: list of Message object
        @return 多条消息的属性，包含消息的基本属性、临时句柄

    */

    public function receive_message($polling_wait_seconds = null)
    {
        $params = ['queueName' => $this->queue_name];
        if ($polling_wait_seconds !== null) {
            $params['UserpollingWaitSeconds'] = $polling_wait_seconds;
            $params['pollingWaitSeconds'] = $polling_wait_seconds;
        } else {
            $params['UserpollingWaitSeconds'] = 30;
        }
        $resp = $this->cmq_client->receive_message($params);
        $msg = new Message();
        if ($this->encoding) {
            $msg->msgBody = base64_decode($resp['msgBody']);
        } else {
            $msg->msgBody = $resp['msgBody'];
        }
        $msg->msgId = $resp['msgId'];
        $msg->receiptHandle = $resp['receiptHandle'];
        $msg->enqueueTime = $resp['enqueueTime'];
        $msg->nextVisibleTime = $resp['nextVisibleTime'];

        $msg->dequeueCount = $resp['dequeueCount'];

        $msg->firstDequeueTime = $resp['firstDequeueTime'];


        return $msg;
    }

    /* 删除消息

        @type receipt_handle: string
        @param receipt_handle: 最近一次操作该消息返回的临时句柄

    */

    public function batch_receive_message($num_of_msg, $polling_wait_seconds = null)
    {
        $params = ['queueName' => $this->queue_name, 'numOfMsg' => $num_of_msg];
        if ($polling_wait_seconds != null) {
            $params['UserpollingWaitSeconds'] = $polling_wait_seconds;
            $params['pollingWaitSeconds'] = $polling_wait_seconds;
        } else {
            $params['UserpollingWaitSeconds'] = 30;
        }
        $msgInfoList = $this->cmq_client->batch_receive_message($params);
        $retMessageList = [];
        foreach ($msgInfoList as $msg) {
            $retmsg = new Message();
            if ($this->encoding) {
                $retmsg->msgBody = base64_decode($msg['msgBody']);
            } else {
                $retmsg->msgBody = $msg['msgBody'];
            }
            $retmsg->msgId = $msg['msgId'];
            $retmsg->receiptHandle = $msg['receiptHandle'];
            $retmsg->enqueueTime = $msg['enqueueTime'];
            $retmsg->nextVisibleTime = $msg['nextVisibleTime'];

            $retmsg->dequeueCount = $msg['dequeueCount'];

            $retmsg->firstDequeueTime = $msg['firstDequeueTime'];

            $retMessageList[] = $retmsg;
        }

        return $retMessageList;
    }

    /* 批量删除消息

        @type receipt_handle_list: list
        @param receipt_handle_list: batch_receive_message返回的多条消息的临时句柄

    */

    public function delete_message($receipt_handle)
    {
        $params = ['queueName' => $this->queue_name, 'receiptHandle' => $receipt_handle];
        $this->cmq_client->delete_message($params);
    }

    public function batch_delete_message($receipt_handle_list)
    {
        $params = ['queueName' => $this->queue_name];
        $n = 1;
        foreach ($receipt_handle_list as $receipt_handle) {
            $key = 'receiptHandle.'.$n;
            $params[$key] = $receipt_handle;
            $n += 1;
        }
        $this->cmq_client->batch_delete_message($params);
    }
}


1			<?php
2
3			namespace Freyo\LaravelQueueCMQ\Queue\Driver;
4
5			class Queue
6			{
7			private $queue_name;
8			private $cmq_client;
9			private $encoding;
10
11			public function __construct($queue_name, CMQClient $cmq_client, $encoding = false)
12			{
13			$this->queue_name = $queue_name;
14			$this->cmq_client = $cmq_client;
15			$this->encoding = $encoding;
16			}
17
18			/**
19			* @return mixed
20			*/
21			public function getQueueName()
22			{
23			return $this->queue_name;
24			}
25
26			/* 设置是否对消息体进行base64编码
27
28			@type encoding: bool
29			@param encoding: 是否对消息体进行base64编码
			0 ignored issues – show Documentation Bug introduced 2018-07-12 05:51 UTC by Report Bug Copy Issue Report The doc comment `是否对消息体进行base64编码` at position `0` could not be parsed: Unknown type name '是否对消息体进行base64编码' at position 0 in 是否对消息体进行base64编码. Loading history...
30			*/
31			public function set_encoding($encoding)
32			{
33			$this->encoding = $encoding;
34			}
35
36			/* 创建队列
37
38			@type queue_meta: QueueMeta object
39			@param queue_meta: QueueMeta对象，设置队列的属性
			0 ignored issues – show Documentation Bug introduced 2018-07-12 05:51 UTC by Report Bug Copy Issue Report The doc comment `QueueMeta对象，设置队列的属性` at position `0` could not be parsed: Unknown type name 'QueueMeta对象，设置队列的属性' at position 0 in QueueMeta对象，设置队列的属性. Loading history...
40			*/
41			public function create($queue_meta)
42			{
43			$params = [
44			'queueName' => $this->queue_name,
45			'pollingWaitSeconds' => $queue_meta->pollingWaitSeconds,
46			'visibilityTimeout' => $queue_meta->visibilityTimeout,
47			'maxMsgSize' => $queue_meta->maxMsgSize,
48			'msgRetentionSeconds' => $queue_meta->msgRetentionSeconds,
49			'rewindSeconds' => $queue_meta->rewindSeconds,
50			];
51			if ($queue_meta->maxMsgHeapNum > 0) {
52			$params['maxMsgHeapNum'] = $queue_meta->maxMsgHeapNum;
53			}
54			$this->cmq_client->create_queue($params);
55			}
56
57			/* 获取队列属性
58
59			@rtype: QueueMeta object
60			@return 队列的属性
			0 ignored issues – show Documentation Bug introduced 2018-07-12 05:51 UTC by Report Bug Copy Issue Report The doc comment `队列的属性` at position `0` could not be parsed: Unknown type name '队列的属性' at position 0 in 队列的属性. Loading history...
61			*/
62			public function get_attributes()
63			{
64			$params = [
65			'queueName' => $this->queue_name,
66			];
67			$resp = $this->cmq_client->get_queue_attributes($params);
68			$queue_meta = new QueueMeta();
69			$queue_meta->queueName = $this->queue_name;
70			$this->__resp2meta__($queue_meta, $resp);
71
72			return $queue_meta;
73			}
74
75			/* 设置队列属性
76
77			@type queue_meta: QueueMeta object
78			@param queue_meta: QueueMeta对象，设置队列的属性
			0 ignored issues – show Documentation Bug introduced 2018-07-12 05:51 UTC by Report Bug Copy Issue Report The doc comment `QueueMeta对象，设置队列的属性` at position `0` could not be parsed: Unknown type name 'QueueMeta对象，设置队列的属性' at position 0 in QueueMeta对象，设置队列的属性. Loading history...
79			*/
80
81			protected function __resp2meta__($queue_meta, $resp)
82			{
83			if (isset($resp['queueName'])) {
84			$queue_meta->queueName = $resp['queueName'];
85			}
86			if (isset($resp['maxMsgHeapNum'])) {
87			$queue_meta->maxMsgHeapNum = $resp['maxMsgHeapNum'];
88			}
89			if (isset($resp['pollingWaitSeconds'])) {
90			$queue_meta->pollingWaitSeconds = $resp['pollingWaitSeconds'];
91			}
92			if (isset($resp['visibilityTimeout'])) {
93			$queue_meta->visibilityTimeout = $resp['visibilityTimeout'];
94			}
95			if (isset($resp['maxMsgSize'])) {
96			$queue_meta->maxMsgSize = $resp['maxMsgSize'];
97			}
98			if (isset($resp['msgRetentionSeconds'])) {
99			$queue_meta->msgRetentionSeconds = $resp['msgRetentionSeconds'];
100			}
101			if (isset($resp['createTime'])) {
102			$queue_meta->createTime = $resp['createTime'];
103			}
104			if (isset($resp['lastModifyTime'])) {
105			$queue_meta->lastModifyTime = $resp['lastModifyTime'];
106			}
107			if (isset($resp['activeMsgNum'])) {
108			$queue_meta->activeMsgNum = $resp['activeMsgNum'];
109			}
110			if (isset($resp['rewindSeconds'])) {
111			$queue_meta->rewindSeconds = $resp['rewindSeconds'];
112			}
113			if (isset($resp['inactiveMsgNum'])) {
114			$queue_meta->inactiveMsgNum = $resp['inactiveMsgNum'];
115			}
116			if (isset($resp['rewindmsgNum'])) {
117			$queue_meta->rewindmsgNum = $resp['rewindmsgNum'];
118			}
119			if (isset($resp['minMsgTime'])) {
120			$queue_meta->minMsgTime = $resp['minMsgTime'];
121			}
122			if (isset($resp['delayMsgNum'])) {
123			$queue_meta->delayMsgNum = $resp['delayMsgNum'];
124			}
125			}
126
127			public function set_attributes($queue_meta)
128			{
129			$params = [
130			'queueName' => $this->queue_name,
131			'pollingWaitSeconds' => $queue_meta->pollingWaitSeconds,
132			'visibilityTimeout' => $queue_meta->visibilityTimeout,
133			'maxMsgSize' => $queue_meta->maxMsgSize,
134			'msgRetentionSeconds' => $queue_meta->msgRetentionSeconds,
135			'rewindSeconds' => $queue_meta->rewindSeconds,
136			];
137			if ($queue_meta->maxMsgHeapNum > 0) {
138			$params['maxMsgHeapNum'] = $queue_meta->maxMsgHeapNum;
139			}
140
141			$this->cmq_client->set_queue_attributes($params);
142			}
143
144			/* 删除队列
145
146			*/
147
148			public function rewindQueue($backTrackingTime)
149			{
150			$params = [
151			'queueName' => $this->queue_name,
152			'startConsumeTime' => $backTrackingTime,
153			];
154			$this->cmq_client->rewindQueue($params);
155			}
156
157			/* 发送消息
158
159			@type message: Message object
160			@param message: 发送的Message object
			0 ignored issues – show Documentation Bug introduced 2018-07-12 05:51 UTC by Report Bug Copy Issue Report The doc comment `发送的Message` at position `0` could not be parsed: Unknown type name '发送的Message' at position 0 in 发送的Message. Loading history...
161
162			@rtype: Message object
163			@return 消息发送成功的返回属性，包含MessageId
			0 ignored issues – show Documentation Bug introduced 2018-07-12 05:51 UTC by Report Bug Copy Issue Report The doc comment `消息发送成功的返...` at position `0` could not be parsed: Unknown type name '消息发送成功的返回属性，包含MessageId' at position 0 in 消息发送成功的返回属性，包含MessageId. Loading history...
164
165			*/
166
167			public function delete()
168			{
169			$params = ['queueName' => $this->queue_name];
170			$this->cmq_client->delete_queue($params);
171			}
172
173			/* 批量发送消息
174
175			@type messages: list of Message object
176			@param messages: 发送的Message object list
			0 ignored issues – show Documentation Bug introduced 2018-07-12 05:51 UTC by Report Bug Copy Issue Report The doc comment `发送的Message` at position `0` could not be parsed: Unknown type name '发送的Message' at position 0 in 发送的Message. Loading history...
177
178			@rtype: list of Message object
179			@return 多条消息发送成功的返回属性，包含MessageId
			0 ignored issues – show Documentation Bug introduced 2018-07-12 05:51 UTC by Report Bug Copy Issue Report The doc comment `多条消息发送成功...` at position `0` could not be parsed: Unknown type name '多条消息发送成功的返回属性，包含MessageId' at position 0 in 多条消息发送成功的返回属性，包含MessageId. Loading history...
180			*/
181
182			public function send_message($message, $delayTime = 0)
183			{
184			if ($this->encoding) {
185			$msgBody = base64_encode($message->msgBody);
186			} else {
187			$msgBody = $message->msgBody;
188			}
189			$params = [
190			'queueName' => $this->queue_name,
191			'msgBody' => $msgBody,
192			'delaySeconds' => $delayTime,
193			];
194			$msgId = $this->cmq_client->send_message($params);
195			$retmsg = new Message();
196			$retmsg->msgId = $msgId;
197
198			return $retmsg;
199			}
200
201			/* 消费消息
202
203			@type polling_wait_seconds: int
204			@param polling_wait_seconds: 本次请求的长轮询时间，单位：秒
			0 ignored issues – show Documentation Bug introduced 2018-07-12 05:51 UTC by Report Bug Copy Issue Report The doc comment `本次请求的长轮询时间，单位：秒` at position `0` could not be parsed: Unknown type name '本次请求的长轮询时间，单位：秒' at position 0 in 本次请求的长轮询时间，单位：秒. Loading history...
205
206			@rtype: Message object
207			@return Message object中包含基本属性、临时句柄
208			*/
209
210			public function batch_send_message($messages, $delayTime = 0)
211			{
212			$params = [
213			'queueName' => $this->queue_name,
214			'delaySeconds' => $delayTime,
215			];
216			$n = 1;
217			foreach ($messages as $message) {
218			$key = 'msgBody.'.$n;
219			if ($this->encoding) {
220			$params[$key] = base64_encode($message->msgBody);
221			} else {
222			$params[$key] = $message->msgBody;
223			}
224			$n += 1;
225			}
226			$msgList = $this->cmq_client->batch_send_message($params);
227			$retMessageList = [];
228			foreach ($msgList as $msg) {
229			$retmsg = new Message();
230			$retmsg->msgId = $msg['msgId'];
231			$retMessageList[] = $retmsg;
232			}
233
234			return $retMessageList;
			0 ignored issues – show Bug Best Practice introduced 2018-07-12 05:51 UTC by Report Bug Copy Issue Report The expression `return $retMessageList` returns the type `Freyo\LaravelQueueCMQ\Queue\Driver\Message[]\|array` which is incompatible with the documented return type `Freyo\LaravelQueueCMQ\Queue\Driver\Message`. Loading history...
235			}
236
237			/* 批量消费消息
238
239			@type num_of_msg: int
240			@param num_of_msg: 本次请求最多获取的消息条数
			0 ignored issues – show Documentation Bug introduced 2018-07-12 05:51 UTC by Report Bug Copy Issue Report The doc comment `本次请求最多获取的消息条数` at position `0` could not be parsed: Unknown type name '本次请求最多获取的消息条数' at position 0 in 本次请求最多获取的消息条数. Loading history...
241
242			@type polling_wait_seconds: int
243			@param polling_wait_seconds: 本次请求的长轮询时间，单位：秒
244
245			@rtype: list of Message object
246			@return 多条消息的属性，包含消息的基本属性、临时句柄
			0 ignored issues – show Documentation Bug introduced 2018-07-12 05:51 UTC by Report Bug Copy Issue Report The doc comment `多条消息的属性，...` at position `0` could not be parsed: Unknown type name '多条消息的属性，包含消息的基本属性、临时句柄' at position 0 in 多条消息的属性，包含消息的基本属性、临时句柄. Loading history...
247			*/
248
249			public function receive_message($polling_wait_seconds = null)
250			{
251			$params = ['queueName' => $this->queue_name];
252			if ($polling_wait_seconds !== null) {
253			$params['UserpollingWaitSeconds'] = $polling_wait_seconds;
254			$params['pollingWaitSeconds'] = $polling_wait_seconds;
255			} else {
256			$params['UserpollingWaitSeconds'] = 30;
257			}
258			$resp = $this->cmq_client->receive_message($params);
259			$msg = new Message();
260			if ($this->encoding) {
261			$msg->msgBody = base64_decode($resp['msgBody']);
262			} else {
263			$msg->msgBody = $resp['msgBody'];
264			}
265			$msg->msgId = $resp['msgId'];
266			$msg->receiptHandle = $resp['receiptHandle'];
267			$msg->enqueueTime = $resp['enqueueTime'];
268			$msg->nextVisibleTime = $resp['nextVisibleTime'];
			0 ignored issues – show Bug Best Practice introduced 2018-07-12 05:51 UTC by Report Bug Copy Issue Report The property `nextVisibleTime` does not exist. Although not strictly required by PHP, it is generally a best practice to declare properties explicitly. Loading history...
269			$msg->dequeueCount = $resp['dequeueCount'];
			0 ignored issues – show Bug Best Practice introduced 2018-07-12 05:51 UTC by Report Bug Copy Issue Report The property `dequeueCount` does not exist. Although not strictly required by PHP, it is generally a best practice to declare properties explicitly. Loading history...
270			$msg->firstDequeueTime = $resp['firstDequeueTime'];
			0 ignored issues – show Bug Best Practice introduced 2018-07-12 05:51 UTC by Report Bug Copy Issue Report The property `firstDequeueTime` does not exist. Although not strictly required by PHP, it is generally a best practice to declare properties explicitly. Loading history...
271
272			return $msg;
273			}
274
275			/* 删除消息
276
277			@type receipt_handle: string
278			@param receipt_handle: 最近一次操作该消息返回的临时句柄
			0 ignored issues – show Documentation Bug introduced 2018-07-12 05:51 UTC by Report Bug Copy Issue Report The doc comment `最近一次操作该消息返回的临时句柄` at position `0` could not be parsed: Unknown type name '最近一次操作该消息返回的临时句柄' at position 0 in 最近一次操作该消息返回的临时句柄. Loading history...
279			*/
280
281			public function batch_receive_message($num_of_msg, $polling_wait_seconds = null)
282			{
283			$params = ['queueName' => $this->queue_name, 'numOfMsg' => $num_of_msg];
284			if ($polling_wait_seconds != null) {
285			$params['UserpollingWaitSeconds'] = $polling_wait_seconds;
286			$params['pollingWaitSeconds'] = $polling_wait_seconds;
287			} else {
288			$params['UserpollingWaitSeconds'] = 30;
289			}
290			$msgInfoList = $this->cmq_client->batch_receive_message($params);
291			$retMessageList = [];
292			foreach ($msgInfoList as $msg) {
293			$retmsg = new Message();
294			if ($this->encoding) {
295			$retmsg->msgBody = base64_decode($msg['msgBody']);
296			} else {
297			$retmsg->msgBody = $msg['msgBody'];
298			}
299			$retmsg->msgId = $msg['msgId'];
300			$retmsg->receiptHandle = $msg['receiptHandle'];
301			$retmsg->enqueueTime = $msg['enqueueTime'];
302			$retmsg->nextVisibleTime = $msg['nextVisibleTime'];
			0 ignored issues – show Bug Best Practice introduced 2018-07-12 05:51 UTC by Report Bug Copy Issue Report The property `nextVisibleTime` does not exist. Although not strictly required by PHP, it is generally a best practice to declare properties explicitly. Loading history...
303			$retmsg->dequeueCount = $msg['dequeueCount'];
			0 ignored issues – show Bug Best Practice introduced 2018-07-12 05:51 UTC by Report Bug Copy Issue Report The property `dequeueCount` does not exist. Although not strictly required by PHP, it is generally a best practice to declare properties explicitly. Loading history...
304			$retmsg->firstDequeueTime = $msg['firstDequeueTime'];
			0 ignored issues – show Bug Best Practice introduced 2018-07-12 05:51 UTC by Report Bug Copy Issue Report The property `firstDequeueTime` does not exist. Although not strictly required by PHP, it is generally a best practice to declare properties explicitly. Loading history...
305			$retMessageList[] = $retmsg;
306			}
307
308			return $retMessageList;
309			}
310
311			/* 批量删除消息
312
313			@type receipt_handle_list: list
314			@param receipt_handle_list: batch_receive_message返回的多条消息的临时句柄
			0 ignored issues – show Documentation Bug introduced 2018-07-12 05:51 UTC by Report Bug Copy Issue Report The doc comment `batch_receive_message返...` at position `0` could not be parsed: Unknown type name 'batch_receive_message返回的多条消息的临时句柄' at position 0 in batch_receive_message返回的多条消息的临时句柄. Loading history...
315			*/
316
317			public function delete_message($receipt_handle)
318			{
319			$params = ['queueName' => $this->queue_name, 'receiptHandle' => $receipt_handle];
320			$this->cmq_client->delete_message($params);
321			}
322
323			public function batch_delete_message($receipt_handle_list)
324			{
325			$params = ['queueName' => $this->queue_name];
326			$n = 1;
327			foreach ($receipt_handle_list as $receipt_handle) {
328			$key = 'receiptHandle.'.$n;
329			$params[$key] = $receipt_handle;
330			$n += 1;
331			}
332			$this->cmq_client->batch_delete_message($params);
333			}
334			}
335

freyo / laravel-queue-cmq

Queue::__resp2meta__() F last analyzed 2021-08-19 05:17 UTC

Complexity

Size

Duplication

Code Coverage

Importance

How to fix Complexity

Long Method

Duplication Side-by-Side

Filter issues like

Queue::resp2meta() F
last analyzed 2021-08-19 05:17 UTC