EDIT

import java.io.InputStream;

import java.nio.file.Files;

import java.nio.file.Path;

import java.nio.file.Paths;

import org.apache.commons.io.IOUtils;

import eu.etaxonomy.cdm.api.application.CdmApplicationState;

import eu.etaxonomy.cdm.io.common.IImportConfigurator.SOURCE_TYPE;

import eu.etaxonomy.cdm.io.service.IIOService;

import eu.etaxonomy.taxeditor.store.internal.TaxeditorStorePlugin;

	public Job createIOServiceJob(IImportConfigurator configurator, InputStream is, SOURCE_TYPE type) {

	    try {

	        return createIOServiceJob(configurator, IOUtils.toByteArray(is), type);

	    } catch (Exception e) {

	        MessagingUtils.errorDialog("Error importing input stream",

	                this,

	                e.getMessage(),

	                TaxeditorStorePlugin.PLUGIN_ID,

	                e,

	                true);

	    }

	    return null;

	}

	public Job createIOServiceJob(IImportConfigurator configurator, File importFile, SOURCE_TYPE type) {

	    Path path = Paths.get(importFile.toURI());

	    try {

	        return createIOServiceJob(configurator, Files.readAllBytes(path), type);

	    } catch (Exception e) {

	        MessagingUtils.errorDialog("Error importing file",

	                this,

	                e.getMessage(),

	                TaxeditorStorePlugin.PLUGIN_ID,

	                e,

	                true);

	    }

	    return null;

	}

    public Job createIOServiceJob(final IImportConfigurator configurator, final byte[] data, final SOURCE_TYPE type) {

        Assert.isNotNull(configurator, "Configuration may not be null");

        final Display display = Display.getDefault();

        Job job = new Job("Import: " + configurator.getClass().getSimpleName()) {

            @Override

            protected IStatus run(IProgressMonitor monitor) {

                monitor.beginTask("Importing data", IProgressMonitor.UNKNOWN);

                IIOService ioService = CdmApplicationState.getIOService();

                ioService.importData(configurator, data, type);

                monitor.done();

                display.asyncExec(new Runnable() {

                    @Override

                    public void run() {

                        CdmStore.getContextManager().notifyContextRefresh();

                    }

                });

                return Status.OK_STATUS;

            }

        };

        return job;