connect($host)){ $redis->select(0); while(true){ $msg = $redis->brPop('queue',0); $myfile = fopen("/log/message_queue.log", "a"); if(!$myfile){ $newFile = '/log/'.time().'.log'; $myfile = fopen($newFile,"a"); } $txt = json_encode($msg)."\n"; fwrite($myfile, $txt); } }else{ echo 'unable to connect'; }