Interface for common queue operations

category Zend
package Zend_Queue
subpackage Adapter
copyright Copyright (c) 2005-2015 Zend Technologies USA Inc. (http://www.zend.com)
license New BSD License

 Methods

Constructor

__construct(array|\Zend_Config $options, \Zend_Queue $queue = null) : void

Parameters

$options

array\Zend_Config

$queue

\Zend_Queue

Return the approximate number of messages in the queue

count(\Zend_Queue|null $queue = null) : integer

Parameters

$queue

\Zend_Queuenull

Returns

integer

Create a new queue

create(string $name, integer $timeout = null) : boolean

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

$name

string

Queue name

$timeout

integer

Default visibility timeout

Returns

boolean

Delete a queue and all of its messages

delete(string $name) : boolean

Return false if the queue is not found, true if the queue exists.

Parameters

$name

string

Queue name

Returns

boolean

Delete a message from the queue

deleteMessage(\Zend_Queue_Message $message) : boolean

Return true if the message is deleted, false if the deletion is unsuccessful.

Parameters

$message

\Zend_Queue_Message

Returns

boolean

Return a list of queue capabilities functions

getCapabilities() : array

$array['function name'] = true or false true is supported, false is not supported.

Returns

array

Returns the configuration options in this adapter.

getOptions() : array

Returns

array

Retrieve queue instance

getQueue() : \Zend_Queue

Returns

\Zend_Queue

Get an array of all available queues

getQueues() : array

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

Returns

array

Does a queue already exist?

isExists(string $name) : boolean

Use isSupported('isExists') to determine if an adapter can test for queue existance.

Parameters

$name

string

Queue name

Returns

boolean

Indicates if a function is supported or not.

isSupported(string $name) : boolean

Parameters

$name

string

Function name

Returns

boolean

Get messages in the queue

receive(integer|null $maxMessages = null, integer|null $timeout = null, \Zend_Queue|null $queue = null) : \Zend_Queue_Message_Iterator

Parameters

$maxMessages

integernull

Maximum number of messages to return

$timeout

integernull

Visibility timeout for these messages

$queue

\Zend_Queuenull

Returns

\Zend_Queue_Message_Iterator

Send a message to the queue

send(mixed $message, \Zend_Queue|null $queue = null) : \Zend_Queue_Message

Parameters

$message

mixed

Message to send to the active queue

$queue

\Zend_Queuenull

Returns

\Zend_Queue_Message

Set queue instnace

setQueue(\Zend_Queue $queue) : \Zend_Queue_Adapter_AdapterInterface

Parameters

$queue

\Zend_Queue

Returns

\Zend_Queue_Adapter_AdapterInterface