SQS adapter for simple queue service.
Provides functionality around setting message and message set classes.
category | Zend |
---|---|
package | Zend_Cloud |
subpackage | QueueService |
copyright | Copyright (c) 2005-2015 Zend Technologies USA Inc. (http://www.zend.com) |
license | New BSD License |
inherited_from | \Zend_Cloud_QueueService_Adapter_AbstractAdapter |
__construct(array|\Zend_Config $options = array()
) : void
array
\Zend_Config
createQueue(string $name, array $options = null
) : string
It may take some time to create the queue. Check your vendor's documentation for details.
string
array
string
Queue ID (typically URL)deleteMessage(string $queueId, \Zend_Cloud_QueueService_Message $message, array $options = null
) : void
string
\Zend_Cloud_QueueService_Message
array
deleteQueue(string $queueId, array $options = null
) : boolean
string
array
boolean
true if successful, false otherwisefetchQueueMetadata(string $queueId, array $options = null
) : array
string
array
array
getClient() : \Zend_Service_Amazon_Sqs
\Zend_Service_Amazon_Sqs
getMessageClass() : string
string
getMessageSetClass() : string
string
listQueues(array $options = null
) : array
array
array
Queue IDspeekMessages(string $queueId, integer $num= 1
, array $options= null
) : array<mixed,\Zend_Cloud_QueueService_Message>
string
integer
How many messages
array
array<mixed,\Zend_Cloud_QueueService_Message>
receiveMessages(string $queueId, integer $max= 1
, array $options= null
) : array
string
integer
array
array
sendMessage(string $queueId, string $message, array $options = null
) : string
string
string
array
string
Message IDsetMessageClass(string $class) : \Zend_Cloud_QueueService_Adapter_AbstractAdapter
string
\Zend_Cloud_QueueService_Adapter_AbstractAdapter
setMessageSetClass(string $class) : \Zend_Cloud_QueueService_Adapter_AbstractAdapter
string
\Zend_Cloud_QueueService_Adapter_AbstractAdapter
storeQueueMetadata(string $queueId, array $metadata, array $options = null
) : void
WARNING: This operation overwrites any metadata that is located at $destinationPath. Some adapters may not support this method.
string
array
array
_makeMessages(array $messages) : array<mixed,\Zend_Cloud_QueueService_Message>
array
array<mixed,\Zend_Cloud_QueueService_Message>
$_sqs : \Zend_Service_Amazon_Sqs
AWS_ACCESS_KEY = 'aws_accesskey'
AWS_SECRET_KEY = 'aws_secretkey'
CREATE_TIMEOUT = 30
MESSAGESET_CLASS = 'messageset_class'
MESSAGE_CLASS = 'message_class'