Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * Licensed to the Apache Software Foundation (ASF) under one or more
   * contributor license agreements.  See the NOTICE file distributed with
   * this work for additional information regarding copyright ownership.
   * The ASF licenses this file to You under the Apache License, Version 2.0
   * (the "License"); you may not use this file except in compliance with
   * the License.  You may obtain a copy of the License at
   *
   *     http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
 package org.jclouds.cloudstack.domain;
 
 import static com.google.common.base.Preconditions.checkNotNull;
 
 import java.util.Date;
 
 
Class AsyncJob

Author(s):
Adrian Cole
 
 public class AsyncJob<S> {

   
Valid job result codes
 
    public static enum ResultCode {
       SUCCESS(0),
       FAIL(530),
       UNKNOWN(-1);
 
       private final int code;
 
       private ResultCode(int code) {
          this. = code;
       }
 
       public int code() {
          return this.;
       }
 
       public static ResultCode fromValue(String value) {
          try {
             int resultCode = Integer.parseInt(value);
             switch (resultCode) {
                case 0:
                   return ;
                case 530:
                   return ;
                default:
                   return ;
             }
          } catch (NumberFormatException e) {
             return ;
          }
       }
    }

   
Valid async job statuses
 
    public static enum Status {
       IN_PROGRESS(0),
       SUCCEEDED(1),
       FAILED(2),
       UNKNOWN(-1);
 
       private final int code;
 
       private Status(int code) {
          this. = code;
       }
 
       public int code() {
          return this.;
       }
 
       public static Status fromValue(String value) {
          try {
             int statusCode = Integer.parseInt(value);
             switch (statusCode) {
                case 0:
                   return ;
                case 1:
                   return ;
                case 2:
                   return ;
               default:
                  return ;
            }
         } catch (NumberFormatException e) {
            return ;
         }
      }
   }
   public static <T> Builder<?, T> builder() {
      return new ConcreteBuilder<T>();
   }
   public Builder toBuilder() {
      return new ConcreteBuilder<S>().fromAsyncJob(this);
   }
   public abstract static class Builder<T extends Builder<T, S>, S> {
      protected abstract T self();
      protected String accountId;
      protected String cmd;
      protected Date created;
      protected String id;
      protected String instanceId;
      protected String instanceType;
      protected int progress;
      protected S result;
      protected AsyncJob.ResultCode resultCode;
      protected String resultType;
      protected AsyncJob.Status status;
      protected String userId;
      protected AsyncJobError error;

      
      public T accountId(String accountId) {
         this. = accountId;
         return self();
      }

      
      public T cmd(String cmd) {
         this. = cmd;
         return self();
      }

      
      public T created(Date created) {
         this. = created;
         return self();
      }

      
      public T id(String id) {
         this. = id;
         return self();
      }

      
      public T instanceId(String instanceId) {
         this. = instanceId;
         return self();
      }

      
      public T instanceType(String instanceType) {
         this. = instanceType;
         return self();
      }

      
      public T progress(int progress) {
         this. = progress;
         return self();
      }

      
      public T result(S result) {
         this. = result;
         return self();
      }

      
      public T resultCode(AsyncJob.ResultCode resultCode) {
         this. = resultCode;
         return self();
      }

      
      public T resultType(String resultType) {
         this. = resultType;
         return self();
      }

      
      public T status(AsyncJob.Status status) {
         this. = status;
         return self();
      }

      
      public T userId(String userId) {
         this. = userId;
         return self();
      }

      
      public T error(AsyncJobError error) {
         this. = error;
         return self();
      }
      public AsyncJob build() {
         return new AsyncJob<S>(,
               );
      }
      public T fromAsyncJob(AsyncJob<S> in) {
         return this
               .accountId(in.getAccountId())
               .cmd(in.getCmd())
               .created(in.getCreated())
               .id(in.getId())
               .instanceId(in.getInstanceId())
               .instanceType(in.getInstanceType())
               .progress(in.getProgress())
               .result(in.getResult())
               .resultCode(in.getResultCode())
               .resultType(in.getResultType())
               .status(in.getStatus())
               .userId(in.getUserId())
               .error(in.getError());
      }
      public static Builder<?, ObjectfromAsyncJobUntyped(AsyncJob<?> in) {
         return new ConcreteBuilder().fromAsyncJob(in);
      }
   }
   private static class ConcreteBuilder<T> extends Builder<ConcreteBuilder<T>, T> {
      @Override
      protected ConcreteBuilder<T> self() {
         return this;
      }
   }
   private final String accountId;
   private final String cmd;
   private final Date created;
   private final String id;
   private final String instanceId;
   private final String instanceType;
   private final int progress;
   private final S result;
   private final AsyncJob.ResultCode resultCode;
   private final String resultType;
   private final AsyncJob.Status status;
   private final String userId;
   private final AsyncJobError error;
         "accountid""cmd""created""jobid""jobinstanceid""jobinstancetype""jobprocstatus""jobresult",
         "jobresultcode""jobresulttype""jobstatus""userid""error"
   })
   protected AsyncJob(@Nullable String accountId, @Nullable String cmd, @Nullable Date createdString id,
                      @Nullable String instanceId, @Nullable String instanceTypeint progress, @Nullable S result,
                      @Nullable AsyncJob.ResultCode resultCode, @Nullable String resultType, @Nullable AsyncJob.Status status,
                      @Nullable String userId, @Nullable AsyncJobError error) {
      this. = accountId;
      this. = cmd;
      this. = created;
      this. = checkNotNull(id"id");
      this. = instanceId;
      this. = instanceType;
      this. = progress;
      this. = result;
      this. = resultCode;
      this. = resultType;
      this. = status;
      this. = userId;
      this. = error;
   }

   

Returns:
the account that executed the async command
   public String getAccountId() {
      return this.;
   }

   

Returns:
the async command executed
   public String getCmd() {
      return this.;
   }

   

Returns:
the created date of the job
   public Date getCreated() {
      return this.;
   }

   

Returns:
async job ID
   public String getId() {
      return this.;
   }

   

Returns:
the unique ID of the instance/entity object related to the job
   public String getInstanceId() {
      return this.;
   }

   

Returns:
the instance/entity object related to the job
   public String getInstanceType() {
      return this.;
   }

   

Returns:
the progress information of the PENDING job
   public int getProgress() {
      return this.;
   }

   

Returns:
the result reason
   public S getResult() {
      return this.;
   }

   

Returns:
the result code for the job
      return this.;
   }

   

Returns:
the result type
   public String getResultType() {
      return this.;
   }

   

Returns:
the current job status-should be 0 for PENDING
   public AsyncJob.Status getStatus() {
      return this.;
   }

   

Returns:
the user that executed the async command
   public String getUserId() {
      return this.;
   }

   

Returns:
the error related to this command, or null if no error or error not yet encountered.
   public AsyncJobError getError() {
      return this.;
   }
   public boolean hasFailed() {
      return getError() != null || getResultCode() == . || getStatus() == .;
   }
   public boolean hasSucceed() {
      return getError() == null && getResultCode() == . && getStatus() == .;
   }
   public int hashCode() {
   }
   public boolean equals(Object obj) {
      if (this == objreturn true;
      if (obj == null || getClass() != obj.getClass()) return false;
      AsyncJob<?> that = AsyncJob.class.cast(obj);
      return Objects.equal(this.that.accountId)
            && Objects.equal(this.that.cmd)
            && Objects.equal(this.that.created)
            && Objects.equal(this.that.id)
            && Objects.equal(this.that.instanceId)
            && Objects.equal(this.that.instanceType)
            && Objects.equal(this.that.progress)
            && Objects.equal(this.that.result)
            && Objects.equal(this.that.resultCode)
            && Objects.equal(this.that.resultType)
            && Objects.equal(this.that.status)
            && Objects.equal(this.that.userId)
            && Objects.equal(this.that.error);
   }
   protected ToStringHelper string() {
      return Objects.toStringHelper(this)
            .add("accountId").add("cmd").add("created").add("id").add("instanceId")
            .add("instanceType").add("progress").add("result").add("resultCode")
            .add("resultType").add("status").add("userId").add("error");
   }
   public String toString() {
      return string().toString();
   }
New to GrepCode? Check out our FAQ X