API Documentation

Zend/Queue/Adapter/Memcacheq.php

Show: inherited
Table of Contents

Zend Framework

LICENSE

This source file is subject to the new BSD license that is bundled with this package in the file LICENSE.txt. It is also available through the world-wide-web at this URL: http://framework.zend.com/license/new-bsd If you did not receive a copy of the license and are unable to obtain it through the world-wide-web, please send an email to license@zend.com so we can send you a copy immediately.

Category
Zend  
Copyright
Copyright (c) 2005-2012 Zend Technologies USA Inc. (http://www.zend.com)  
License
New BSD License  
Package
Zend_Queue  
Subpackage
Adapter  
Version
$Id: Memcacheq.php 24594 2012-01-05 21:27:01Z matthew $  

\Zend_Queue_Adapter_Memcacheq

Package: Zend\Queue\Adapter

Class for using connecting to a Zend_Cache-based queuing system

Parent(s)
\Zend_Queue_Adapter_AdapterAbstract
Category
Zend  
Copyright
Copyright (c) 2005-2012 Zend Technologies USA Inc. (http://www.zend.com)  
License
New BSD License  

Constants

Constant  DEFAULT_HOST = '127.0.0.1'
Constant  DEFAULT_PORT = 22201
Constant  EOL = "\r\n"

Properties

Propertyprotected\Memcache  $_cache= 'null'

Default valuenullDetails
Type
\Memcache
Propertyprotectedstring  $_host= 'null'

Default valuenullDetails
Type
string
Propertyprotectedinteger  $_port= 'null'

Default valuenullDetails
Type
integer
Propertyprotectedresource  $_socket= 'null'

Default valuenullDetails
Type
resource

Methods

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

Constructor

Parameters
Name Type Description
$options array|\Zend_Config
$queue null|\Zend_Queue
methodpublic__destruct( ) : void

Destructor

methodprotected_sendCommand( string $command, array $terminator, boolean $include_term = false ) : array

sends a command to MemcacheQ

The memcache functions by php cannot handle all types of requests supported by MemcacheQ Non-standard requests are handled by this function.

Parameters
Name Type Description
$command string
  • command to send to memcacheQ
$terminator array
  • strings to indicate end of memcacheQ response
$include_term boolean
  • include terminator in response
Returns
Type Description
array
Throws
Exception Description
\Zend_Queue_Exception if connection cannot be opened
methodpubliccount( \Zend_Queue $queue = null ) : integer

Return the approximate number of messages in the queue

Parameters
Name Type Description
$queue \Zend_Queue
Returns
Type Description
integer
Throws
Exception Description
\Zend_Queue_Exception (not supported)
methodpubliccreate( string $name, integer $timeout = null ) : boolean

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
Name Type Description
$name string

queue name

$timeout integer

default visibility timeout

Returns
Type Description
boolean
Throws
Exception Description
\Zend_Queue_Exception
methodpublicdelete( string $name ) : boolean

Delete a queue and all of it's messages

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

Parameters
Name Type Description
$name string

queue name

Returns
Type Description
boolean
Throws
Exception Description
\Zend_Queue_Exception
methodpublicdeleteMessage( \Zend_Queue_Message $message ) : boolean

Delete a message from the queue

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

Parameters
Name Type Description
$message \Zend_Queue_Message
Returns
Type Description
boolean
Throws
Exception Description
\Zend_Queue_Exception (unsupported)
methodpublicgetCapabilities( ) : array

Return a list of queue capabilities functions

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

Returns
Type Description
array
methodpublicgetQueues( ) : array

Get an array of all available queues

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

Returns
Type Description
array
Throws
Exception Description
\Zend_Queue_Exception
methodpublicisExists( string $name ) : boolean

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
Name Type Description
$name string
Returns
Type Description
boolean
Throws
Exception Description
\Zend_Queue_Exception
methodpublicreceive( integer $maxMessages = null, integer $timeout = null, \Zend_Queue $queue = null ) : \Zend_Queue_Message_Iterator

Get messages in the queue

Parameters
Name Type Description
$maxMessages integer

Maximum number of messages to return

$timeout integer

Visibility timeout for these messages

$queue \Zend_Queue
Returns
Type Description
\Zend_Queue_Message_Iterator
Throws
Exception Description
\Zend_Queue_Exception
methodpublicsend( string $message, \Zend_Queue $queue = null ) : \Zend_Queue_Message

Send a message to the queue

Parameters
Name Type Description
$message string

Message to send to the active queue

$queue \Zend_Queue
Returns
Type Description
\Zend_Queue_Message
Throws
Exception Description
\Zend_Queue_Exception
Documentation was generated by DocBlox 0.15.1.