equal
deleted
inserted
replaced
11 * to license@zend.com so we can send you a copy immediately. |
11 * to license@zend.com so we can send you a copy immediately. |
12 * |
12 * |
13 * @category Zend |
13 * @category Zend |
14 * @package Zend_Cloud |
14 * @package Zend_Cloud |
15 * @subpackage QueueService |
15 * @subpackage QueueService |
16 * @copyright Copyright (c) 2005-2012 Zend Technologies USA Inc. (http://www.zend.com) |
16 * @copyright Copyright (c) 2005-2015 Zend Technologies USA Inc. (http://www.zend.com) |
17 * @license http://framework.zend.com/license/new-bsd New BSD License |
17 * @license http://framework.zend.com/license/new-bsd New BSD License |
18 */ |
18 */ |
19 |
19 |
20 require_once 'Zend/Service/Amazon/Sqs.php'; |
20 require_once 'Zend/Service/Amazon/Sqs.php'; |
21 require_once 'Zend/Cloud/QueueService/Adapter/AbstractAdapter.php'; |
21 require_once 'Zend/Cloud/QueueService/Adapter/AbstractAdapter.php'; |
26 * SQS adapter for simple queue service. |
26 * SQS adapter for simple queue service. |
27 * |
27 * |
28 * @category Zend |
28 * @category Zend |
29 * @package Zend_Cloud |
29 * @package Zend_Cloud |
30 * @subpackage QueueService |
30 * @subpackage QueueService |
31 * @copyright Copyright (c) 2005-2012 Zend Technologies USA Inc. (http://www.zend.com) |
31 * @copyright Copyright (c) 2005-2015 Zend Technologies USA Inc. (http://www.zend.com) |
32 * @license http://framework.zend.com/license/new-bsd New BSD License |
32 * @license http://framework.zend.com/license/new-bsd New BSD License |
33 */ |
33 */ |
34 class Zend_Cloud_QueueService_Adapter_Sqs |
34 class Zend_Cloud_QueueService_Adapter_Sqs |
35 extends Zend_Cloud_QueueService_Adapter_AbstractAdapter |
35 extends Zend_Cloud_QueueService_Adapter_AbstractAdapter |
36 { |
36 { |
116 public function deleteQueue($queueId, $options = null) |
116 public function deleteQueue($queueId, $options = null) |
117 { |
117 { |
118 try { |
118 try { |
119 return $this->_sqs->delete($queueId); |
119 return $this->_sqs->delete($queueId); |
120 } catch(Zend_Service_Amazon_Exception $e) { |
120 } catch(Zend_Service_Amazon_Exception $e) { |
121 throw Zend_Cloud_QueueService_Exception('Error on queue deletion: '.$e->getMessage(), $e->getCode(), $e); |
121 throw new Zend_Cloud_QueueService_Exception('Error on queue deletion: '.$e->getMessage(), $e->getCode(), $e); |
122 } |
122 } |
123 } |
123 } |
124 |
124 |
125 /** |
125 /** |
126 * List all queues. |
126 * List all queues. |