Zend Framework  1.12
Public Member Functions | Protected Attributes | List of all members
Zend_Queue_Adapter_Array Class Reference

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 it's 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.
 
 getCapabilities ()
 Return a list of queue capabilities functions.
 
 __sleep ()
 serialize
 
 getData ()
 returns underlying _data array $queue->getAdapter()->getData();
 
 setData ($data)
 sets the underlying _data array $queue->getAdapter()->setData($data);
 
- Public Member Functions inherited from Zend_Queue_Adapter_AdapterAbstract
 __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

 $_data = array()
 
- Protected Attributes inherited from Zend_Queue_Adapter_AdapterAbstract
 $_options = array()
 
 $_queues = array()
 
 $_queue = null
 

Additional Inherited Members

- Public Attributes inherited from Zend_Queue_Adapter_AdapterAbstract
const CREATE_TIMEOUT_DEFAULT = 30
 Default timeout for createQueue() function.
 
const RECEIVE_TIMEOUT_DEFAULT = 30
 Default timeout for recieve() function.
 

Constructor & Destructor Documentation

__construct (   $options,
Zend_Queue  $queue = null 
)

Constructor.

Parameters
array | Zend_Config$options
Zend_Queue | null$queue
Returns
void

Implements Zend_Queue_Adapter_AdapterInterface.

Member Function Documentation

__sleep ( )

serialize

count ( Zend_Queue  $queue = null)

Return the approximate number of messages in the queue.

Parameters
Zend_Queue$queue
Returns
integer
Exceptions
Zend_Queue_Exception
See Also
Zend_Queue_Exception

Implements Zend_Queue_Adapter_AdapterInterface.

create (   $name,
  $timeout = null 
)

Create a new queue.

Visibility timeout is how long a message is left in the queue "invisible" to other readers. If the message is acknowleged (deleted) before the timeout, then the message is deleted. However, if the timeout expires then the message will be made available to other queue readers.

Parameters
string$namequeue name
integer$timeoutdefault visibility timeout
Returns
boolean

Implements Zend_Queue_Adapter_AdapterInterface.

delete (   $name)

Delete a queue and all of it's messages.

Returns false if the queue is not found, true if the queue exists

Parameters
string$namequeue name
Returns
boolean

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.

Parameters
Zend_Queue_Message$message
Returns
boolean
Exceptions
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.

Parameters
string$name
Returns
array

Implements Zend_Queue_Adapter_AdapterInterface.

getData ( )

returns underlying _data array $queue->getAdapter()->getData();

Returns
$this;
getQueues ( )

Get an array of all available queues.

Not all adapters support getQueues(), use isSupported('getQueues') to determine if the adapter supports this feature.

Returns
array

Implements Zend_Queue_Adapter_AdapterInterface.

isExists (   $name)

Does a queue already exist?

Throws an exception if the adapter cannot determine if a queue exists. use isSupported('isExists') to determine if an adapter can test for queue existance.

Parameters
string$name
Returns
boolean

Implements Zend_Queue_Adapter_AdapterInterface.

receive (   $maxMessages = null,
  $timeout = null,
Zend_Queue  $queue = null 
)

Get messages in the queue.

Parameters
integer$maxMessagesMaximum number of messages to return
integer$timeoutVisibility timeout for these messages
Zend_Queue$queue
Returns
Zend_Queue_Message_Iterator

Implements Zend_Queue_Adapter_AdapterInterface.

send (   $message,
Zend_Queue  $queue = null 
)

Send a message to the queue.

Parameters
string$messageMessage to send to the active queue
Zend_Queue$queue
Returns
Zend_Queue_Message
Exceptions
Zend_Queue_Exception

Implements Zend_Queue_Adapter_AdapterInterface.

setData (   $data)

sets the underlying _data array $queue->getAdapter()->setData($data);

Parameters
array$data
Returns
$this;

Member Data Documentation

$_data = array()
protected