jdornbusch/queue-adapters

一个模块，封装了zend-queue库，允许通过服务管理器访问

维护者

详细信息

github.com/joachimdo/zf2-queueing-factory-module

源代码

问题

安装: 32

依赖: 0

建议者: 0

安全: 0

星星: 0

关注者: 0

分支: 0

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

Requires

GPL-3.0+ 8ba2cfe8c072af0265f3c3cf626fd21f046a5abe

  • joachimdo <dornbusch.woop@free.fr>

This package is not auto-updated.

Last update: 2024-09-28 15:59:55 UTC

README

此模块仅提供工厂，以便通过Zend服务管理器访问队列功能。目前，它仅限于Activemq。

安装

只需将QueueAdapters添加到列表中的模块名称中，将module.queue-adapters.local.php.dist重命名为您的应用程序配置autoload目录，并填写它，例如

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

);

使用方法

现在有一个带有ActivMQ适配器的ZendQueue\Queue实例可用

  • 作为服务
$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();
  • 或者作为插件管理器，如果您想从控制器访问它
//write to queue
$this->queue()->createQueue("test");
$this->queue()->send("Hello World n°1");
//read from queue
$iterator=$this->queue()->receive();
$current=$iterator->current();