jdornbusch/queue-adapters

Module that wraps the zend-queue library allowing access via the service manager

dev-master 2014-04-26 06:26 UTC

Requires

• php: >=5.3.3
• zendframework/zend-queue: master
• zendframework/zendframework: 2.2.*

GPL-3.0+

• joachimdo

README

This module only provides factories to give access to the queueing functionalities via Zend Service Manager. For now, it is limited to Activemq.

Installation

Just add QueueAdapters to the listed module names, rename and copy the module.queue-adapters.local.php.dist to your application config autoload directory and fill it, e.g. :

return array (
		"queue-adapters" => array(
				//inform the controller plugin, 
				// "default" =>"activemq",
				"activemq" => array (
						//"host" => "127.0.0.1",
						//"port" => "61613",
						// "scheme" => "tcp",
						
				)
		)

);

Usage

An instance of ZendQueue\Queue with the ActivMQ adapter is now available :

• either as a service

$service = $this->getServiceLocator()->get("activemq");
//write to queue
$service->createQueue("test");
$service->send("Hello World n°1");
//read from queue
$iterator=$service->receive();
$current=$iterator->current();

• or as a plugin manager if you want to access it from a Controller

//write to queue
$this->queue()->createQueue("test");
$this->queue()->send("Hello World n°1");
//read from queue
$iterator=$this->queue()->receive();
$current=$iterator->current();