Examples of com.google.common.io.Closer.register()

com.google.common.io.Closer.register()
Registers the given {@code closeable} to be closed when this {@code Closer} is{@linkplain #close closed}. @return the given {@code closeable}

            }
            MongoDocumentStore docStore = (MongoDocumentStore) dns.getDocumentStore();
            LastRevRecoveryAgent agent = new LastRevRecoveryAgent(dns);
            MongoMissingLastRevSeeker seeker = new MongoMissingLastRevSeeker(docStore);
            CloseableIterable<NodeDocument> docs = seeker.getCandidates(0);
            closer.register(docs);
            boolean dryRun = Arrays.asList(args).contains("dryRun");
            agent.recover(docs.iterator(), dns.getClusterId(), dryRun);
        } catch (Throwable e) {
            throw closer.rethrow(e);
        } finally {

View Full Code Here

    public int recover(Iterator<NodeDocument> suspects,
                       int clusterId, boolean dryRun) {
        Closer closer = Closer.create();
        try {
            UnsavedModifications unsaved = new UnsavedModifications();
            closer.register(unsaved);
            UnsavedModifications unsavedParents = new UnsavedModifications();
            closer.register(unsavedParents);


            //Map of known last rev of checked paths
            UnsavedModifications knownLastRevs = new UnsavedModifications();

View Full Code Here

        Closer closer = Closer.create();
        try {
            UnsavedModifications unsaved = new UnsavedModifications();
            closer.register(unsaved);
            UnsavedModifications unsavedParents = new UnsavedModifications();
            closer.register(unsavedParents);


            //Map of known last rev of checked paths
            UnsavedModifications knownLastRevs = new UnsavedModifications();
            closer.register(knownLastRevs);

View Full Code Here

            UnsavedModifications unsavedParents = new UnsavedModifications();
            closer.register(unsavedParents);


            //Map of known last rev of checked paths
            UnsavedModifications knownLastRevs = new UnsavedModifications();
            closer.register(knownLastRevs);


            long count = 0;
            while (suspects.hasNext()) {
                NodeDocument doc = suspects.next();
                count++;

View Full Code Here

    try {
      channel.setCommand(this.script);
      Closer closer = Closer.create();
      InputStream stdoutStream = channel.getInputStream();
      InputStream stderrStream = channel.getErrStream();
      Reader stdoutReader = closer.register(new InputStreamReader(
          stdoutStream, "UTF-8"));
      Reader stderrReader = closer.register(new InputStreamReader(
          stderrStream, "UTF-8"));
      try {
        // executes the command

View Full Code Here

      Closer closer = Closer.create();
      InputStream stdoutStream = channel.getInputStream();
      InputStream stderrStream = channel.getErrStream();
      Reader stdoutReader = closer.register(new InputStreamReader(
          stdoutStream, "UTF-8"));
      Reader stderrReader = closer.register(new InputStreamReader(
          stderrStream, "UTF-8"));
      try {
        // executes the command
        channel.connect();
        String stdout = CharStreams.toString(stdoutReader);

View Full Code Here

            return null;
        }


        try {
            Closer closer = Closer.create();
            InputStream in = closer.register(url.openStream());
            try {
                Properties props = new Properties();
                props.load(in);


                return props.getProperty("version");

View Full Code Here

        slave.end = System.currentTimeMillis();
      }      
    });


    Closer closer = Closer.create();
    closer.register(eventStream);
    closer.register(w);
    try {
      OutputStream sysout = closer.register(new BufferedOutputStream(new FileOutputStream(sysoutFile)));
      OutputStream syserr = closer.register(new BufferedOutputStream(new FileOutputStream(syserrFile)));
      RandomAccessFile streamsBuffer = closer.register(new RandomAccessFile(streamsBufferFile, "rw"));

View Full Code Here

      }      
    });


    Closer closer = Closer.create();
    closer.register(eventStream);
    closer.register(w);
    try {
      OutputStream sysout = closer.register(new BufferedOutputStream(new FileOutputStream(sysoutFile)));
      OutputStream syserr = closer.register(new BufferedOutputStream(new FileOutputStream(syserrFile)));
      RandomAccessFile streamsBuffer = closer.register(new RandomAccessFile(streamsBufferFile, "rw"));

View Full Code Here


    Closer closer = Closer.create();
    closer.register(eventStream);
    closer.register(w);
    try {
      OutputStream sysout = closer.register(new BufferedOutputStream(new FileOutputStream(sysoutFile)));
      OutputStream syserr = closer.register(new BufferedOutputStream(new FileOutputStream(syserrFile)));
      RandomAccessFile streamsBuffer = closer.register(new RandomAccessFile(streamsBufferFile, "rw"));


      Execute execute = forkProcess(slave, eventBus, commandline, eventStream, sysout, syserr, streamsBuffer);
      log("Forked JVM J" + slave.id + " finished with exit code: " + execute.getExitValue(), Project.MSG_DEBUG);

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

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.