Zend Framework
1.12
|
Public Member Functions | |
__construct ($options, Zend_Queue $queue=null) | |
Constructor. | |
isExists ($name) | |
Does a queue already exist? | |
create ($name, $timeout=null) | |
Create a new queue. | |
delete ($name) | |
Delete a queue and all of its messages. | |
getQueues () | |
Get an array of all available queues. | |
count (Zend_Queue $queue=null) | |
Return the approximate number of messages in the queue. | |
send ($message, Zend_Queue $queue=null) | |
Send a message to the queue. | |
receive ($maxMessages=null, $timeout=null, Zend_Queue $queue=null) | |
Get messages in the queue. | |
deleteMessage (Zend_Queue_Message $message) | |
Delete a message from the queue. | |
isJobIdExist ($id) | |
getCapabilities () | |
Return a list of queue capabilities functions. | |
__sleep () | |
Serialize. | |
__wakeup () | |
Unserialize. | |
![]() | |
__construct ($options, Zend_Queue $queue=null) | |
Constructor. | |
getQueue () | |
get the Zend_Queue class that is attached to this object | |
setQueue (Zend_Queue $queue) | |
set the Zend_Queue class for this object | |
getOptions () | |
Returns the configuration options in this adapter. | |
isSupported ($name) | |
Indicates if a function is supported or not. | |
Protected Attributes | |
$_zendQueue | |
![]() | |
$_options = array() | |
$_queues = array() | |
$_queue = null | |
Additional Inherited Members | |
![]() | |
const | CREATE_TIMEOUT_DEFAULT = 30 |
Default timeout for createQueue() function. | |
const | RECEIVE_TIMEOUT_DEFAULT = 30 |
Default timeout for recieve() function. | |
__construct | ( | $options, | |
Zend_Queue | $queue = null |
||
) |
Constructor.
array | Zend_Config | $options | |
Zend_Queue | null | $queue |
Implements Zend_Queue_Adapter_AdapterInterface.
__sleep | ( | ) |
Serialize.
__wakeup | ( | ) |
Unserialize.
count | ( | Zend_Queue | $queue = null | ) |
Return the approximate number of messages in the queue.
Zend_Queue | null | $queue |
Implements Zend_Queue_Adapter_AdapterInterface.
create | ( | $name, | |
$timeout = null |
|||
) |
Create a new queue.
string | $name | queue name |
integer | $timeout | default visibility timeout |
Zend_Queue_Exception |
Implements Zend_Queue_Adapter_AdapterInterface.
delete | ( | $name | ) |
Delete a queue and all of its messages.
string | $name | queue name |
Zend_Queue_Exception |
Implements Zend_Queue_Adapter_AdapterInterface.
deleteMessage | ( | Zend_Queue_Message | $message | ) |
Delete a message from the queue.
Returns true if the message is deleted, false if the deletion is unsuccessful.
Zend_Queue_Message | $message |
Zend_Queue_Exception |
Implements Zend_Queue_Adapter_AdapterInterface.
getCapabilities | ( | ) |
Return a list of queue capabilities functions.
$array['function name'] = true or false true is supported, false is not supported.
string | $name |
Implements Zend_Queue_Adapter_AdapterInterface.
getQueues | ( | ) |
Get an array of all available queues.
Zend_Queue_Exception |
Implements Zend_Queue_Adapter_AdapterInterface.
isExists | ( | $name | ) |
Does a queue already exist?
string | $name |
Zend_Queue_Exception | (not supported) |
Implements Zend_Queue_Adapter_AdapterInterface.
isJobIdExist | ( | $id | ) |
receive | ( | $maxMessages = null , |
|
$timeout = null , |
|||
Zend_Queue | $queue = null |
||
) |
Get messages in the queue.
integer | $maxMessages | Maximum number of messages to return |
integer | $timeout | Ignored |
Zend_Queue | $queue | Not supported |
Zend_Queue_Exception |
Implements Zend_Queue_Adapter_AdapterInterface.
send | ( | $message, | |
Zend_Queue | $queue = null |
||
) |
Send a message to the queue.
array | ZendAPI_job | $message | Message to send to the active queue |
Zend_Queue | $queue | Not supported |
Zend_Queue_Exception |
Implements Zend_Queue_Adapter_AdapterInterface.
|
protected |