def __init__(self, user, token, queue, upload_size=<NUM_LIT:100>, on_error=None):
Thread.__init__(self)<EOL>self.api = librato.connect(user, token)<EOL>self.daemon = True  <EOL>self.upload_size = upload_size<EOL>self.on_error = on_error<EOL>self.queue = queue<EOL>self.retries = <NUM_LIT:3><EOL>
Create a consumer thread.