def __init__(self,host,port):
    self.host = host
    self.port = int(port)
    self.simpleName = ("%s_%d" % (self.host,self.port)).replace('.','_')
    self.factory = PypeConnectionFactory(self)
    self.client = internet.TCPClient(self.host, self.port, self.factory)
    self.consumedMessages = 0
    self.logicalMessages = 0
dataset/ETHPy150Open tmm1/graphite/misc/carbon-relay/pyped.py/PypeConsumer.__init__/original