Zend_Queue_Adapter_Phpredisを作りました

Zend_QueueでRedisを使いたくなったので、Zend_Queue_Adapter_Phpredis作りました。
まあほぼmemcacheqのアダプターと構成は同じですがcountとかもちゃんとサポートできている感じです。

まあちゃんとテストも書いてないのでバグがあるかもしれませんが、良かったら使ってみてください。

ちなみにZend_Queue_Adapter_Phpredisの使用例はこんな感じです。

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28


<?php
require_once 'Zend/Loader/Autoloader.php';
$autoloader = Zend_Loader_Autoloader::getInstance();

try {
	$queue = new Zend_Queue('Phpredis',array(
		'name' => 'test_queue',
		'driverOptions' => array(
			'host' => '127.0.0.1', // default 127.0.0.1
			'port' => 6379,			// default 6379
		),
	));


	// send message
	$queue->send('job 1');
	$queue->send('job 2');
	echo "send end\n\n";

	// get message
	$messages = $queue->receive(3);
	foreach ( $messages as $message ) {
		echo $message->body . "\n";
	}

} catch ( Zend_Queue_Exception $e ) {
	echo $e->getMessage();
}