File: /home/httpd/html/baretube.com.new/admin/aws-sdk-for-php/services/sqs.class.php
<?php
/*
* Copyright 2010-2013 Amazon.com, Inc. or its affiliates. All Rights Reserved.
*
* Licensed under the Apache License, Version 2.0 (the "License").
* You may not use this file except in compliance with the License.
* A copy of the License is located at
*
* http://aws.amazon.com/apache2.0
*
* or in the "license" file accompanying this file. This file is distributed
* on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
* express or implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
/**
* Amazon Simple Queue Service (Amazon SQS) offers a reliable, highly scalable, hosted queue for
* storing messages as they travel between computers. By using Amazon SQS, developers can simply
* move data between distributed components of their applications that perform different tasks,
* without losing messages or requiring each component to be always available. Amazon SQS makes it
* easy to build an automated workflow, working in close conjunction with the Amazon Elastic
* Compute Cloud (Amazon EC2) and the other AWS infrastructure web services.
*
* Amazon SQS works by exposing Amazon's web-scale messaging infrastructure as a web service. Any
* computer on the Internet can add or read messages without any installed software or special
* firewall configurations. Components of applications using Amazon SQS can run independently, and
* do not need to be on the same network, developed with the same technologies, or running at the
* same time.
*
* Visit <a href="http://aws.amazon.com/sqs/">http://aws.amazon.com/sqs/</a> for more information.
*
* @version 2013.01.14
* @license See the included NOTICE.md file for complete information.
* @copyright See the included NOTICE.md file for complete information.
* @link http://aws.amazon.com/sqs/ Amazon Simple Queue Service
* @link http://aws.amazon.com/sqs/documentation/ Amazon Simple Queue Service documentation
*/
class AmazonSQS extends CFRuntime
{
/*%******************************************************************************************%*/
// CLASS CONSTANTS
/**
* Specify the queue URL for the United States East (Northern Virginia) Region.
*/
const REGION_US_E1 = 'sqs.us-east-1.amazonaws.com';
/**
* Specify the queue URL for the United States East (Northern Virginia) Region.
*/
const REGION_VIRGINIA = self::REGION_US_E1;
/**
* Specify the queue URL for the United States West (Northern California) Region.
*/
const REGION_US_W1 = 'sqs.us-west-1.amazonaws.com';
/**
* Specify the queue URL for the United States West (Northern California) Region.
*/
const REGION_CALIFORNIA = self::REGION_US_W1;
/**
* Specify the queue URL for the United States West (Oregon) Region.
*/
const REGION_US_W2 = 'sqs.us-west-2.amazonaws.com';
/**
* Specify the queue URL for the United States West (Oregon) Region.
*/
const REGION_OREGON = self::REGION_US_W2;
/**
* Specify the queue URL for the Europe West (Ireland) Region.
*/
const REGION_EU_W1 = 'sqs.eu-west-1.amazonaws.com';
/**
* Specify the queue URL for the Europe West (Ireland) Region.
*/
const REGION_IRELAND = self::REGION_EU_W1;
/**
* Specify the queue URL for the Asia Pacific Southeast (Singapore) Region.
*/
const REGION_APAC_SE1 = 'sqs.ap-southeast-1.amazonaws.com';
/**
* Specify the queue URL for the Asia Pacific Southeast (Singapore) Region.
*/
const REGION_SINGAPORE = self::REGION_APAC_SE1;
/**
* Specify the queue URL for the Asia Pacific Southeast (Singapore) Region.
*/
const REGION_APAC_SE2 = 'sqs.ap-southeast-2.amazonaws.com';
/**
* Specify the queue URL for the Asia Pacific Southeast (Singapore) Region.
*/
const REGION_SYDNEY = self::REGION_APAC_SE2;
/**
* Specify the queue URL for the Asia Pacific Northeast (Tokyo) Region.
*/
const REGION_APAC_NE1 = 'sqs.ap-northeast-1.amazonaws.com';
/**
* Specify the queue URL for the Asia Pacific Northeast (Tokyo) Region.
*/
const REGION_TOKYO = self::REGION_APAC_NE1;
/**
* Specify the queue URL for the South America (Sao Paulo) Region.
*/
const REGION_SA_E1 = 'sqs.sa-east-1.amazonaws.com';
/**
* Specify the queue URL for the South America (Sao Paulo) Region.
*/
const REGION_SAO_PAULO = self::REGION_SA_E1;
/**
* Specify the queue URL for the United States GovCloud Region.
*/
const REGION_US_GOV1 = 'sqs.us-gov-west-1.amazonaws.com';
/**
* Default service endpoint.
*/
const DEFAULT_URL = self::REGION_US_E1;
/*%******************************************************************************************%*/
// CONSTRUCTOR
/**
* Constructs a new instance of <AmazonSQS>.
*
* @param array $options (Optional) An associative array of parameters that can have the following keys: <ul>
* <li><code>certificate_authority</code> - <code>boolean</code> - Optional - Determines which Cerificate Authority file to use. A value of boolean <code>false</code> will use the Certificate Authority file available on the system. A value of boolean <code>true</code> will use the Certificate Authority provided by the SDK. Passing a file system path to a Certificate Authority file (chmodded to <code>0755</code>) will use that. Leave this set to <code>false</code> if you're not sure.</li>
* <li><code>credentials</code> - <code>string</code> - Optional - The name of the credential set to use for authentication.</li>
* <li><code>default_cache_config</code> - <code>string</code> - Optional - This option allows a preferred storage type to be configured for long-term caching. This can be changed later using the <set_cache_config()> method. Valid values are: <code>apc</code>, <code>xcache</code>, or a file system path such as <code>./cache</code> or <code>/tmp/cache/</code>.</li>
* <li><code>key</code> - <code>string</code> - Optional - Your AWS key, or a session key. If blank, the default credential set will be used.</li>
* <li><code>secret</code> - <code>string</code> - Optional - Your AWS secret key, or a session secret key. If blank, the default credential set will be used.</li>
* <li><code>token</code> - <code>string</code> - Optional - An AWS session token.</li></ul>
* @return void
*/
public function __construct(array $options = array())
{
$this->api_version = '2012-11-05';
$this->hostname = self::DEFAULT_URL;
$this->auth_class = 'AuthV4Query';
return parent::__construct($options);
}
/*%******************************************************************************************%*/
// SETTERS
/**
* This allows you to explicitly sets the region for the service to use.
*
* @param string $region (Required) The region to explicitly set. Available options are <REGION_US_E1>, <REGION_US_W1>, <REGION_US_W2>, <REGION_EU_W1>, <REGION_APAC_SE1>, <REGION_APAC_SE2>, <REGION_APAC_NE1>, <REGION_SA_E1>, <REGION_US_GOV1>.
* @return $this A reference to the current instance.
*/
public function set_region($region)
{
// @codeCoverageIgnoreStart
$this->set_hostname($region);
return $this;
// @codeCoverageIgnoreEnd
}
/*%******************************************************************************************%*/
// CONVENIENCE METHODS
/**
* Converts a queue URI into a queue ARN.
*
* @param string $queue_url (Required) The queue URL to perform the action on. Retrieved when the queue is first created.
* @return string An ARN representation of the queue URI.
*/
function get_queue_arn($queue_url)
{
return str_replace(
array('http://', 'https://', '.amazonaws.com', '/', '.'),
array('arn:aws:', 'arn:aws:', '', ':', ':'),
$queue_url
);
}
/**
* Returns the approximate number of messages in the queue.
*
* @param string $queue_url (Required) The queue URL to perform the action on. Retrieved when the queue is first created.
* @return mixed The Approximate number of messages in the queue as an integer. If the queue doesn't exist, it returns the entire <CFResponse> object.
*/
public function get_queue_size($queue_url)
{
$response = $this->get_queue_attributes($queue_url, array(
'AttributeName' => 'ApproximateNumberOfMessages'
));
if (!$response->isOK())
{
return $response;
}
return (integer) $response->body->Value(0);
}
/**
* ONLY lists the queue URLs, as an array, on the SQS account.
*
* @param string $pcre (Optional) A Perl-Compatible Regular Expression (PCRE) to filter the names against.
* @return array The list of matching queue names. If there are no results, the method will return an empty array.
* @link http://php.net/pcre Perl-Compatible Regular Expression (PCRE) Docs
*/
public function get_queue_list($pcre = null)
{
if ($this->use_batch_flow)
{
throw new SQS_Exception(__FUNCTION__ . '() cannot be batch requested');
}
// Get a list of queues.
$list = $this->list_queues();
if ($list = $list->body->QueueUrl())
{
$list = $list->map_string($pcre);
return $list;
}
return array();
}
/*%******************************************************************************************%*/
// OVERWRITTEN METHODS
/**
* This overwrites the default authenticate method in sdk.class.php to address SQS queue URLs.
*
* @return CFResponse Object containing a parsed HTTP response.
*/
public function authenticate($operation, $payload)
{
// Save the current hostname
$hostname = $this->hostname;
if (isset($payload['QueueUrl']))
{
// Change the hostname to the queue URL
$this->hostname = $payload['QueueUrl'];
// Remove "QueueURL" from the payload
unset($payload['QueueUrl']);
}
// Perform the request
$response = parent::authenticate($operation, $payload);
// Restore the hostname
$this->hostname = $hostname;
return $response;
}
/*%******************************************************************************************%*/
// SERVICE METHODS
/**
* The AddPermission action adds a permission to a queue for a specific <a href=
* "http://docs.amazonwebservices.com/AWSSimpleQueueService/latest/APIReference/Glossary.html#d0e3892">
* principal</a>. This allows for sharing access to the queue.
*
* When you create a queue, you have full control access rights for the queue. Only you (as owner
* of the queue) can grant or deny permissions to the queue. For more information about these
* permissions, see <a href=
* "http://docs.amazonwebservices.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/?acp-overview.html">
* Shared Queues</a> in the Amazon SQS Developer Guide.
*
* <code>AddPermission</code> writes an SQS-generated policy. If you want to write your own
* policy, use SetQueueAttributes to upload your policy. For more information about writing your
* own policy, see <a href=
* "http://docs.amazonwebservices.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/?AccessPolicyLanguage.html">
* Appendix: The Access Policy Language</a> in the Amazon SQS Developer Guide.
*
* @param string $queue_url (Required) The URL of the SQS queue to take action on.
* @param string $label (Required) The unique identification of the permission you're setting (e.g., <code>AliceSendMessage</code>). Constraints: Maximum 80 characters; alphanumeric characters, hyphens (-), and underscores (_) are allowed.
* @param string|array $aws_account_id (Required) The AWS account number of the <a href="http://docs.amazonwebservices.com/AWSSimpleQueueService/latest/APIReference/Glossary.html">principal</a> who will be given permission. The principal must have an AWS account, but does not need to be signed up for Amazon SQS. Pass a string for a single value, or an indexed array for multiple values.
* @param string|array $action_name (Required) The action the client wants to allow for the specified principal. Pass a string for a single value, or an indexed array for multiple values.
* @param array $opt (Optional) An associative array of parameters that can have the following keys: <ul>
* <li><code>curlopts</code> - <code>array</code> - Optional - A set of values to pass directly into <code>curl_setopt()</code>, where the key is a pre-defined <code>CURLOPT_*</code> constant.</li>
* <li><code>returnCurlHandle</code> - <code>boolean</code> - Optional - A private toggle specifying that the cURL handle be returned rather than actually completing the request. This toggle is useful for manually managed batch requests.</li></ul>
* @return CFResponse A <CFResponse> object containing a parsed HTTP response.
*/
public function add_permission($queue_url, $label, $aws_account_id, $action_name, $opt = null)
{
if (!$opt) $opt = array();
$opt['QueueUrl'] = $queue_url;
$opt['Label'] = $label;
// Required list (non-map)
$opt = array_merge($opt, CFComplexType::map(array(
'AWSAccountId' => (is_array($aws_account_id) ? $aws_account_id : array($aws_account_id))
)));
// Required list (non-map)
$opt = array_merge($opt, CFComplexType::map(array(
'ActionName' => (is_array($action_name) ? $action_name : array($action_name))
)));
return $this->authenticate('AddPermission', $opt);
}
/**
* The <code>ChangeMessageVisibility</code> action changes the visibility timeout of a specified
* message in a queue to a new value. The maximum allowed timeout value you can set the value to
* is 12 hours. This means you can't extend the timeout of a message in an existing queue to more
* than a total visibility timeout of 12 hours. (For more information visibility timeout, see
* <a href=
* "http://docs.amazonwebservices.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/AboutVT.html">
* Visibility Timeout</a> in the Amazon SQS Developer Guide.)
*
* For example, let's say you have a message and its default message visibility timeout is 30
* minutes. You could call <code>ChangeMessageVisiblity</code> with a value of two hours and the
* effective timeout would be two hours and 30 minutes. When that time comes near you could again
* extend the time out by calling ChangeMessageVisiblity, but this time the maximum allowed
* timeout would be 9 hours and 30 minutes.
*
* <p class="important">
* If you attempt to set the <code>VisibilityTimeout</code> to an amount more than the maximum
* time left, Amazon SQS returns an error. It will not automatically recalculate and increase the
* timeout to the maximum time remaining.
* </p>
* <p class="important">
* Unlike with a queue, when you change the visibility timeout for a specific message, that
* timeout value is applied immediately but is not saved in memory for that message. If you don't
* delete a message after it is received, the visibility timeout for the message the next time it
* is received reverts to the original timeout value, not the value you set with the
* ChangeMessageVisibility action.
* </p>
*
* @param string $queue_url (Required) The URL of the SQS queue to take action on.
* @param string $receipt_handle (Required) The receipt handle associated with the message whose visibility timeout should be changed.
* @param integer $visibility_timeout (Required) The new value (in seconds) for the message's visibility timeout.
* @param array $opt (Optional) An associative array of parameters that can have the following keys: <ul>
* <li><code>curlopts</code> - <code>array</code> - Optional - A set of values to pass directly into <code>curl_setopt()</code>, where the key is a pre-defined <code>CURLOPT_*</code> constant.</li>
* <li><code>returnCurlHandle</code> - <code>boolean</code> - Optional - A private toggle specifying that the cURL handle be returned rather than actually completing the request. This toggle is useful for manually managed batch requests.</li></ul>
* @return CFResponse A <CFResponse> object containing a parsed HTTP response.
*/
public function change_message_visibility($queue_url, $receipt_handle, $visibility_timeout, $opt = null)
{
if (!$opt) $opt = array();
$opt['QueueUrl'] = $queue_url;
$opt['ReceiptHandle'] = $receipt_handle;
$opt['VisibilityTimeout'] = $visibility_timeout;
return $this->authenticate('ChangeMessageVisibility', $opt);
}
/**
* This is a batch version of <code>ChangeMessageVisibility</code>. It takes multiple receipt
* handles and performs the operation on each of the them. The result of the operation on each
* message is reported individually in the response.
*
* @param string $queue_url (Required) The URL of the SQS queue to take action on.
* @param array $change_message_visibility_batch_request_entry (Required) A list of receipt handles of the messages for which the visibility timeout must be changed. <ul>
* <li><code>x</code> - <code>array</code> - Optional - This represents a simple array index. <ul>
* <li><code>Id</code> - <code>string</code> - Required - An identifier for this particular receipt handle. This is used to communicate the result. Note that the <code>Id</code> s of a batch request need to be unique within the request.</li>
* <li><code>ReceiptHandle</code> - <code>string</code> - Required - A receipt handle.</li>
* <li><code>VisibilityTimeout</code> - <code>integer</code> - Optional - The new value (in seconds) for the message's visibility timeout.</li>
* </ul></li>
* </ul>
* @param array $opt (Optional) An associative array of parameters that can have the following keys: <ul>
* <li><code>curlopts</code> - <code>array</code> - Optional - A set of values to pass directly into <code>curl_setopt()</code>, where the key is a pre-defined <code>CURLOPT_*</code> constant.</li>
* <li><code>returnCurlHandle</code> - <code>boolean</code> - Optional - A private toggle specifying that the cURL handle be returned rather than actually completing the request. This toggle is useful for manually managed batch requests.</li></ul>
* @return CFResponse A <CFResponse> object containing a parsed HTTP response.
*/
public function change_message_visibility_batch($queue_url, $change_message_visibility_batch_request_entry, $opt = null)
{
if (!$opt) $opt = array();
$opt['QueueUrl'] = $queue_url;
// Required list + map
$opt = array_merge($opt, CFComplexType::map(array(
'ChangeMessageVisibilityBatchRequestEntry' => (is_array($change_message_visibility_batch_request_entry) ? $change_message_visibility_batch_request_entry : array($change_message_visibility_batch_request_entry))
)));
return $this->authenticate('ChangeMessageVisibilityBatch', $opt);
}
/**
* The <code>CreateQueue</code> action creates a new queue, or returns the URL of an existing one.
* When you request <code>CreateQueue</code>, you provide a name for the queue. To successfully
* create a new queue, you must provide a name that is unique within the scope of your own queues.
*
* You may pass one or more attributes in the request. If you do not provide a value for any
* attribute, the queue will have the default value for that attribute. Permitted attributes are
* the same that can be set using <code>SetQueueAttributes</code>.
*
* If you provide the name of an existing queue, a new queue isn't created. If the values of
* attributes provided with the request match up with those on the existing queue, the queue URL
* is returned. Otherwise, a <code>QueueNameExists</code> error is returned.
*
* @param string $queue_name (Required) The name for the queue to be created.
* @param array $opt (Optional) An associative array of parameters that can have the following keys: <ul>
* <li><code>Attribute</code> - <code>array</code> - Optional - A map of attributes with their corresponding values. <ul>
* <li><code>x</code> - <code>array</code> - Optional - This represents a simple array index. <ul>
* <li><code>Name</code> - <code>string</code> - Optional - The name of a queue attribute. [Allowed values: <code>Policy</code>, <code>VisibilityTimeout</code>, <code>MaximumMessageSize</code>, <code>MessageRetentionPeriod</code>, <code>ApproximateNumberOfMessages</code>, <code>ApproximateNumberOfMessagesNotVisible</code>, <code>CreatedTimestamp</code>, <code>LastModifiedTimestamp</code>, <code>QueueArn</code>, <code>ApproximateNumberOfMessagesDelayed</code>, <code>DelaySeconds</code>, <code>ReceiveMessageWaitTimeSeconds</code>]</li>
* <li><code>Value</code> - <code>string</code> - Optional - The value of a queue attribute.</li>
* </ul></li>
* </ul></li>
* <li><code>curlopts</code> - <code>array</code> - Optional - A set of values to pass directly into <code>curl_setopt()</code>, where the key is a pre-defined <code>CURLOPT_*</code> constant.</li>
* <li><code>returnCurlHandle</code> - <code>boolean</code> - Optional - A private toggle specifying that the cURL handle be returned rather than actually completing the request. This toggle is useful for manually managed batch requests.</li></ul>
* @return CFResponse A <CFResponse> object containing a parsed HTTP response.
*/
public function create_queue($queue_name, $opt = null)
{
if (!$opt) $opt = array();
$opt['QueueName'] = $queue_name;
// Optional map (non-list)
if (isset($opt['Attribute']))
{
$opt = array_merge($opt, CFComplexType::map(array(
'Attribute' => $opt['Attribute']
)));
unset($opt['Attribute']);
}
return $this->authenticate('CreateQueue', $opt);
}
/**
* The <code>DeleteMessage</code> action unconditionally removes the specified message from the
* specified queue. Even if the message is locked by another reader due to the visibility timeout
* setting, it is still deleted from the queue.
*
* @param string $queue_url (Required) The URL of the SQS queue to take action on.
* @param string $receipt_handle (Required) The receipt handle associated with the message to delete.
* @param array $opt (Optional) An associative array of parameters that can have the following keys: <ul>
* <li><code>curlopts</code> - <code>array</code> - Optional - A set of values to pass directly into <code>curl_setopt()</code>, where the key is a pre-defined <code>CURLOPT_*</code> constant.</li>
* <li><code>returnCurlHandle</code> - <code>boolean</code> - Optional - A private toggle specifying that the cURL handle be returned rather than actually completing the request. This toggle is useful for manually managed batch requests.</li></ul>
* @return CFResponse A <CFResponse> object containing a parsed HTTP response.
*/
public function delete_message($queue_url, $receipt_handle, $opt = null)
{
if (!$opt) $opt = array();
$opt['QueueUrl'] = $queue_url;
$opt['ReceiptHandle'] = $receipt_handle;
return $this->authenticate('DeleteMessage', $opt);
}
/**
* This is a batch version of <code>DeleteMessage</code>. It takes multiple receipt handles and
* deletes each one of the messages. The result of the delete operation on each message is
* reported individually in the response.
*
* @param string $queue_url (Required) The URL of the SQS queue to take action on.
* @param array $delete_message_batch_request_entry (Required) A list of receipt handles for the messages to be deleted. <ul>
* <li><code>x</code> - <code>array</code> - Optional - This represents a simple array index. <ul>
* <li><code>Id</code> - <code>string</code> - Required - An identifier for this particular receipt handle. This is used to communicate the result. Note that the <code>Id</code> s of a batch request need to be unique within the request.</li>
* <li><code>ReceiptHandle</code> - <code>string</code> - Required - A receipt handle.</li>
* </ul></li>
* </ul>
* @param array $opt (Optional) An associative array of parameters that can have the following keys: <ul>
* <li><code>curlopts</code> - <code>array</code> - Optional - A set of values to pass directly into <code>curl_setopt()</code>, where the key is a pre-defined <code>CURLOPT_*</code> constant.</li>
* <li><code>returnCurlHandle</code> - <code>boolean</code> - Optional - A private toggle specifying that the cURL handle be returned rather than actually completing the request. This toggle is useful for manually managed batch requests.</li></ul>
* @return CFResponse A <CFResponse> object containing a parsed HTTP response.
*/
public function delete_message_batch($queue_url, $delete_message_batch_request_entry, $opt = null)
{
if (!$opt) $opt = array();
$opt['QueueUrl'] = $queue_url;
// Required list + map
$opt = array_merge($opt, CFComplexType::map(array(
'DeleteMessageBatchRequestEntry' => (is_array($delete_message_batch_request_entry) ? $delete_message_batch_request_entry : array($delete_message_batch_request_entry))
)));
return $this->authenticate('DeleteMessageBatch', $opt);
}
/**
* This action unconditionally deletes the queue specified by the queue URL. Use this operation
* WITH CARE! The queue is deleted even if it is NOT empty.
*
* Once a queue has been deleted, the queue name is unavailable for use with new queues for 60
* seconds.
*
* @param string $queue_url (Required) The URL of the SQS queue to take action on.
* @param array $opt (Optional) An associative array of parameters that can have the following keys: <ul>
* <li><code>curlopts</code> - <code>array</code> - Optional - A set of values to pass directly into <code>curl_setopt()</code>, where the key is a pre-defined <code>CURLOPT_*</code> constant.</li>
* <li><code>returnCurlHandle</code> - <code>boolean</code> - Optional - A private toggle specifying that the cURL handle be returned rather than actually completing the request. This toggle is useful for manually managed batch requests.</li></ul>
* @return CFResponse A <CFResponse> object containing a parsed HTTP response.
*/
public function delete_queue($queue_url, $opt = null)
{
if (!$opt) $opt = array();
$opt['QueueUrl'] = $queue_url;
return $this->authenticate('DeleteQueue', $opt);
}
/**
* Gets attributes for the specified queue. The following attributes are supported:
*
* <ul>
* <li><code>All</code> - returns all values.</li>
* <li><code>ApproximateNumberOfMessages</code> - returns the approximate number of visible
* messages in a queue. For more information, see Resources Required to Process Messages in
* the Amazon SQS Developer Guide.</li>
* <li><code>ApproximateNumberOfMessagesNotVisible</code> - returns the approximate number of
* messages that are not timed-out and not deleted. For more information, see Resources
* Required to Process Messages in the Amazon SQS Developer Guide.</li>
* <li><code>VisibilityTimeout</code> - returns the visibility timeout for the queue. For more
* information about visibility timeout, see Visibility Timeout in the Amazon SQS Developer
* Guide.</li>
* <li><code>CreatedTimestamp</code> - returns the time when the queue was created (epoch time in
* seconds).</li>
* <li><code>LastModifiedTimestamp</code> - returns the time when the queue was last changed
* (epoch time in seconds).</li>
* <li><code>Policy</code> - returns the queue's policy.</li>
* <li><code>MaximumMessageSize</code> - returns the limit of how many bytes a message can contain
* before Amazon SQS rejects it.</li>
* <li><code>MessageRetentionPeriod</code> - returns the number of seconds Amazon SQS retains a
* message.</li>
* <li><code>QueueArn</code> - returns the queue's Amazon resource name (ARN).</li>
* <li><code>ApproximateNumberOfMessagesDelayed</code> - returns the approximate number of
* messages that are pending to be added to the queue.</li>
* <li><code>DelaySeconds</code> - returns the default delay on the queue in seconds.</li>
* <li><code>ReceiveMessageWaitTimeSeconds</code> - returns the time for which a ReceiveMessage
* call will wait for a message to arrive.</li>
* </ul>
*
* @param string $queue_url (Required) The URL of the SQS queue to take action on.
* @param array $opt (Optional) An associative array of parameters that can have the following keys: <ul>
* <li><code>AttributeName</code> - <code>string|array</code> - Optional - A list of attributes to retrieve information for. Pass a string for a single value, or an indexed array for multiple values.</li>
* <li><code>curlopts</code> - <code>array</code> - Optional - A set of values to pass directly into <code>curl_setopt()</code>, where the key is a pre-defined <code>CURLOPT_*</code> constant.</li>
* <li><code>returnCurlHandle</code> - <code>boolean</code> - Optional - A private toggle specifying that the cURL handle be returned rather than actually completing the request. This toggle is useful for manually managed batch requests.</li></ul>
* @return CFResponse A <CFResponse> object containing a parsed HTTP response.
*/
public function get_queue_attributes($queue_url, $opt = null)
{
if (!$opt) $opt = array();
$opt['QueueUrl'] = $queue_url;
// Optional list (non-map)
if (isset($opt['AttributeName']))
{
$opt = array_merge($opt, CFComplexType::map(array(
'AttributeName' => (is_array($opt['AttributeName']) ? $opt['AttributeName'] : array($opt['AttributeName']))
)));
unset($opt['AttributeName']);
}
return $this->authenticate('GetQueueAttributes', $opt);
}
/**
* The <code>GetQueueUrl</code> action returns the URL of an existing queue.
*
* @param string $queue_name (Required) The name of the queue whose URL must be fetched.
* @param array $opt (Optional) An associative array of parameters that can have the following keys: <ul>
* <li><code>QueueOwnerAWSAccountId</code> - <code>string</code> - Optional - The AWS account number of the queue's owner.</li>
* <li><code>curlopts</code> - <code>array</code> - Optional - A set of values to pass directly into <code>curl_setopt()</code>, where the key is a pre-defined <code>CURLOPT_*</code> constant.</li>
* <li><code>returnCurlHandle</code> - <code>boolean</code> - Optional - A private toggle specifying that the cURL handle be returned rather than actually completing the request. This toggle is useful for manually managed batch requests.</li></ul>
* @return CFResponse A <CFResponse> object containing a parsed HTTP response.
*/
public function get_queue_url($queue_name, $opt = null)
{
if (!$opt) $opt = array();
$opt['QueueName'] = $queue_name;
return $this->authenticate('GetQueueUrl', $opt);
}
/**
* Returns a list of your queues.
*
* @param array $opt (Optional) An associative array of parameters that can have the following keys: <ul>
* <li><code>QueueNamePrefix</code> - <code>string</code> - Optional - A string to use for filtering the list results. Only those queues whose name begins with the specified string are returned.</li>
* <li><code>curlopts</code> - <code>array</code> - Optional - A set of values to pass directly into <code>curl_setopt()</code>, where the key is a pre-defined <code>CURLOPT_*</code> constant.</li>
* <li><code>returnCurlHandle</code> - <code>boolean</code> - Optional - A private toggle specifying that the cURL handle be returned rather than actually completing the request. This toggle is useful for manually managed batch requests.</li></ul>
* @return CFResponse A <CFResponse> object containing a parsed HTTP response.
*/
public function list_queues($opt = null)
{
if (!$opt) $opt = array();
return $this->authenticate('ListQueues', $opt);
}
/**
* Retrieves one or more messages from the specified queue, including the message body and message
* ID of each message. Messages returned by this action stay in the queue until you delete them.
* However, once a message is returned to a <code>ReceiveMessage</code> request, it is not
* returned on subsequent <code>ReceiveMessage</code> requests for the duration of the
* <code>VisibilityTimeout</code>. If you do not specify a <code>VisibilityTimeout</code> in the
* request, the overall visibility timeout for the queue is used for the returned messages.
*
* If a message is available in the queue, the call will return immediately. Otherwise, it will
* wait up to <code>WaitTimeSeconds</code> for a message to arrive. If you do not specify
* <code>WaitTimeSeconds</code> in the request, the queue attribute ReceiveMessageWaitTimeSeconds
* is used to determine how long to wait.
*
* You could ask for additional information about each message through the attributes. Attributes
* that can be requested are <code>[SenderId, ApproximateFirstReceiveTimestamp,
* ApproximateReceiveCount, SentTimestamp]</code>.
*
* @param string $queue_url (Required) The URL of the SQS queue to take action on.
* @param array $opt (Optional) An associative array of parameters that can have the following keys: <ul>
* <li><code>AttributeName</code> - <code>string|array</code> - Optional - A list of attributes that need to be returned along with each message. The set of valid attributes are [SenderId, ApproximateFirstReceiveTimestamp, ApproximateReceiveCount, SentTimestamp]. Pass a string for a single value, or an indexed array for multiple values.</li>
* <li><code>MaxNumberOfMessages</code> - <code>integer</code> - Optional - The maximum number of messages to return. Amazon SQS never returns more messages than this value but may return fewer. All of the messages are not necessarily returned.</li>
* <li><code>VisibilityTimeout</code> - <code>integer</code> - Optional - The duration (in seconds) that the received messages are hidden from subsequent retrieve requests after being retrieved by a <code>ReceiveMessage</code> request.</li>
* <li><code>WaitTimeSeconds</code> - <code>integer</code> - Optional - The duration (in seconds) for which the call will wait for a message to arrive in the queue before returning. If a message is available, the call will return sooner than WaitTimeSeconds.</li>
* <li><code>curlopts</code> - <code>array</code> - Optional - A set of values to pass directly into <code>curl_setopt()</code>, where the key is a pre-defined <code>CURLOPT_*</code> constant.</li>
* <li><code>returnCurlHandle</code> - <code>boolean</code> - Optional - A private toggle specifying that the cURL handle be returned rather than actually completing the request. This toggle is useful for manually managed batch requests.</li></ul>
* @return CFResponse A <CFResponse> object containing a parsed HTTP response.
*/
public function receive_message($queue_url, $opt = null)
{
if (!$opt) $opt = array();
$opt['QueueUrl'] = $queue_url;
// Optional list (non-map)
if (isset($opt['AttributeName']))
{
$opt = array_merge($opt, CFComplexType::map(array(
'AttributeName' => (is_array($opt['AttributeName']) ? $opt['AttributeName'] : array($opt['AttributeName']))
)));
unset($opt['AttributeName']);
}
return $this->authenticate('ReceiveMessage', $opt);
}
/**
* The <code>RemovePermission</code> action revokes any permissions in the queue policy that
* matches the specified <code>Label</code> parameter. Only the owner of the queue can remove
* permissions.
*
* @param string $queue_url (Required) The URL of the SQS queue to take action on.
* @param string $label (Required) The identification of the permission to remove. This is the label added with the <code>AddPermission</code> operation.
* @param array $opt (Optional) An associative array of parameters that can have the following keys: <ul>
* <li><code>curlopts</code> - <code>array</code> - Optional - A set of values to pass directly into <code>curl_setopt()</code>, where the key is a pre-defined <code>CURLOPT_*</code> constant.</li>
* <li><code>returnCurlHandle</code> - <code>boolean</code> - Optional - A private toggle specifying that the cURL handle be returned rather than actually completing the request. This toggle is useful for manually managed batch requests.</li></ul>
* @return CFResponse A <CFResponse> object containing a parsed HTTP response.
*/
public function remove_permission($queue_url, $label, $opt = null)
{
if (!$opt) $opt = array();
$opt['QueueUrl'] = $queue_url;
$opt['Label'] = $label;
return $this->authenticate('RemovePermission', $opt);
}
/**
* The <code>SendMessage</code> action delivers a message to the specified queue.
*
* @param string $queue_url (Required) The URL of the SQS queue to take action on.
* @param string $message_body (Required) The message to send.
* @param array $opt (Optional) An associative array of parameters that can have the following keys: <ul>
* <li><code>DelaySeconds</code> - <code>integer</code> - Optional - The number of seconds the message has to be delayed.</li>
* <li><code>curlopts</code> - <code>array</code> - Optional - A set of values to pass directly into <code>curl_setopt()</code>, where the key is a pre-defined <code>CURLOPT_*</code> constant.</li>
* <li><code>returnCurlHandle</code> - <code>boolean</code> - Optional - A private toggle specifying that the cURL handle be returned rather than actually completing the request. This toggle is useful for manually managed batch requests.</li></ul>
* @return CFResponse A <CFResponse> object containing a parsed HTTP response.
*/
public function send_message($queue_url, $message_body, $opt = null)
{
if (!$opt) $opt = array();
$opt['QueueUrl'] = $queue_url;
$opt['MessageBody'] = $message_body;
return $this->authenticate('SendMessage', $opt);
}
/**
* This is a batch version of <code>SendMessage</code>. It takes multiple messages and adds each
* of them to the queue. The result of each add operation is reported individually in the
* response.
*
* @param string $queue_url (Required) The URL of the SQS queue to take action on.
* @param array $send_message_batch_request_entry (Required) A list of <code>SendMessageBatchRequestEntry</code> s. <ul>
* <li><code>x</code> - <code>array</code> - Optional - This represents a simple array index. <ul>
* <li><code>Id</code> - <code>string</code> - Required - An identifier for the message in this batch. This is used to communicate the result. Note that the the <code>Id</code> s of a batch request need to be unique within the request.</li>
* <li><code>MessageBody</code> - <code>string</code> - Required - Body of the message.</li>
* <li><code>DelaySeconds</code> - <code>integer</code> - Optional - The number of seconds for which the message has to be delayed.</li>
* </ul></li>
* </ul>
* @param array $opt (Optional) An associative array of parameters that can have the following keys: <ul>
* <li><code>curlopts</code> - <code>array</code> - Optional - A set of values to pass directly into <code>curl_setopt()</code>, where the key is a pre-defined <code>CURLOPT_*</code> constant.</li>
* <li><code>returnCurlHandle</code> - <code>boolean</code> - Optional - A private toggle specifying that the cURL handle be returned rather than actually completing the request. This toggle is useful for manually managed batch requests.</li></ul>
* @return CFResponse A <CFResponse> object containing a parsed HTTP response.
*/
public function send_message_batch($queue_url, $send_message_batch_request_entry, $opt = null)
{
if (!$opt) $opt = array();
$opt['QueueUrl'] = $queue_url;
// Required list + map
$opt = array_merge($opt, CFComplexType::map(array(
'SendMessageBatchRequestEntry' => (is_array($send_message_batch_request_entry) ? $send_message_batch_request_entry : array($send_message_batch_request_entry))
)));
return $this->authenticate('SendMessageBatch', $opt);
}
/**
* Sets the value of one or more queue attributes. Valid attributes that can be set are
* [VisibilityTimeout, Policy, MaximumMessageSize, MessageRetentionPeriod,
* ReceiveMessageWaitTimeSeconds].
*
* @param string $queue_url (Required) The URL of the SQS queue to take action on.
* @param array $attribute (Required) A map of attributes to set. <ul>
* <li><code>x</code> - <code>array</code> - Optional - This represents a simple array index. <ul>
* <li><code>Name</code> - <code>string</code> - Optional - The name of a queue attribute. [Allowed values: <code>Policy</code>, <code>VisibilityTimeout</code>, <code>MaximumMessageSize</code>, <code>MessageRetentionPeriod</code>, <code>ApproximateNumberOfMessages</code>, <code>ApproximateNumberOfMessagesNotVisible</code>, <code>CreatedTimestamp</code>, <code>LastModifiedTimestamp</code>, <code>QueueArn</code>, <code>ApproximateNumberOfMessagesDelayed</code>, <code>DelaySeconds</code>, <code>ReceiveMessageWaitTimeSeconds</code>]</li>
* <li><code>Value</code> - <code>string</code> - Optional - The value of a queue attribute.</li>
* </ul></li>
* </ul>
* @param array $opt (Optional) An associative array of parameters that can have the following keys: <ul>
* <li><code>curlopts</code> - <code>array</code> - Optional - A set of values to pass directly into <code>curl_setopt()</code>, where the key is a pre-defined <code>CURLOPT_*</code> constant.</li>
* <li><code>returnCurlHandle</code> - <code>boolean</code> - Optional - A private toggle specifying that the cURL handle be returned rather than actually completing the request. This toggle is useful for manually managed batch requests.</li></ul>
* @return CFResponse A <CFResponse> object containing a parsed HTTP response.
*/
public function set_queue_attributes($queue_url, $attribute, $opt = null)
{
if (!$opt) $opt = array();
$opt['QueueUrl'] = $queue_url;
// Required map (non-list)
$opt = array_merge($opt, CFComplexType::map(array(
'Attribute' => (is_array($attribute) ? $attribute : array($attribute))
)));
return $this->authenticate('SetQueueAttributes', $opt);
}
}
/*%******************************************************************************************%*/
// EXCEPTIONS
class SQS_Exception extends Exception {}