sokil/redis.queue.consumer.php

## redis.queue.consumer.php
<?php

$client = new \Predis\Client([
    'read_write_timeout'    => 0,
]);

while(true) {
    $message = $client->blpop('queue1', 0);
}

## redis.queue.producer.php
<?php

$client = new \Predis\Client();
$client->rpush('queue1', 'message ' . time());
	<?php

	$client = new \Predis\Client([
	'read_write_timeout' => 0,
	]);

	while(true) {
	$message = $client->blpop('queue1', 0);
	}
	<?php

	$client = new \Predis\Client();
	$client->rpush('queue1', 'message ' . time());