'The remote has caught up after we started buffering!'

def resumeProducing(self):

    logger.info('[%s]    Resume    producing', self.id())
    self.state = ConnectionStates.ESTABLISHED
    self._send_pending_commands()
