Cloud/QueueService/Adapter/AbstractAdapter.php
LICENSE
This source file is subject to the new BSD license that is bundled with this package in the file LICENSE.txt. It is also available through the world-wide-web at this URL: http://framework.zend.com/license/new-bsd If you did not receive a copy of the license and are unable to obtain it through the world-wide-web, please send an email to [email protected] so we can send you a copy immediately.
- Category
- Zend
- Copyright
- Copyright (c) 2005-2012 Zend Technologies USA Inc. (http://www.zend.com)
- License
- New BSD License
- Package
- Zend_Cloud
- Subpackage
- QueueService
\Zend_Cloud_QueueService_Adapter_AbstractAdapter
Abstract queue adapter
Provides functionality around setting message and message set classes.
- Implements
- \Zend_Cloud_QueueService_Adapter
- Children
- \Zend_Cloud_QueueService_Adapter_WindowsAzure
- \Zend_Cloud_QueueService_Adapter_Sqs
- \Zend_Cloud_QueueService_Adapter_ZendQueue
- Category
- Zend
- Copyright
- Copyright (c) 2005-2012 Zend Technologies USA Inc. (http://www.zend.com)
- License
- New BSD License
Constants

VISIBILITY_TIMEOUT
= 'visibility_timeout'
Message visibility timeout option
Inherited from: \Zend_Cloud_QueueService_Adapter::VISIBILITY_TIMEOUT- Inherited_from
- \Zend_Cloud_QueueService_Adapter::VISIBILITY_TIMEOUT

DEFAULT_TIMEOUT
= 30
Default visibility timeout
Inherited from: \Zend_Cloud_QueueService_Adapter::DEFAULT_TIMEOUT- Inherited_from
- \Zend_Cloud_QueueService_Adapter::DEFAULT_TIMEOUT
Properties


string $_messageClass = 'Zend_Cloud_QueueService_Message'
'Zend_Cloud_QueueService_Message'
Details- Type
- string
Methods


createQueue(string $name, array $options = null) : string
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.
Name constraints: Maximum 80 characters Only alphanumeric characters, hyphens (-), and underscores (_)
Name | Type | Description |
---|---|---|
$name | string | |
$options | array |
Type | Description |
---|---|
string | Queue ID (typically URL) |


deleteMessage(string $queueId, \Zend_Cloud_QueueService_Message $message, array $options = null) : void
Delete the specified message from the specified queue.
Inherited from: \Zend_Cloud_QueueService_Adapter::deleteMessage()Name | Type | Description |
---|---|---|
$queueId | string | |
$message | \Zend_Cloud_QueueService_Message | Message to delete |
$options | array |


deleteQueue(string $queueId, array $options = null) : boolean
All messages in the queue will also be deleted.
Name | Type | Description |
---|---|---|
$queueId | string | |
$options | array |
Type | Description |
---|---|
boolean | true if successful, false otherwise |


fetchQueueMetadata(string $queueId, array $options = null) : array
Get a key/value array of metadata for the given queue.
Inherited from: \Zend_Cloud_QueueService_Adapter::fetchQueueMetadata()Name | Type | Description |
---|---|---|
$queueId | string | |
$options | array |
Type | Description |
---|---|
array |


getMessageSetClass() : string
Get class to use for message collection objects
Type | Description |
---|---|
string |


listQueues(array $options = null) : array
Name | Type | Description |
---|---|---|
$options | array |
Type | Description |
---|---|
array | Queue IDs |


peekMessages(string $queueId, int $num = 1, array $options = null) : \array[Zend_Cloud_QueueService_Message]
Peek at the messages from the specified queue without removing them.
Inherited from: \Zend_Cloud_QueueService_Adapter::peekMessages()Name | Type | Description |
---|---|---|
$queueId | string | |
$num | int | How many messages |
$options | array |
Type | Description |
---|---|
\array[Zend_Cloud_QueueService_Message] |


receiveMessages(string $queueId, int $max = 1, array $options = null) : \array[Zend_Cloud_QueueService_Message]
Recieve at most $max messages from the specified queue and return the message IDs for messages recieved.
Inherited from: \Zend_Cloud_QueueService_Adapter::receiveMessages()Name | Type | Description |
---|---|---|
$queueId | string | |
$max | int | |
$options | array |
Type | Description |
---|---|
\array[Zend_Cloud_QueueService_Message] | Array of messages |


sendMessage(string $queueId, string $message, array $options = null) : string
Send a message to the specified queue.
Inherited from: \Zend_Cloud_QueueService_Adapter::sendMessage()Name | Type | Description |
---|---|---|
$queueId | string | |
$message | string | |
$options | array |
Type | Description |
---|---|
string | Message ID |


setMessageClass(string $class) : \Zend_Cloud_QueueService_Adapter_AbstractAdapter
Set class to use for message objects
Name | Type | Description |
---|---|---|
$class | string |
Type | Description |
---|---|
\Zend_Cloud_QueueService_Adapter_AbstractAdapter |


setMessageSetClass(string $class) : \Zend_Cloud_QueueService_Adapter_AbstractAdapter
Set class to use for message collection objects
Name | Type | Description |
---|---|---|
$class | string |
Type | Description |
---|---|
\Zend_Cloud_QueueService_Adapter_AbstractAdapter |


storeQueueMetadata(string $queueId, array $metadata, array $options = null) : void
Store a key/value array of metadata for the specified queue.
Inherited from: \Zend_Cloud_QueueService_Adapter::storeQueueMetadata()WARNING: This operation overwrites any metadata that is located at $destinationPath. Some adapters may not support this method.
Name | Type | Description |
---|---|---|
$queueId | string | |
$metadata | array | |
$options | array |