tweet_live: comparison web/lib/Zend/Cloud/QueueService/Adapter/ZendQueue.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_ZendQueue
 extends Zend_Cloud_QueueService_Adapter_AbstractAdapter
 {
 /**
 * Options array keys for the Zend_Queue adapter.
 */
 const ADAPTER = 'adapter';
 /**
 * Storage client
 *
 * @var Zend_Queue
 */
 protected $_queue = null;
 /**
 * @var array All queues
 */
 protected $_queues = array();
 /**
 * Constructor
 *
 * @param  array|Zend_Config $options
 * @return void
 */
 public function __construct ($options = array())
 {
 if ($options instanceof Zend_Config) {
 $this->_queue = new Zend_Queue($adapter, $options);
 } catch (Zend_Queue_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 $name;
 } catch (Zend_Queue_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
 }
 } catch (Zend_Queue_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 $this->_queue->getQueues();
 } catch (Zend_Queue_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->_queues[$queueId]->getOptions();
 } catch (Zend_Queue_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->_queues[$queueId]->setOptions($metadata);
 } catch (Zend_Queue_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
 */
 return $this->_queues[$queueId]->send($message);
 } catch (Zend_Queue_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 array
 */
 }
 } catch (Zend_Queue_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)
 {
 foreach ($messages as $message) {
 $result[] = new $messageClass($message->body, $message);
 }
 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)
 {
 $message = $message->getMessage();
 }
 if (!($message instanceof Zend_Queue_Message)) {
 throw new Zend_Cloud_QueueService_Exception('Cannot delete the message: Zend_Queue_Message object required');
 }
 return $this->_queues[$queueId]->deleteMessage($message);
 } catch (Zend_Queue_Exception $e) {
 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.
 *
 * @param  string $queueId
 * @param  int $num How many messages
 public function peekMessages($queueId, $num = 1, $options = null)
 {
 require_once 'Zend/Cloud/OperationNotAvailableException.php';
 throw new Zend_Cloud_OperationNotAvailableException('ZendQueue doesn\'t currently support message peeking');
 }
 /**
 * Get Azure implementation
 * @return Zend_Queue
 */
 public function getClient()
 {
 return $this->_queue;
 }

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