Package com.mozilla.grouperfish.batch.handlers

Examples of com.mozilla.grouperfish.batch.handlers.CleanupHandler


        // Here we could in theory create e.g. several run workers instead of just one for this host...
        workers = new ImmutableList.Builder<Worker>()
            .add(new Worker(failQ, prepQ, runQ, new FetchHandler(fs, indexes)))
            .add(new Worker(failQ,        runQ, putQ, new RunHandler(fs, transforms)))
            .add(new Worker(failQ,              putQ, cleanupQ, new PutHandler(grid, fs)))
            .add(new Worker(failQ,                    cleanupQ, null, new CleanupHandler(fs)))
            .build();

        prepareQueue = prepQ;
        log.info("Instantiated service: {}", getClass().getSimpleName());
    }
View Full Code Here


            final TransformProvider transforms) {
        return new SequentialHandler(
                new FetchHandler(fs, indexes),
                new RunHandler(fs, transforms),
                new PutHandler(grid, fs),
                new CleanupHandler(fs));
    }
View Full Code Here

TOP

Related Classes of com.mozilla.grouperfish.batch.handlers.CleanupHandler

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.