Para instanciar un adaptador de QueueService, use el método estático Zend_Cloud_QueueService_Factory::getAdapter(), que acepta un array o un objeto Zend_Config. Tres parámetros se aplican a todos los adaptadores, mientras que el resto de parámetros son propiedades específicas del adaptador; estas propiedades específicas del adaptador a menudo contienen detalles de acceso.

Los parámetros generales son los siguientes:

$queues = Zend_Cloud_QueueService_Factory::getAdapter(array(
    Zend_Cloud_QueueService_Factory::QUEUE_ADAPTER_KEY  => 'Zend_Cloud_QueueService_Adapter_Sqs',
    Zend_Cloud_QueueService_Adapter_Sqs::AWS_ACCESS_KEY => $amazonKey,
    Zend_Cloud_QueueService_Adapter_Sqs::AWS_SECRET_KEY => $amazonSecret,
));

Cada servicio de colas normalmente ofrece una o más colas. Cada cola puede almacenar cero o más mensajes. Un proceso puede enviar un mensaje a una cola, y otro proceso puede eliminarlo. Habitualmente los procesos eliminan el mensaje más antiguo de la cola, siguiendo una interfaz de cola de tipo primero en entrar, primero en salir (FIFO).

Si ocurre algún error dentro del servicio de almacenamiento, se lanza una Zend_Cloud_QueueService_Exception. Si la excepción fue causada por el driver del servicio subyacente, puede usar el método getClientException() para recuperar la excepción original.

Dado que los distintos proveedores de nube implementan diferentes conjuntos de servicios, algunos adaptadores no implementan ciertas funcionalidades. En este caso, se lanza la excepción Zend_Cloud_OperationNotAvailableException.

El método createQueue() crea una cola de mensajes con el nombre indicado. Devuelve un identificador de cola, cuyo formato depende del servicio. Algunos servicios devuelven una URL como identificador de cola, mientras que otros devuelven un GUID a usar en operaciones futuras.

$queueId = $queues->createQueue('my-queue');

El método deleteQueue() elimina la cola del servicio. Debe usar el identificador recibido de createQueue() al llamar a deleteQueue().

$queueId = $queues->createQueue('my-queue');

// ... haga otras cosas ...

$queues->deleteQueue($queueId);

	Nota
	Eliminar una cola puede tardar bastante tiempo en algunos servicios. Normalmente, no puede volver a crear una cola con el mismo nombre hasta que la cola original se haya eliminado por completo.

Para recuperar la lista de todas las colas del sistema, use el método listQueues().

$names = $queues->listQueues();
foreach ($names as $name) {
    echo "Found queue $name\n";
}

En algunos servicios, puede asociar un conjunto de pares clave-valor a la cola como metadatos de la cola. Para establecer los metadatos de la cola, use el método storeQueueMetadata():

$queues->storeQueueMetadata($queueId, array(
    'purpose'       => 'Operations',
    'administrator' => 'joe@example.com',
));

Para recuperar los metadatos de la cola, use el método fetchQueueMetadata().

$metadata = $queues->fetchQueueMetadata($queueId);
foreac h($metadata as $key => $value) {
    echo "Metadata $key: $value\n";
}

Para añadir un mensaje a una cola, use el método sendMessage(). El mensaje se pasa como una cadena sin estructurar.

$queues->sendMessage($queueId, "Hello world!");

Para recibir uno o más mensajes de la cola, use el método receiveMessages(). Este método devuelve por defecto una instancia de Zend_Cloud_QueueService_MessageSet, a menos que se configure de otra forma. Cada elemento del MessageSet es, por defecto, una instancia de Zend_Cloud_QueueService_Message, a menos que se configure de otra forma.

// Get the first message
$messages = $queues->receiveMessages($queueId);
if (count($messages)) {
    foreach ($messages as $message) {
        echo "Message: " . $message->getBody();
        break;
    }
}

// Get two messages
$messages = $queues->receiveMessages($queueId, 2);

Cuando se recibe un mensaje, no es visible para otros clientes. Sin embargo, no se elimina de la cola hasta que el cliente que ha recibido el mensaje llama al método deleteMessage(). Si no se elimina durante el tiempo de espera de visibilidad especificado, volverá a ser visible para el resto de clientes. En otras palabras, todos los clientes podrán recuperar el mensaje con el método receiveMessages() si se supera el tiempo de espera de visibilidad.

Para eliminar el mensaje de la cola, use el método deleteMessage(). Este método elimina el mensaje especificado.

// process and delete $max messages
$messages = $queues->receiveMessages($queueId, $max);
if (count($messages)) {
    foreach ($messages as $message) {
        process($message);
        $queues->deleteMessage($queueId, $message);
    }
}

En ocasiones es necesario recuperar el adaptador concreto del servicio con el que trabaja la Queue API. Esto se puede lograr usando el método getAdapter().

	Nota
	Acceder al adaptador subyacente rompe la portabilidad entre servicios, por lo que debería reservarse únicamente para circunstancias excepcionales.

// send the message directly with the SQS client library
$sqs = $queues->getAdapter();
$sqs->sendMessage("myQueue", "hello!");