QueueConsumer.php — 10Web Booster – Website speed optimization, Cache & Page Speed optimizer trunk

tenweb-speed-optimizer / vendor / 10web-utils / tenweb-image-optimizer / src / TenWebIO / Queue / QueueConsumer.php

tenweb-speed-optimizer / vendor / 10web-utils / tenweb-image-optimizer / src / TenWebIO / Queue Last commit date

QueueConsumer.php

56 lines

1	<?php
2	namespace TenWebIO\Queue;
3
4	use TenWebIO\Compress;
5	use TenWebIO\Logs;
6	use TenWebIO\Utils;
7	use TenWebQueue\Abstracts\QueueConsumerAbstract;
8
9	class QueueConsumer extends QueueConsumerAbstract
10	{
11	/**
12	* @param $message
13	*
14	* @return bool
15	*/
16	public function process($message)
17	{
18	$message_data = json_decode($message->getBody(), true);
19	if (!is_array($message_data)) {
20	$message_data = json_decode($message_data, true);
21	}
22	$compress = new Compress($this->getQueueName(), $message_data['guid'], $message_data['ID'], $message_data['size']);
23	try {
24	$compress->compress();
25	Logs::setLog("compress:process:" . $message_data['guid'] . ':ID:' . $message_data['ID'], 'Success');
26	} catch (\Exception $e) {
27	Logs::setLog("compress:process:" . $message_data['guid'] . ':ID:' . $message_data['ID'], 'Error ' . $e->getMessage(), 'error');
28	if ($e->getMessage() === 'finish_queue') {
29	Logs::setLog("compress:process:finished", 'Queue has finished because of 400 bad request', 'error');
30	$this->finishInCaseOfError();
31	}
32	}
33
34	return true;
35	}
36
37	/**
38	* @return bool
39	*/
40	public function finish()
41	{
42	Utils::finishQueue(Utils::getQueueTypeByName($this->getQueueName()));
43
44	return true;
45	}
46
47	/**
48	* @return bool
49	*/
50	public function finishInCaseOfError()
51	{
52	Utils::finishQueue(Utils::getQueueTypeByName($this->getQueueName()), true, false);
53
54	return true;
55	}
56	}