#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Author  : <NAME>
# @Email   : <EMAIL>
# @File    : output.py
# @Time    : 18/07/15 9:42

from rqueue import RedisQueue
import time

def routput():
    q = RedisQueue('test', host='172.16.31.10', password='<PASSWORD>', port=6379, db=0)
    while 1:
        result = q.get_nowait()
        if not result:
            break
        print("output.py: data {} out of queue {}".format(result, time.strftime("%c")))
        time.sleep(0.01)


