tweet_live: comparison web/lib/Zend/Cloud/QueueService/Adapter/WindowsAzure.php

equal deleted inserted replaced

-:2251fb41dbc7
+:1e110b03ae96
 * to license@zend.com so we can send you a copy immediately.
 *
 * @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
 */
 require_once 'Zend/Cloud/QueueService/Adapter/AbstractAdapter.php';
 require_once 'Zend/Cloud/QueueService/Exception.php';
 * WindowsAzure adapter for simple queue service.
 *
 * @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_WindowsAzure
 extends Zend_Cloud_QueueService_Adapter_AbstractAdapter
 {
 /**
 * Option array keys for the Windows Azure adapter.
 */
 const LIST_PREFIX      = 'prefix';
 const LIST_MAX_RESULTS = 'max_results';
 /** message options */
 const MESSAGE_TTL = 'ttl';
 const DEFAULT_HOST = Zend_Service_WindowsAzure_Storage::URL_CLOUD_QUEUE;
 /**
 * Storage client
 *
 * @var Zend_Service_WindowsAzure_Storage_Queue
 */
 protected $_storageClient = null;
 /**
 * Constructor
 *
 * @param  array|Zend_Config $options
 * @return void
 */
 public function __construct($options = array())
 {
 if ($options instanceof Zend_Config) {
 $this->_storageClient->setHttpClientChannel($httpAdapter);
 }
 } catch(Zend_Service_WindowsAzure_Exception $e) {
 throw new Zend_Cloud_QueueService_Exception('Error on create: '.$e->getMessage(), $e->getCode(), $e);
 }
 }
 /**
 * Create a queue. Returns the ID of the created queue (typically the URL).
 * It may take some time to create the queue. Check your vendor's
 * documentation for details.
 *
 return $queue->Name;
 } catch (Zend_Service_WindowsAzure_Exception $e) {
 throw new Zend_Cloud_QueueService_Exception('Error on queue creation: '.$e->getMessage(), $e->getCode(), $e);
 }
 }
 /**
 * Delete a queue. All messages in the queue will also be deleted.
 *
 * @param  string $queueId
 * @param  array  $options
 return $this->_storageClient->deleteQueue($queueId);
 } catch (Zend_Service_WindowsAzure_Exception $e) {
 throw new Zend_Cloud_QueueService_Exception('Error on queue deletion: '.$e->getMessage(), $e->getCode(), $e);
 }
 }
 /**
 * List all queues.
 *
 * @param  array $options
 * @return array Queue IDs
 return $result;
 } catch (Zend_Service_WindowsAzure_Exception $e) {
 throw new Zend_Cloud_QueueService_Exception('Error on listing queues: '.$e->getMessage(), $e->getCode(), $e);
 }
 }
 /**
 * Get a key/value array of metadata for the given queue.
 *
 * @param  string $queueId
 * @param  array  $options
 return $this->_storageClient->getQueueMetadata($queueId);
 } catch (Zend_Service_WindowsAzure_Exception $e) {
 throw new Zend_Cloud_QueueService_Exception('Error on fetching queue metadata: '.$e->getMessage(), $e->getCode(), $e);
 }
 }
 /**
 * Store a key/value array of metadata for the specified queue.
 * WARNING: This operation overwrites any metadata that is located at
 * $destinationPath. Some adapters may not support this method.
 *
 * @param  string $queueId
 * @param  array  $metadata
 * @param  array  $options
 * @return void
 */
 return $this->_storageClient->setQueueMetadata($queueId, $metadata);
 } catch (Zend_Service_WindowsAzure_Exception $e) {
 throw new Zend_Cloud_QueueService_Exception('Error on setting queue metadata: '.$e->getMessage(), $e->getCode(), $e);
 }
 }
 /**
 * Send a message to the specified queue.
 *
 * @param  string $queueId
 * @param  string $message
 * @param  array  $options
 * @return string Message ID
 */
 );
 } catch (Zend_Service_WindowsAzure_Exception $e) {
 throw new Zend_Cloud_QueueService_Exception('Error on sending message: '.$e->getMessage(), $e->getCode(), $e);
 }
 }
 /**
 * Recieve at most $max messages from the specified queue and return the
 * message IDs for messages recieved.
 *
 * @param  string $queueId
 * @param  int    $max
 * @param  array  $options
 * @return Zend_Cloud_QueueService_Message[]
 */
 return $this->_makeMessages($this->_storageClient->getMessages($queueId, $max, $visibility, false));
 } catch (Zend_Service_WindowsAzure_Exception $e) {
 throw new Zend_Cloud_QueueService_Exception('Error on recieving messages: '.$e->getMessage(), $e->getCode(), $e);
 }
 }
 /**
 * Create Zend_Cloud_QueueService_Message array for
 * Azure messages.
 *
 * @param array $messages
 * @return Zend_Cloud_QueueService_Message[]
 */
 protected function _makeMessages($messages)
 {
 return new $setClass($result);
 }
 /**
 * Delete the specified message from the specified queue.
 *
 * @param  string $queueId
 * @param  Zend_Cloud_QueueService_Message $message Message ID or message
 * @param  array  $options
 * @return void
 */
 public function deleteMessage($queueId, $message, $options = null)
 {
 return $this->_makeMessages($this->_storageClient->peekMessages($queueId, $num));
 } catch (Zend_Service_WindowsAzure_Exception $e) {
 throw new Zend_Cloud_QueueService_Exception('Error on peeking messages: '.$e->getMessage(), $e->getCode(), $e);
 }
 }
 /**
 * Get Azure implementation
 * @return Zend_Service_Azure_Storage_Queue
 */
 public function getClient()
 {
 return $this->_storageClient;
 }

changeset 886	1e110b03ae96
parent 807	877f952ae2bd
child 1230	68c69c656a2c