/*
    * Copyright 2005-2008 The Kuali Foundation
    * 
    * 
    * Licensed under the Educational Community 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.opensource.org/licenses/ecl2.php
    * 
   * 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.kuali.rice.ksb.messaging;
  
  import java.io.Serializable;
  import java.sql.Timestamp;
  
  import javax.persistence.Column;
  import javax.persistence.Entity;
  import javax.persistence.Id;
  import javax.persistence.NamedQueries;
  import javax.persistence.NamedQuery;
  import javax.persistence.PrePersist;
  import javax.persistence.Table;
  import javax.persistence.Transient;
  import javax.persistence.Version;
  
  import org.kuali.rice.core.jpa.annotations.Sequence;
  import org.kuali.rice.core.util.OrmUtils;
  import org.kuali.rice.ksb.service.KSBServiceLocator;
  
  /**
   * A message which has been persisted to the data store.
   *
   * @author Kuali Rice Team (rice.collab@kuali.org)
   */
  @Entity
  @Table(name="KRSB_MSG_QUE_T")
  @Sequence(name="KRSB_MSG_QUE_S", property="routeQueueId")
  @NamedQueries({
    @NamedQuery(name="PersistedMessage.FindAll", query="select pm from PersistedMessage pm"),
    @NamedQuery(name="PersistedMessage.FindByServiceName", query="select pm from PersistedMessage pm where pm.serviceName = :serviceName and pm.methodName = :methodName"),
    @NamedQuery(name="PersistedMessage.GetNextDocuments", query="select pm from PersistedMessage pm where pm.serviceNamespace = :serviceNamespace and pm.queueStatus <> :queueStatus and pm.ipNumber = :ipNumber order by queuePriority asc, routeQueueId asc, queueDate asc")
  })
  public class PersistedMessage implements Serializable {
  
  	private static final long serialVersionUID = -7047766894738304195L;
  
  	@Id
  	@Column(name="MSG_QUE_ID")
  	private Long routeQueueId;
  	@Column(name="PRIO")
  	private Integer queuePriority;
  	@Column(name="STAT_CD")
  	private String queueStatus;
  	@Column(name="DT")
  	private Timestamp queueDate;
  	@Column(name="EXP_DT")
  	private Timestamp expirationDate;
  	@Column(name="RTRY_CNT")
  	private Integer retryCount;
  	@Version
  	@Column(name="VER_NBR")
  	private Integer lockVerNbr;
      @Column(name="IP_NBR")
  	private String ipNumber;
      @Column(name="SVC_NM")
  	private String serviceName;
      @Column(name="SVC_NMSPC")
  	private String serviceNamespace;
      @Column(name="SVC_MTHD_NM")
  	private String methodName;
      @Transient
      private AsynchronousCall methodCall;
      @Transient
      private PersistedMessagePayload payload;
      @Column(name="APP_VAL_ONE")
  	private String value1;
      @Column(name="APP_VAL_TWO")
  	private String value2;
      
      public PersistedMessage() {
          // default constructor
      }
      
      @PrePersist
      public void beforeInsert(){
          OrmUtils.populateAutoIncValue(this, KSBServiceLocator.getMessageEntityManagerFactory().createEntityManager());
      }
      
  	public String getServiceNamespace() {
  		return this.serviceNamespace;
  	}
  
  	public void setServiceNamespace(String ServiceNamespace) {
  		this.serviceNamespace = ServiceNamespace;
  	}
  
     public String getIpNumber() {
         return this.ipNumber;
     }
     
     public void setIpNumber(String ipNumber) {
         this.ipNumber = ipNumber;
     }
     
 	public Timestamp getQueueDate() {
 		return this.queueDate;
 	}
 
 	public Integer getQueuePriority() {
 		return this.queuePriority;
 	}
 
 	public String getQueueStatus() {
 		return this.queueStatus;
 	}
 
 	public Integer getRetryCount() {
 		return this.retryCount;
 	}
 
 
 	public void setQueueDate(Timestamp timestamp) {
 	    this.queueDate = timestamp;
 	}
 
 	public void setQueuePriority(Integer integer) {
 	    this.queuePriority = integer;
 	}
 
 	public void setQueueStatus(String string) {
 	    this.queueStatus = string;
 	}
 
 	public void setRetryCount(Integer integer) {
 	    this.retryCount = integer;
 	}
 
 
     public Integer getLockVerNbr() {
         return this.lockVerNbr;
     }
     
     public void setLockVerNbr(Integer lockVerNbr) {
         this.lockVerNbr = lockVerNbr;
     }
     
     public Long getRouteQueueId() {
         return this.routeQueueId;
     }
     
     public void setRouteQueueId(Long queueSequence) {
         this.routeQueueId = queueSequence;
     }
     
 	public String getServiceName() {
 		return this.serviceName;
 	}
 
 	public void setServiceName(String serviceName) {
 		this.serviceName = serviceName;
 	}
 
     public String toString() {
 	return "[RouteQueue: " + ", routeQueueId=" + this.routeQueueId + ", ipNumber=" + this.ipNumber 
 		+ "serviceNamespace=" + this.serviceNamespace + ", serviceName=" + this.serviceName + ", methodName=" + methodName 
 		+ ", queueStatus=" + this.queueStatus + ", queuePriority=" + this.queuePriority
 		+ ", queueDate=" + this.queueDate + "]";
     }
 
 	public AsynchronousCall getMethodCall() {
 		return this.methodCall;
 	}
 
 	public void setMethodCall(AsynchronousCall methodCall) {
 		this.methodCall = methodCall;
 	}
 
 	public String getMethodName() {
 		return this.methodName;
 	}
 
 	public void setMethodName(String methodName) {
 		this.methodName = methodName;
 	}
 
 	public Timestamp getExpirationDate() {
 		return this.expirationDate;
 	}
 
 	public void setExpirationDate(Timestamp expirationDate) {
 		this.expirationDate = expirationDate;
 	}
 
     public PersistedMessagePayload getPayload() {
 	if (this.payload == null) {
 	    if (this.getRouteQueueId() == null) {
 		return null;
 }	    this.payload = KSBServiceLocator.getRouteQueueService().findByPersistedMessageByRouteQueueId(this.getRouteQueueId()); 
 	}
         return this.payload;
     }
 
     public void setPayload(PersistedMessagePayload payload) {
         this.payload = payload;
     }
 
     public String getValue1() {
         return this.value1;
     }
 
     public void setValue1(String value1) {
         this.value1 = value1;
     }
 
     public String getValue2() {
         return this.value2;
     }
 
     public void setValue2(String value2) {
         this.value2 = value2;
     }
 
 }