ode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sean...@apache.org
Subject svn commit: r780780 - /ode/branches/APACHE_ODE_1.X/dao-jpa/src/main/java/org/apache/ode/dao/jpa/ProcessInstanceDAOImpl.java
Date Mon, 01 Jun 2009 18:59:42 GMT
Author: seanahn
Date: Mon Jun  1 18:59:42 2009
New Revision: 780780

URL: http://svn.apache.org/viewvc?rev=780780&view=rev
Log:
Removed tabs

Modified:
    ode/branches/APACHE_ODE_1.X/dao-jpa/src/main/java/org/apache/ode/dao/jpa/ProcessInstanceDAOImpl.java

Modified: ode/branches/APACHE_ODE_1.X/dao-jpa/src/main/java/org/apache/ode/dao/jpa/ProcessInstanceDAOImpl.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/dao-jpa/src/main/java/org/apache/ode/dao/jpa/ProcessInstanceDAOImpl.java?rev=780780&r1=780779&r2=780780&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/dao-jpa/src/main/java/org/apache/ode/dao/jpa/ProcessInstanceDAOImpl.java
(original)
+++ ode/branches/APACHE_ODE_1.X/dao-jpa/src/main/java/org/apache/ode/dao/jpa/ProcessInstanceDAOImpl.java
Mon Jun  1 18:59:42 2009
@@ -63,161 +63,161 @@
 @Entity
 @Table(name="ODE_PROCESS_INSTANCE")
 @NamedQueries({
- 	@NamedQuery(name=ProcessInstanceDAOImpl.DELETE_INSTANCES_BY_PROCESS, query="delete from
ProcessInstanceDAOImpl as i where i._process = :process"),
- 	@NamedQuery(name=ProcessInstanceDAOImpl.SELECT_INSTANCE_IDS_BY_PROCESS, query="select i._instanceId
from ProcessInstanceDAOImpl as i where i._process = :process"),
- 	@NamedQuery(name=ProcessInstanceDAOImpl.COUNT_INSTANCE_IDS_BY_PROCESS, query="select count(i._instanceId)
from ProcessInstanceDAOImpl as i where i._process = :process"),
- 	@NamedQuery(name=ProcessInstanceDAOImpl.SELECT_FAULT_IDS_BY_PROCESS, query="select i._faultId
from ProcessInstanceDAOImpl as i where i._process = :process and i._faultId is not null"),
-	@NamedQuery(name=ProcessInstanceDAOImpl.COUNT_FAILED_INSTANCES_BY_STATUS_AND_PROCESS_ID,

-			query="select count(i._instanceId), max(i._lastRecovery) from ProcessInstanceDAOImpl as
i where i._process._processId = :processId and i._state in(:states) and exists(select r from
ActivityRecoveryDAOImpl r where i = r._instance)")
+     @NamedQuery(name=ProcessInstanceDAOImpl.DELETE_INSTANCES_BY_PROCESS, query="delete from
ProcessInstanceDAOImpl as i where i._process = :process"),
+     @NamedQuery(name=ProcessInstanceDAOImpl.SELECT_INSTANCE_IDS_BY_PROCESS, query="select
i._instanceId from ProcessInstanceDAOImpl as i where i._process = :process"),
+     @NamedQuery(name=ProcessInstanceDAOImpl.COUNT_INSTANCE_IDS_BY_PROCESS, query="select
count(i._instanceId) from ProcessInstanceDAOImpl as i where i._process = :process"),
+     @NamedQuery(name=ProcessInstanceDAOImpl.SELECT_FAULT_IDS_BY_PROCESS, query="select i._faultId
from ProcessInstanceDAOImpl as i where i._process = :process and i._faultId is not null"),
+    @NamedQuery(name=ProcessInstanceDAOImpl.COUNT_FAILED_INSTANCES_BY_STATUS_AND_PROCESS_ID,

+            query="select count(i._instanceId), max(i._lastRecovery) from ProcessInstanceDAOImpl
as i where i._process._processId = :processId and i._state in(:states) and exists(select r
from ActivityRecoveryDAOImpl r where i = r._instance)")
 })
 public class ProcessInstanceDAOImpl extends OpenJPADAO implements ProcessInstanceDAO {
-	private static final Log __log = LogFactory.getLog(ProcessInstanceDAOImpl.class);
-	
-	public final static String DELETE_INSTANCES_BY_PROCESS = "DELETE_INSTANCES_BY_PROCESS";
- 	public final static String SELECT_INSTANCE_IDS_BY_PROCESS = "SELECT_INSTANCE_IDS_BY_PROCESS";
	public final static String COUNT_INSTANCE_IDS_BY_PROCESS = "COUNT_INSTANCE_IDS_BY_PROCESS";
-
- 	public final static String SELECT_FAULT_IDS_BY_PROCESS = "SELECT_FAULT_IDS_BY_PROCESS";
-	public final static String COUNT_FAILED_INSTANCES_BY_STATUS_AND_PROCESS_ID = "COUNT_FAILED_INSTANCES_BY_STATUS_AND_PROCESS_ID";
-	
+    private static final Log __log = LogFactory.getLog(ProcessInstanceDAOImpl.class);
+    
+    public final static String DELETE_INSTANCES_BY_PROCESS = "DELETE_INSTANCES_BY_PROCESS";
+     public final static String SELECT_INSTANCE_IDS_BY_PROCESS = "SELECT_INSTANCE_IDS_BY_PROCESS";
    public final static String COUNT_INSTANCE_IDS_BY_PROCESS = "COUNT_INSTANCE_IDS_BY_PROCESS";
+
+     public final static String SELECT_FAULT_IDS_BY_PROCESS = "SELECT_FAULT_IDS_BY_PROCESS";
+    public final static String COUNT_FAILED_INSTANCES_BY_STATUS_AND_PROCESS_ID = "COUNT_FAILED_INSTANCES_BY_STATUS_AND_PROCESS_ID";
+    
     @Id @Column(name="ID")
-	@GeneratedValue(strategy=GenerationType.AUTO)
-	private Long _instanceId;
-	@Basic @Column(name="LAST_RECOVERY_DATE")
+    @GeneratedValue(strategy=GenerationType.AUTO)
+    private Long _instanceId;
+    @Basic @Column(name="LAST_RECOVERY_DATE")
     private Date _lastRecovery;
-	@Basic @Column(name="LAST_ACTIVE_TIME")
+    @Basic @Column(name="LAST_ACTIVE_TIME")
     private Date _lastActive;
-	@Basic @Column(name="INSTANCE_STATE")
+    @Basic @Column(name="INSTANCE_STATE")
     private short _state;
-	@Basic @Column(name="PREVIOUS_STATE")
+    @Basic @Column(name="PREVIOUS_STATE")
     private short _previousState;
-	@Lob @Column(name="EXECUTION_STATE")
+    @Lob @Column(name="EXECUTION_STATE")
     private byte[] _executionState;
-	@Basic @Column(name="SEQUENCE")
+    @Basic @Column(name="SEQUENCE")
     private long _sequence;
-	@Basic @Column(name="DATE_CREATED")
+    @Basic @Column(name="DATE_CREATED")
     private Date _dateCreated = new Date();
-	
-	@OneToOne(fetch=FetchType.LAZY,cascade={CascadeType.MERGE, CascadeType.PERSIST, CascadeType.REFRESH})
@Column(name="ROOT_SCOPE_ID")
-	private ScopeDAOImpl _rootScope;
-	@OneToMany(targetEntity=ScopeDAOImpl.class,mappedBy="_processInstance",fetch=FetchType.LAZY,cascade={CascadeType.MERGE,
CascadeType.PERSIST, CascadeType.REFRESH})
-	private Collection<ScopeDAO> _scopes = new ArrayList<ScopeDAO>();
-	@OneToMany(targetEntity=ActivityRecoveryDAOImpl.class,mappedBy="_instance",fetch=FetchType.LAZY,cascade={CascadeType.ALL})
+    
+    @OneToOne(fetch=FetchType.LAZY,cascade={CascadeType.MERGE, CascadeType.PERSIST, CascadeType.REFRESH})
@Column(name="ROOT_SCOPE_ID")
+    private ScopeDAOImpl _rootScope;
+    @OneToMany(targetEntity=ScopeDAOImpl.class,mappedBy="_processInstance",fetch=FetchType.LAZY,cascade={CascadeType.MERGE,
CascadeType.PERSIST, CascadeType.REFRESH})
+    private Collection<ScopeDAO> _scopes = new ArrayList<ScopeDAO>();
+    @OneToMany(targetEntity=ActivityRecoveryDAOImpl.class,mappedBy="_instance",fetch=FetchType.LAZY,cascade={CascadeType.ALL})
     private Collection<ActivityRecoveryDAO> _recoveries = new ArrayList<ActivityRecoveryDAO>();
 
-	@SuppressWarnings("unused")
-	@Basic @Column(name="FAULT_ID", insertable=false, updatable=false, nullable=true)
+    @SuppressWarnings("unused")
+    @Basic @Column(name="FAULT_ID", insertable=false, updatable=false, nullable=true)
     private long _faultId;
-	@OneToOne(fetch=FetchType.LAZY,cascade={CascadeType.MERGE, CascadeType.PERSIST, CascadeType.REFRESH})
@Column(name="FAULT_ID")
-	private FaultDAOImpl _fault;
-	@ManyToOne(fetch=FetchType.LAZY,cascade={CascadeType.PERSIST}) @Column(name="PROCESS_ID")
-	private ProcessDAOImpl _process;
-	@ManyToOne(fetch=FetchType.LAZY,cascade={CascadeType.PERSIST}) @Column(name="INSTANTIATING_CORRELATOR_ID")
-	private CorrelatorDAOImpl _instantiatingCorrelator;
-
-	@OneToMany(targetEntity=MessageExchangeDAOImpl.class,mappedBy="_processInst",fetch=FetchType.LAZY)
-	@SuppressWarnings("unused")
-	private Collection<MessageExchangeDAO> _messageExchanges = new ArrayList<MessageExchangeDAO>();
-	
-	private transient int _activityFailureCount = -1;
-	
-	public ProcessInstanceDAOImpl() {}
-	public ProcessInstanceDAOImpl(CorrelatorDAOImpl correlator, ProcessDAOImpl process) {
-		_instantiatingCorrelator = correlator;
-		_process = process;
-	}
-
-	public void createActivityRecovery(String channel, long activityId,
-			String reason, Date dateTime, Element data, String[] actions,
-			int retries) {
-		ActivityRecoveryDAOImpl ar = new ActivityRecoveryDAOImpl(channel, activityId, reason, dateTime,
data, actions, retries);
+    @OneToOne(fetch=FetchType.LAZY,cascade={CascadeType.MERGE, CascadeType.PERSIST, CascadeType.REFRESH})
@Column(name="FAULT_ID")
+    private FaultDAOImpl _fault;
+    @ManyToOne(fetch=FetchType.LAZY,cascade={CascadeType.PERSIST}) @Column(name="PROCESS_ID")
+    private ProcessDAOImpl _process;
+    @ManyToOne(fetch=FetchType.LAZY,cascade={CascadeType.PERSIST}) @Column(name="INSTANTIATING_CORRELATOR_ID")
+    private CorrelatorDAOImpl _instantiatingCorrelator;
+
+    @OneToMany(targetEntity=MessageExchangeDAOImpl.class,mappedBy="_processInst",fetch=FetchType.LAZY)
+    @SuppressWarnings("unused")
+    private Collection<MessageExchangeDAO> _messageExchanges = new ArrayList<MessageExchangeDAO>();
+    
+    private transient int _activityFailureCount = -1;
+    
+    public ProcessInstanceDAOImpl() {}
+    public ProcessInstanceDAOImpl(CorrelatorDAOImpl correlator, ProcessDAOImpl process) {
+        _instantiatingCorrelator = correlator;
+        _process = process;
+    }
+
+    public void createActivityRecovery(String channel, long activityId,
+            String reason, Date dateTime, Element data, String[] actions,
+            int retries) {
+        ActivityRecoveryDAOImpl ar = new ActivityRecoveryDAOImpl(channel, activityId, reason,
dateTime, data, actions, retries);
         _recoveries.add(ar);
         ar.setInstance(this);
         _lastRecovery = dateTime;
     }
 
-	public ScopeDAO createScope(ScopeDAO parentScope, String name, int scopeModelId) {
-		ScopeDAOImpl ret = new ScopeDAOImpl((ScopeDAOImpl)parentScope,name,scopeModelId,this);
+    public ScopeDAO createScope(ScopeDAO parentScope, String name, int scopeModelId) {
+        ScopeDAOImpl ret = new ScopeDAOImpl((ScopeDAOImpl)parentScope,name,scopeModelId,this);
         ret.setState(ScopeStateEnum.ACTIVE);
         _scopes.add(ret);
-		_rootScope = (parentScope == null)?ret:_rootScope;
-		
-		// Must persist the scope to generate a scope ID
-		getEM().persist(ret);
-		return ret;
-	}
+        _rootScope = (parentScope == null)?ret:_rootScope;
+        
+        // Must persist the scope to generate a scope ID
+        getEM().persist(ret);
+        return ret;
+    }
 
     @SuppressWarnings("unchecked")
     public Collection<CorrelationSetDAO> selectCorrelationSets(Collection<ProcessInstanceDAO>
instances) {
-	    return getEM().createNamedQuery(CorrelationSetDAOImpl.SELECT_CORRELATION_SETS_BY_INSTANCES).setParameter("instances",
instances).getResultList();
-	}
-	
-	public void delete(Set<CLEANUP_CATEGORY> cleanupCategories) {
-		if(__log.isDebugEnabled()) __log.debug("Cleaning up instance Data with " + cleanupCategories);
-		
-		// remove jacob state
-		setExecutionState(null);
-		if (getEM() != null) {
-			if( !cleanupCategories.isEmpty() ) {
-				// by default, we do not flush before select; flush it, so we can delete no matter if
an entity is loaded up
-				// or not; more importantly, OpenJPA will secretly load from the entire table if some
entities reside only
-				// in memory
-				getEM().flush();
-			}
-			
-			if (cleanupCategories.contains(CLEANUP_CATEGORY.EVENTS)) {
-				deleteEvents();
-			}
-			if (cleanupCategories.contains(CLEANUP_CATEGORY.CORRELATIONS)) {
-				deleteCorrelations();
-			}
-			if( cleanupCategories.contains(CLEANUP_CATEGORY.MESSAGES) ) {
-				deleteMessageRoutes();
-			}
-			if (cleanupCategories.contains(CLEANUP_CATEGORY.VARIABLES)) {
-				deleteVariables();
-			}
-			if (cleanupCategories.contains(CLEANUP_CATEGORY.INSTANCE)) {
-				deleteInstance();
-			}
-
-			getEM().flush();
-		}
-	}
-	
-	private void deleteInstance() {
-		if( _fault != null ) {
-			getEM().remove(_fault);
-		}
-		getEM().remove(this); // This deletes ActivityRecoveryDAO 
-	}
-	
-	@SuppressWarnings("unchecked")
-	private void deleteVariables() {
-		Collection xmlDataIds = getEM().createNamedQuery(XmlDataDAOImpl.SELECT_XMLDATA_IDS_BY_INSTANCE).setParameter("instance",
this).getResultList();
-		batchUpdateByIds(xmlDataIds.iterator(), getEM().createNamedQuery(XmlDataProperty.DELETE_XML_DATA_PROPERTIES_BY_XML_DATA_IDS),
"xmlDataIds");
-		Collection scopeIds = getEM().createNamedQuery(ScopeDAOImpl.SELECT_SCOPE_IDS_BY_INSTANCE).setParameter("instance",
this).getResultList();
-		batchUpdateByIds(scopeIds.iterator(), getEM().createNamedQuery(XmlDataDAOImpl.DELETE_XMLDATA_BY_SCOPE_IDS),
"scopeIds");
-
-		batchUpdateByIds(scopeIds.iterator(), getEM().createNamedQuery(PartnerLinkDAOImpl.DELETE_PARTNER_LINKS_BY_SCOPE_IDS),
"scopeIds");
-		batchUpdateByIds(scopeIds.iterator(), getEM().createNamedQuery(ScopeDAOImpl.DELETE_SCOPES_BY_SCOPE_IDS),
"ids");
-	}
-
-	private void deleteMessageRoutes() {
-		getEM().createNamedQuery(MessageRouteDAOImpl.DELETE_MESSAGE_ROUTES_BY_INSTANCE).setParameter
("instance", this).executeUpdate();
-	}
-	
-	@SuppressWarnings("unchecked")
-	private void deleteCorrelations() {
-		Collection corrSetIds = getEM().createNamedQuery(CorrelationSetDAOImpl.SELECT_CORRELATION_SET_IDS_BY_INSTANCE).setParameter("instance",
this).getResultList();
-		batchUpdateByIds(corrSetIds.iterator(), getEM().createNamedQuery(CorrSetProperty.DELETE_CORSET_PROPERTIES_BY_PROPERTY_IDS),
"corrSetIds");
-		batchUpdateByIds(corrSetIds.iterator(), getEM().createNamedQuery(CorrelationSetDAOImpl.DELETE_CORRELATION_SETS_BY_IDS),
"ids");
-	}
-
-	private void deleteEvents() {
-		getEM().createNamedQuery(EventDAOImpl.DELETE_EVENTS_BY_INSTANCE).setParameter ("instance",
this).executeUpdate();
-	}
-	
-	public void deleteActivityRecovery(String channel) {
+        return getEM().createNamedQuery(CorrelationSetDAOImpl.SELECT_CORRELATION_SETS_BY_INSTANCES).setParameter("instances",
instances).getResultList();
+    }
+    
+    public void delete(Set<CLEANUP_CATEGORY> cleanupCategories) {
+        if(__log.isDebugEnabled()) __log.debug("Cleaning up instance Data with " + cleanupCategories);
+        
+        // remove jacob state
+        setExecutionState(null);
+        if (getEM() != null) {
+            if( !cleanupCategories.isEmpty() ) {
+                // by default, we do not flush before select; flush it, so we can delete
no matter if an entity is loaded up
+                // or not; more importantly, OpenJPA will secretly load from the entire table
if some entities reside only
+                // in memory
+                getEM().flush();
+            }
+            
+            if (cleanupCategories.contains(CLEANUP_CATEGORY.EVENTS)) {
+                deleteEvents();
+            }
+            if (cleanupCategories.contains(CLEANUP_CATEGORY.CORRELATIONS)) {
+                deleteCorrelations();
+            }
+            if( cleanupCategories.contains(CLEANUP_CATEGORY.MESSAGES) ) {
+                deleteMessageRoutes();
+            }
+            if (cleanupCategories.contains(CLEANUP_CATEGORY.VARIABLES)) {
+                deleteVariables();
+            }
+            if (cleanupCategories.contains(CLEANUP_CATEGORY.INSTANCE)) {
+                deleteInstance();
+            }
+
+            getEM().flush();
+        }
+    }
+    
+    private void deleteInstance() {
+        if( _fault != null ) {
+            getEM().remove(_fault);
+        }
+        getEM().remove(this); // This deletes ActivityRecoveryDAO 
+    }
+    
+    @SuppressWarnings("unchecked")
+    private void deleteVariables() {
+        Collection xmlDataIds = getEM().createNamedQuery(XmlDataDAOImpl.SELECT_XMLDATA_IDS_BY_INSTANCE).setParameter("instance",
this).getResultList();
+        batchUpdateByIds(xmlDataIds.iterator(), getEM().createNamedQuery(XmlDataProperty.DELETE_XML_DATA_PROPERTIES_BY_XML_DATA_IDS),
"xmlDataIds");
+        Collection scopeIds = getEM().createNamedQuery(ScopeDAOImpl.SELECT_SCOPE_IDS_BY_INSTANCE).setParameter("instance",
this).getResultList();
+        batchUpdateByIds(scopeIds.iterator(), getEM().createNamedQuery(XmlDataDAOImpl.DELETE_XMLDATA_BY_SCOPE_IDS),
"scopeIds");
+
+        batchUpdateByIds(scopeIds.iterator(), getEM().createNamedQuery(PartnerLinkDAOImpl.DELETE_PARTNER_LINKS_BY_SCOPE_IDS),
"scopeIds");
+        batchUpdateByIds(scopeIds.iterator(), getEM().createNamedQuery(ScopeDAOImpl.DELETE_SCOPES_BY_SCOPE_IDS),
"ids");
+    }
+
+    private void deleteMessageRoutes() {
+        getEM().createNamedQuery(MessageRouteDAOImpl.DELETE_MESSAGE_ROUTES_BY_INSTANCE).setParameter
("instance", this).executeUpdate();
+    }
+    
+    @SuppressWarnings("unchecked")
+    private void deleteCorrelations() {
+        Collection corrSetIds = getEM().createNamedQuery(CorrelationSetDAOImpl.SELECT_CORRELATION_SET_IDS_BY_INSTANCE).setParameter("instance",
this).getResultList();
+        batchUpdateByIds(corrSetIds.iterator(), getEM().createNamedQuery(CorrSetProperty.DELETE_CORSET_PROPERTIES_BY_PROPERTY_IDS),
"corrSetIds");
+        batchUpdateByIds(corrSetIds.iterator(), getEM().createNamedQuery(CorrelationSetDAOImpl.DELETE_CORRELATION_SETS_BY_IDS),
"ids");
+    }
+
+    private void deleteEvents() {
+        getEM().createNamedQuery(EventDAOImpl.DELETE_EVENTS_BY_INSTANCE).setParameter ("instance",
this).executeUpdate();
+    }
+    
+    public void deleteActivityRecovery(String channel) {
         ActivityRecoveryDAOImpl toRemove = null;
         for (ActivityRecoveryDAO _recovery : _recoveries) {
             ActivityRecoveryDAOImpl arElement = (ActivityRecoveryDAOImpl) _recovery;
@@ -232,161 +232,161 @@
         }
 
     }
-	
-	public void finishCompletion() {
-	    // make sure we have completed.
-	    assert (ProcessState.isFinished(this.getState()));
-	    // let our process know that we've done our work.
-	}
-
-	public long genMonotonic() {
-		return _sequence++;
-	}
-
-	public int getActivityFailureCount() {
-		if( _activityFailureCount == -1 ) {
-			_activityFailureCount = _recoveries.size();
-		}
-		
-		return _activityFailureCount;
-	}
-	
-	public void setActivityFailureCount(int activityFailureCount) {
-		_activityFailureCount = activityFailureCount;
-	}
-
-	public Date getActivityFailureDateTime() {
-		return _lastRecovery;
-	}
-
-	public Collection<ActivityRecoveryDAO> getActivityRecoveries() {
-		return _recoveries;
-	}
-
-	public CorrelationSetDAO getCorrelationSet(String name) {
-		//	TODO: should this method be deprecated?
-		
-		//  Its not clear where the correlation set for the process is used
-		//  or populated.
-		
-		throw new UnsupportedOperationException();
-		
-		//return null;
-	}
-
-	public Set<CorrelationSetDAO> getCorrelationSets() {
-		//	TODO: should this method be deprecated?
-		//  Its not clear where the correlation set for the process is used
-		//  or populated.
-		return new HashSet<CorrelationSetDAO>();
-	}
-
-	public Date getCreateTime() {
-		return _dateCreated;
-	}
-
-	public EventsFirstLastCountTuple getEventsFirstLastCount() {
-		// TODO Auto-generated method stub
-		return null;
-	}
-
-	public byte[] getExecutionState() {
-		return _executionState;
-	}
-
-	public FaultDAO getFault() {
-		return _fault;
-	}
-
-	public Long getInstanceId() {
-		return _instanceId;
-	}
-
-	public CorrelatorDAO getInstantiatingCorrelator() {
-		return _instantiatingCorrelator;
-	}
-
-	public Date getLastActiveTime() {
-		return _lastActive;
-	}
-
-	public short getPreviousState() {
-		return _previousState;
-	}
-
-	public ProcessDAO getProcess() {
-		return _process;
-	}
-
-	public ScopeDAO getRootScope() {
-		return _rootScope;
-	}
+    
+    public void finishCompletion() {
+        // make sure we have completed.
+        assert (ProcessState.isFinished(this.getState()));
+        // let our process know that we've done our work.
+    }
+
+    public long genMonotonic() {
+        return _sequence++;
+    }
+
+    public int getActivityFailureCount() {
+        if( _activityFailureCount == -1 ) {
+            _activityFailureCount = _recoveries.size();
+        }
+        
+        return _activityFailureCount;
+    }
+    
+    public void setActivityFailureCount(int activityFailureCount) {
+        _activityFailureCount = activityFailureCount;
+    }
+
+    public Date getActivityFailureDateTime() {
+        return _lastRecovery;
+    }
+
+    public Collection<ActivityRecoveryDAO> getActivityRecoveries() {
+        return _recoveries;
+    }
+
+    public CorrelationSetDAO getCorrelationSet(String name) {
+        //    TODO: should this method be deprecated?
+        
+        //  Its not clear where the correlation set for the process is used
+        //  or populated.
+        
+        throw new UnsupportedOperationException();
+        
+        //return null;
+    }
+
+    public Set<CorrelationSetDAO> getCorrelationSets() {
+        //    TODO: should this method be deprecated?
+        //  Its not clear where the correlation set for the process is used
+        //  or populated.
+        return new HashSet<CorrelationSetDAO>();
+    }
+
+    public Date getCreateTime() {
+        return _dateCreated;
+    }
 
-	public ScopeDAO getScope(Long scopeInstanceId) {
+    public EventsFirstLastCountTuple getEventsFirstLastCount() {
+        // TODO Auto-generated method stub
+        return null;
+    }
+
+    public byte[] getExecutionState() {
+        return _executionState;
+    }
+
+    public FaultDAO getFault() {
+        return _fault;
+    }
+
+    public Long getInstanceId() {
+        return _instanceId;
+    }
+
+    public CorrelatorDAO getInstantiatingCorrelator() {
+        return _instantiatingCorrelator;
+    }
+
+    public Date getLastActiveTime() {
+        return _lastActive;
+    }
+
+    public short getPreviousState() {
+        return _previousState;
+    }
+
+    public ProcessDAO getProcess() {
+        return _process;
+    }
+
+    public ScopeDAO getRootScope() {
+        return _rootScope;
+    }
+
+    public ScopeDAO getScope(Long scopeInstanceId) {
         return getEM().find(ScopeDAOImpl.class, scopeInstanceId);
-	}
+    }
+
+    public Collection<ScopeDAO> getScopes(String scopeName) {
+        Collection<ScopeDAO> ret = new ArrayList<ScopeDAO>();
+        
+        for (ScopeDAO sElement : _scopes) {
+            if ( sElement.getName().equals(scopeName)) ret.add(sElement);
+        }
+        return ret;
+    }
+
+    public Collection<ScopeDAO> getScopes() {
+        return _scopes;
+    }
+
+    public short getState() {
+        return _state;
+    }
 
-	public Collection<ScopeDAO> getScopes(String scopeName) {
-		Collection<ScopeDAO> ret = new ArrayList<ScopeDAO>();
-		
-		for (ScopeDAO sElement : _scopes) {
-			if ( sElement.getName().equals(scopeName)) ret.add(sElement);
-		}
-		return ret;
-	}
-
-	public Collection<ScopeDAO> getScopes() {
-		return _scopes;
-	}
-
-	public short getState() {
-		return _state;
-	}
-
-	public XmlDataDAO[] getVariables(String variableName, int scopeModelId) {
-		
-		//TODO: This method is not used and should be considered a deprecation candidate.
-		
-		List<XmlDataDAO> results = new ArrayList<XmlDataDAO>();
-		
-		for (ScopeDAO sElement : _scopes) {
-			if ( sElement.getModelId() == scopeModelId) {
-				XmlDataDAO var = sElement.getVariable(variableName);
-				if ( var != null ) results.add(var);
-			}
-		}
-		return results.toArray(new XmlDataDAO[results.size()]);
-	}
+    public XmlDataDAO[] getVariables(String variableName, int scopeModelId) {
+        
+        //TODO: This method is not used and should be considered a deprecation candidate.
+        
+        List<XmlDataDAO> results = new ArrayList<XmlDataDAO>();
+        
+        for (ScopeDAO sElement : _scopes) {
+            if ( sElement.getModelId() == scopeModelId) {
+                XmlDataDAO var = sElement.getVariable(variableName);
+                if ( var != null ) results.add(var);
+            }
+        }
+        return results.toArray(new XmlDataDAO[results.size()]);
+    }
 
-	public void insertBpelEvent(ProcessInstanceEvent event) {
+    public void insertBpelEvent(ProcessInstanceEvent event) {
         getConn().insertBpelEvent(event, getProcess(), this);
-	}
+    }
 
-	public void setExecutionState(byte[] execState) {
-		_executionState = execState;
-	}
-
-	public void setFault(FaultDAO fault) {
-		_fault = (FaultDAOImpl)fault;
-	}
-
-	public void setFault(QName faultName, String explanation, int faultLineNo,
-			int activityId, Element faultMessage) {
-		_fault = new FaultDAOImpl(faultName,explanation,faultLineNo,activityId,faultMessage);
-	}
-
-	public void setLastActiveTime(Date dt) {
-		_lastActive = dt;
-	}
-
-	public void setState(short state) {
-		_previousState = _state;
-		_state = state;
-	}
-	
-	void removeRoutes(String routeGroupId) {
-		_process.removeRoutes(routeGroupId, this);
-	}
+    public void setExecutionState(byte[] execState) {
+        _executionState = execState;
+    }
+
+    public void setFault(FaultDAO fault) {
+        _fault = (FaultDAOImpl)fault;
+    }
+
+    public void setFault(QName faultName, String explanation, int faultLineNo,
+            int activityId, Element faultMessage) {
+        _fault = new FaultDAOImpl(faultName,explanation,faultLineNo,activityId,faultMessage);
+    }
+
+    public void setLastActiveTime(Date dt) {
+        _lastActive = dt;
+    }
+
+    public void setState(short state) {
+        _previousState = _state;
+        _state = state;
+    }
+    
+    void removeRoutes(String routeGroupId) {
+        _process.removeRoutes(routeGroupId, this);
+    }
 
     public BpelDAOConnection getConnection() {
         return new BPELDAOConnectionImpl(getEM());



Mime
View raw message