core/src/com/cloud/async/AsyncJobVO.java - cloudstack - Git at Google

 /**
  *  Copyright (C) 2010 Cloud.com, Inc.  All rights reserved.
  *
  * This software is licensed under the GNU General Public License v3 or later.
  *
  * It is free software: you can redistribute it and/or modify
  * it under the terms of the GNU General Public License as published by
  * the Free Software Foundation, either version 3 of the License, or any later version.
  * This program is distributed in the hope that it will be useful,
  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  * GNU General Public License for more details.
  *
  * You should have received a copy of the GNU General Public License
  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  *
  */

 package com.cloud.async;

 import java.util.Date;

 import javax.persistence.Column;
 import javax.persistence.Entity;
 import javax.persistence.GeneratedValue;
 import javax.persistence.GenerationType;
 import javax.persistence.Id;
 import javax.persistence.Table;
 import javax.persistence.Temporal;
 import javax.persistence.TemporalType;

 import com.cloud.utils.db.GenericDao;

 @Entity
 @Table(name="async_job")
 public class AsyncJobVO {
 	public static final int CALLBACK_POLLING = 0;
 	public static final int CALLBACK_EMAIL = 1;

 	@Id
     @GeneratedValue(strategy=GenerationType.IDENTITY)
     @Column(name="id")
     private Long id = null;

     @Column(name="user_id")
     private long userId;

     @Column(name="account_id")
     private long accountId;

     @Column(name="session_key")
     private String sessionKey;

 	@Column(name="job_cmd")
     private String cmd;

 	@Column(name="job_cmd_originator")
 	private String cmdOriginator;

 	@Column(name="job_cmd_ver")
     private int cmdVersion;

     @Column(name="job_cmd_info", length=65535)
     private String cmdInfo;

     @Column(name="callback_type")
     private int callbackType;

     @Column(name="callback_address")
     private String callbackAddress;

     @Column(name="job_status")
     private int status;

     @Column(name="job_process_status")
     private int processStatus;

     @Column(name="job_result_code")
     private int resultCode;

     @Column(name="job_result", length=65535)
     private String result;

     @Column(name="instance_type", length=64)
     private String instanceType;

 	@Column(name="instance_id", length=64)
     private Long instanceId;

     @Column(name="job_init_msid")
     private Long initMsid;

     @Column(name="job_complete_msid")
     private Long completeMsid;

     @Column(name=GenericDao.CREATED_COLUMN)
     private Date created;

     @Column(name="last_updated")
     @Temporal(TemporalType.TIMESTAMP)
     private Date lastUpdated;

     @Column(name="last_polled")
     @Temporal(TemporalType.TIMESTAMP)
     private Date lastPolled;

     @Column(name=GenericDao.REMOVED_COLUMN)
     private Date removed;

     public AsyncJobVO() {
     }

     public AsyncJobVO(long userId, long accountId, String cmd, String cmdInfo) {
     	this.userId = userId;
     	this.accountId = accountId;
     	this.cmd = cmd;
     	this.cmdInfo = cmdInfo;
     	callbackType = CALLBACK_POLLING;
     }

     public AsyncJobVO(long userId, long accountId, String cmd, String cmdInfo,
     	int callbackType, String callbackAddress) {

     	this(userId, accountId, cmd, cmdInfo);
     	this.callbackType = callbackType;
     	this.callbackAddress = callbackAddress;
     }

     public Long getId() {
 		return id;
 	}

 	public void setId(Long id) {
 		this.id = id;
 	}

 	public long getUserId() {
 		return userId;
 	}

 	public void setUserId(long userId) {
 		this.userId = userId;
 	}

 	public long getAccountId() {
 		return accountId;
 	}

 	public void setAccountId(long accountId) {
 		this.accountId = accountId;
 	}

 	public String getCmd() {
 		return cmd;
 	}

 	public void setCmd(String cmd) {
 		this.cmd = cmd;
 	}

 	public int getCmdVersion() {
 		return cmdVersion;
 	}

 	public void setCmdVersion(int version) {
 		cmdVersion = version;
 	}

 	public String getCmdInfo() {
 		return cmdInfo;
 	}

 	public void setCmdInfo(String cmdInfo) {
 		this.cmdInfo = cmdInfo;
 	}

 	public int getCallbackType() {
 		return callbackType;
 	}

 	public void setCallbackType(int callbackType) {
 		this.callbackType = callbackType;
 	}

 	public String getCallbackAddress() {
 		return callbackAddress;
 	}

 	public void setCallbackAddress(String callbackAddress) {
 		this.callbackAddress = callbackAddress;
 	}

 	public int getStatus() {
 		return status;
 	}

 	public void setStatus(int status) {
 		this.status = status;
 	}

 	public int getProcessStatus() {
 		return processStatus;
 	}

 	public void setProcessStatus(int status) {
 		processStatus = status;
 	}

 	public int getResultCode() {
 		return resultCode;
 	}

 	public void setResultCode(int resultCode) {
 		this.resultCode = resultCode;
 	}

 	public String getResult() {
 		return result;
 	}

 	public void setResult(String result) {
 		this.result = result;
 	}

 	public Long getInitMsid() {
 		return initMsid;
 	}

 	public void setInitMsid(Long initMsid) {
 		this.initMsid = initMsid;
 	}

 	public Long getCompleteMsid() {
 		return completeMsid;
 	}

 	public void setCompleteMsid(Long completeMsid) {
 		this.completeMsid = completeMsid;
 	}

 	public Date getCreated() {
 		return created;
 	}

 	public void setCreated(Date created) {
 		this.created = created;
 	}

 	public Date getLastUpdated() {
 		return lastUpdated;
 	}

 	public void setLastUpdated(Date lastUpdated) {
 		this.lastUpdated = lastUpdated;
 	}

 	public Date getLastPolled() {
 		return lastPolled;
 	}

 	public void setLastPolled(Date lastPolled) {
 		this.lastPolled = lastPolled;
 	}

 	public Date getRemoved() {
 		return removed;
 	}

 	public void setRemoved(Date removed) {
 		this.removed = removed;
 	}

     public String getInstanceType() {
 		return instanceType;
 	}

 	public void setInstanceType(String instanceType) {
 		this.instanceType = instanceType;
 	}

 	public Long getInstanceId() {
 		return instanceId;
 	}

 	public void setInstanceId(Long instanceId) {
 		this.instanceId = instanceId;
 	}

     public String getSessionKey() {
 		return sessionKey;
 	}

 	public void setSessionKey(String sessionKey) {
 		this.sessionKey = sessionKey;
 	}

     public String getCmdOriginator() {
 		return cmdOriginator;
 	}

 	public void setCmdOriginator(String cmdOriginator) {
 		this.cmdOriginator = cmdOriginator;
 	}

 	public String toString() {
 		StringBuffer sb = new StringBuffer();
 		sb.append("AsyncJobVO {id:").append(getId());
 		sb.append(", userId: ").append(getUserId());
 		sb.append(", accountId: ").append(getAccountId());
 		sb.append(", sessionKey: ").append(getSessionKey());
 		sb.append(", instanceType: ").append(getInstanceType());
 		sb.append(", instanceId: ").append(getInstanceId());
 		sb.append(", cmd: ").append(getCmd());
 		sb.append(", cmdOriginator: ").append(getCmdOriginator());
 		sb.append(", cmdInfo: ").append(getCmdInfo());
 		sb.append(", cmdVersion: ").append(getCmdVersion());
 		sb.append(", callbackType: ").append(getCallbackType());
 		sb.append(", callbackAddress: ").append(getCallbackAddress());
 		sb.append(", status: ").append(getStatus());
 		sb.append(", processStatus: ").append(getProcessStatus());
 		sb.append(", resultCode: ").append(getResultCode());
 		sb.append(", result: ").append(getResult());
 		sb.append(", initMsid: ").append(getInitMsid());
 		sb.append(", completeMsid: ").append(getCompleteMsid());
 		sb.append(", lastUpdated: ").append(getLastUpdated());
 		sb.append(", lastPolled: ").append(getLastPolled());
 		sb.append(", created: ").append(getCreated());
 		sb.append("}");
 		return sb.toString();
 	}
 }
	/**
	* Copyright (C) 2010 Cloud.com, Inc. All rights reserved.
	*
	* This software is licensed under the GNU General Public License v3 or later.
	*
	* It is free software: you can redistribute it and/or modify
	* it under the terms of the GNU General Public License as published by
	* the Free Software Foundation, either version 3 of the License, or any later version.
	* This program is distributed in the hope that it will be useful,
	* but WITHOUT ANY WARRANTY; without even the implied warranty of
	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
	* GNU General Public License for more details.
	*
	* You should have received a copy of the GNU General Public License
	* along with this program. If not, see <http://www.gnu.org/licenses/>.
	*
	*/

	package com.cloud.async;

	import java.util.Date;

	import javax.persistence.Column;
	import javax.persistence.Entity;
	import javax.persistence.GeneratedValue;
	import javax.persistence.GenerationType;
	import javax.persistence.Id;
	import javax.persistence.Table;
	import javax.persistence.Temporal;
	import javax.persistence.TemporalType;

	import com.cloud.utils.db.GenericDao;

	@Entity
	@Table(name="async_job")
	public class AsyncJobVO {
	public static final int CALLBACK_POLLING = 0;
	public static final int CALLBACK_EMAIL = 1;

	@Id
	@GeneratedValue(strategy=GenerationType.IDENTITY)
	@Column(name="id")
	private Long id = null;

	@Column(name="user_id")
	private long userId;

	@Column(name="account_id")
	private long accountId;

	@Column(name="session_key")
	private String sessionKey;

	@Column(name="job_cmd")
	private String cmd;

	@Column(name="job_cmd_originator")
	private String cmdOriginator;

	@Column(name="job_cmd_ver")
	private int cmdVersion;

	@Column(name="job_cmd_info", length=65535)
	private String cmdInfo;

	@Column(name="callback_type")
	private int callbackType;

	@Column(name="callback_address")
	private String callbackAddress;

	@Column(name="job_status")
	private int status;

	@Column(name="job_process_status")
	private int processStatus;

	@Column(name="job_result_code")
	private int resultCode;

	@Column(name="job_result", length=65535)
	private String result;

	@Column(name="instance_type", length=64)
	private String instanceType;

	@Column(name="instance_id", length=64)
	private Long instanceId;

	@Column(name="job_init_msid")
	private Long initMsid;

	@Column(name="job_complete_msid")
	private Long completeMsid;

	@Column(name=GenericDao.CREATED_COLUMN)
	private Date created;

	@Column(name="last_updated")
	@Temporal(TemporalType.TIMESTAMP)
	private Date lastUpdated;

	@Column(name="last_polled")
	@Temporal(TemporalType.TIMESTAMP)
	private Date lastPolled;

	@Column(name=GenericDao.REMOVED_COLUMN)
	private Date removed;

	public AsyncJobVO() {
	}

	public AsyncJobVO(long userId, long accountId, String cmd, String cmdInfo) {
	this.userId = userId;
	this.accountId = accountId;
	this.cmd = cmd;
	this.cmdInfo = cmdInfo;
	callbackType = CALLBACK_POLLING;
	}

	public AsyncJobVO(long userId, long accountId, String cmd, String cmdInfo,
	int callbackType, String callbackAddress) {

	this(userId, accountId, cmd, cmdInfo);
	this.callbackType = callbackType;
	this.callbackAddress = callbackAddress;
	}

	public Long getId() {
	return id;
	}

	public void setId(Long id) {
	this.id = id;
	}

	public long getUserId() {
	return userId;
	}

	public void setUserId(long userId) {
	this.userId = userId;
	}

	public long getAccountId() {
	return accountId;
	}

	public void setAccountId(long accountId) {
	this.accountId = accountId;
	}

	public String getCmd() {
	return cmd;
	}

	public void setCmd(String cmd) {
	this.cmd = cmd;
	}

	public int getCmdVersion() {
	return cmdVersion;
	}

	public void setCmdVersion(int version) {
	cmdVersion = version;
	}

	public String getCmdInfo() {
	return cmdInfo;
	}

	public void setCmdInfo(String cmdInfo) {
	this.cmdInfo = cmdInfo;
	}

	public int getCallbackType() {
	return callbackType;
	}

	public void setCallbackType(int callbackType) {
	this.callbackType = callbackType;
	}

	public String getCallbackAddress() {
	return callbackAddress;
	}

	public void setCallbackAddress(String callbackAddress) {
	this.callbackAddress = callbackAddress;
	}

	public int getStatus() {
	return status;
	}

	public void setStatus(int status) {
	this.status = status;
	}

	public int getProcessStatus() {
	return processStatus;
	}

	public void setProcessStatus(int status) {
	processStatus = status;
	}

	public int getResultCode() {
	return resultCode;
	}

	public void setResultCode(int resultCode) {
	this.resultCode = resultCode;
	}

	public String getResult() {
	return result;
	}

	public void setResult(String result) {
	this.result = result;
	}

	public Long getInitMsid() {
	return initMsid;
	}

	public void setInitMsid(Long initMsid) {
	this.initMsid = initMsid;
	}

	public Long getCompleteMsid() {
	return completeMsid;
	}

	public void setCompleteMsid(Long completeMsid) {
	this.completeMsid = completeMsid;
	}

	public Date getCreated() {
	return created;
	}

	public void setCreated(Date created) {
	this.created = created;
	}

	public Date getLastUpdated() {
	return lastUpdated;
	}

	public void setLastUpdated(Date lastUpdated) {
	this.lastUpdated = lastUpdated;
	}

	public Date getLastPolled() {
	return lastPolled;
	}

	public void setLastPolled(Date lastPolled) {
	this.lastPolled = lastPolled;
	}

	public Date getRemoved() {
	return removed;
	}

	public void setRemoved(Date removed) {
	this.removed = removed;
	}

	public String getInstanceType() {
	return instanceType;
	}

	public void setInstanceType(String instanceType) {
	this.instanceType = instanceType;
	}

	public Long getInstanceId() {
	return instanceId;
	}

	public void setInstanceId(Long instanceId) {
	this.instanceId = instanceId;
	}

	public String getSessionKey() {
	return sessionKey;
	}

	public void setSessionKey(String sessionKey) {
	this.sessionKey = sessionKey;
	}

	public String getCmdOriginator() {
	return cmdOriginator;
	}

	public void setCmdOriginator(String cmdOriginator) {
	this.cmdOriginator = cmdOriginator;
	}

	public String toString() {
	StringBuffer sb = new StringBuffer();
	sb.append("AsyncJobVO {id:").append(getId());
	sb.append(", userId: ").append(getUserId());
	sb.append(", accountId: ").append(getAccountId());
	sb.append(", sessionKey: ").append(getSessionKey());
	sb.append(", instanceType: ").append(getInstanceType());
	sb.append(", instanceId: ").append(getInstanceId());
	sb.append(", cmd: ").append(getCmd());
	sb.append(", cmdOriginator: ").append(getCmdOriginator());
	sb.append(", cmdInfo: ").append(getCmdInfo());
	sb.append(", cmdVersion: ").append(getCmdVersion());
	sb.append(", callbackType: ").append(getCallbackType());
	sb.append(", callbackAddress: ").append(getCallbackAddress());
	sb.append(", status: ").append(getStatus());
	sb.append(", processStatus: ").append(getProcessStatus());
	sb.append(", resultCode: ").append(getResultCode());
	sb.append(", result: ").append(getResult());
	sb.append(", initMsid: ").append(getInitMsid());
	sb.append(", completeMsid: ").append(getCompleteMsid());
	sb.append(", lastUpdated: ").append(getLastUpdated());
	sb.append(", lastPolled: ").append(getLastPolled());
	sb.append(", created: ").append(getCreated());
	sb.append("}");
	return sb.toString();
	}
	}