if (file.getName().endsWith(".pbf")) {
        pbf = true;
    } else if (file.getName().endsWith(".gz")) {
        compression = CompressionMethod.GZip;
    } else if (file.getName().endsWith(".bz2")) {
        compression = CompressionMethod.BZip2;
    }

    RunnableSource reader;
    FileInputStream fis = null;
    if (pbf) {
        fis = new FileInputStream(file);
        reader = new crosby.binary.osmosis.OsmosisReader(
            fis);
    } else {
        reader = new XmlReader(file, false, compression);
    }


    reader.setSink(this);

    System.out.println("starting import");
    Thread readerThread = new Thread(reader);
    readerThread.setUncaughtExceptionHandler(new Thread.UncaughtExceptionHandler() {
        Override
        public void uncaughtException(Thread thread, Throwable throwable) {
            System.out.println("import failed!");
            throwable.printStackTrace();

        }
    });
    readerThread.start();

    while (readerThread.isAlive()) {
        try {
            readerThread.join();
        } catch (InterruptedException e) {
    /* do nothing */
        }
    }