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.

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 Member Functions
	_initDbAdapter ()
	Initialize Db adapter using 'driverOptions' section of the _options array.

	getQueueId ($name)
	Get the queue ID.

Protected Attributes
	$_queueTable = null

	$_messageTable = null

	$_messageRow = null

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

_initDbAdapter ( )

protected

Initialize Db adapter using 'driverOptions' section of the _options array.

Throws an exception if the adapter cannot connect to DB.

Returns: Zend_Db_Adapter_Abstract

Exceptions

Zend_Queue_Exception

count ( Zend_Queue $queue = null )

Return the approximate number of messages in the queue.

Parameters

Zend_Queue $queue

Returns: integer

Exceptions

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	$name	queue name
integer	$timeout	default visibility timeout

Returns: boolean

Exceptions

Zend_Queue_Exception - database error

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 $name queue name

Returns: boolean

Exceptions

Zend_Queue_Exception - database error

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 - database error

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.

getQueueId ( $name )

protected

Get the queue ID.

Returns the queue's row identifier.

Parameters

string $name

Returns: integer|null

Exceptions

Zend_Queue_Exception

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