gistfile1.py

def on_receive(self, response_chunk):
        self.response_object += str(response_chunk).strip()
        if response_chunk.endswith("\r\n") and self.response_object.strip():
            try:
                adn_object = self.response_object.strip()
                self.publish_message(adn_object)
            except Exception as e:
                text = "on_receive error {}".format(e)
                print text
                log.error(text)
            except:
                print "on_receive unknown exception"
                log.error("on_receive unknown exception")
            finally:
                self.response_object = ""