web/lib/Zend/Cloud/QueueService/Adapter/Sqs.php
changeset 807 877f952ae2bd
parent 207 621fa6caec0c
child 1230 68c69c656a2c
--- a/web/lib/Zend/Cloud/QueueService/Adapter/Sqs.php	Thu Mar 21 17:31:31 2013 +0100
+++ b/web/lib/Zend/Cloud/QueueService/Adapter/Sqs.php	Thu Mar 21 19:50:53 2013 +0100
@@ -13,7 +13,7 @@
  * @category   Zend
  * @package    Zend_Cloud
  * @subpackage QueueService
- * @copyright  Copyright (c) 2005-2010 Zend Technologies USA Inc. (http://www.zend.com)
+ * @copyright  Copyright (c) 2005-2012 Zend Technologies USA Inc. (http://www.zend.com)
  * @license    http://framework.zend.com/license/new-bsd     New BSD License
  */
 
@@ -28,10 +28,10 @@
  * @category   Zend
  * @package    Zend_Cloud
  * @subpackage QueueService
- * @copyright  Copyright (c) 2005-2010 Zend Technologies USA Inc. (http://www.zend.com)
+ * @copyright  Copyright (c) 2005-2012 Zend Technologies USA Inc. (http://www.zend.com)
  * @license    http://framework.zend.com/license/new-bsd     New BSD License
  */
-class Zend_Cloud_QueueService_Adapter_Sqs 
+class Zend_Cloud_QueueService_Adapter_Sqs
     extends Zend_Cloud_QueueService_Adapter_AbstractAdapter
 {
     /*
@@ -53,11 +53,11 @@
 
     /**
      * Constructor
-     * 
-     * @param  array|Zend_Config $options 
+     *
+     * @param  array|Zend_Config $options
      * @return void
      */
-    public function __construct($options = array()) 
+    public function __construct($options = array())
     {
         if ($options instanceof Zend_Config) {
             $options = $options->toArray();
@@ -85,7 +85,7 @@
 
         if(isset($options[self::HTTP_ADAPTER])) {
             $this->_sqs->getHttpClient()->setAdapter($options[self::HTTP_ADAPTER]);
-        } 
+        }
     }
 
      /**
@@ -97,7 +97,7 @@
      * @param  array  $options
      * @return string Queue ID (typically URL)
      */
-    public function createQueue($name, $options = null) 
+    public function createQueue($name, $options = null)
     {
         try {
             return $this->_sqs->create($name, $options[self::CREATE_TIMEOUT]);
@@ -113,7 +113,7 @@
      * @param  array  $options
      * @return boolean true if successful, false otherwise
      */
-    public function deleteQueue($queueId, $options = null) 
+    public function deleteQueue($queueId, $options = null)
 {
         try {
             return $this->_sqs->delete($queueId);
@@ -128,7 +128,7 @@
      * @param  array $options
      * @return array Queue IDs
      */
-    public function listQueues($options = null) 
+    public function listQueues($options = null)
     {
         try {
             return $this->_sqs->getQueues();
@@ -144,7 +144,7 @@
      * @param  array  $options
      * @return array
      */
-    public function fetchQueueMetadata($queueId, $options = null) 
+    public function fetchQueueMetadata($queueId, $options = null)
     {
         try {
             // TODO: ZF-9050 Fix the SQS client library in trunk to return all attribute values
@@ -169,7 +169,7 @@
      * @param  array  $options
      * @return void
      */
-    public function storeQueueMetadata($queueId, $metadata, $options = null) 
+    public function storeQueueMetadata($queueId, $metadata, $options = null)
     {
         // TODO Add support for SetQueueAttributes to client library
         require_once 'Zend/Cloud/OperationNotAvailableException.php';
@@ -184,7 +184,7 @@
      * @param  array  $options
      * @return string Message ID
      */
-    public function sendMessage($queueId, $message, $options = null) 
+    public function sendMessage($queueId, $message, $options = null)
     {
         try {
             return $this->_sqs->send($queueId, $message);
@@ -202,7 +202,7 @@
      * @param  array  $options
      * @return array
      */
-    public function receiveMessages($queueId, $max = 1, $options = null) 
+    public function receiveMessages($queueId, $max = 1, $options = null)
     {
         try {
             return $this->_makeMessages($this->_sqs->receive($queueId, $max, $options[self::VISIBILITY_TIMEOUT]));
@@ -210,11 +210,11 @@
             throw new Zend_Cloud_QueueService_Exception('Error on recieving messages: '.$e->getMessage(), $e->getCode(), $e);
         }
     }
-    
+
     /**
      * Create Zend_Cloud_QueueService_Message array for
      * Sqs messages.
-     *  
+     *
      * @param array $messages
      * @return Zend_Cloud_QueueService_Message[]
      */
@@ -237,7 +237,7 @@
      * @param  array  $options
      * @return void
      */
-    public function deleteMessage($queueId, $message, $options = null) 
+    public function deleteMessage($queueId, $message, $options = null)
     {
         try {
             if($message instanceof Zend_Cloud_QueueService_Message) {
@@ -249,7 +249,7 @@
             throw new Zend_Cloud_QueueService_Exception('Error on deleting a message: '.$e->getMessage(), $e->getCode(), $e);
         }
     }
-    
+
     /**
      * Peek at the messages from the specified queue without removing them.
      *
@@ -269,7 +269,7 @@
 
     /**
      * Get SQS implementation
-     * @return Zend_Service_Amazon_Sqs 
+     * @return Zend_Service_Amazon_Sqs
      */
     public function getClient()
     {