Author: mszefler
Date: Thu Aug 2 10:42:18 2007
New Revision: 562193
URL: http://svn.apache.org/viewvc?view=rev&rev=562193
Log:
BART tweaks
Modified:
ode/branches/bart/bpel-dao/src/main/java/org/apache/ode/bpel/dao/BpelDAOConnection.java
ode/branches/bart/bpel-dao/src/main/java/org/apache/ode/bpel/dao/MessageExchangeDAO.java
Modified:
ode/branches/bart/bpel-dao/src/main/java/org/apache/ode/bpel/dao/BpelDAOConnection.java
URL:
http://svn.apache.org/viewvc/ode/branches/bart/bpel-dao/src/main/java/org/apache/ode/bpel/dao/BpelDAOConnection.java?view=diff&rev=562193&r1=562192&r2=562193
==============================================================================
---
ode/branches/bart/bpel-dao/src/main/java/org/apache/ode/bpel/dao/BpelDAOConnection.java
(original)
+++
ode/branches/bart/bpel-dao/src/main/java/org/apache/ode/bpel/dao/BpelDAOConnection.java
Thu Aug 2 10:42:18 2007
@@ -27,82 +27,96 @@
import java.util.Date;
import java.util.List;
-
/**
* Represents the physical resource for connecting to the bpel state store.
*/
-public interface BpelDAOConnection {
- /**
- * Return the DAO for a bpel process.
- *
- * @param processId name (identifier) of the process
- *
- * @return DAO
- */
- ProcessDAO getProcess(QName processId);
-
-
- /**
- * Retrieve a process instance from the database.
- * @param iid instance identifier
- * @return process instance
- */
- ProcessInstanceDAO getInstance(Long iid);
-
- /**
- * Retrieve a scope instance from the database.
- * @param siidl scope instance identifier
- * @return scope instance
- */
- ScopeDAO getScope(Long siidl);
-
- /**
- * Query instances in the database meeting the requested
- * criteria.
- * @param criteria
- * @return Collection<ProcessInstanceDAO>
- */
- Collection<ProcessInstanceDAO> instanceQuery(InstanceFilter criteria);
-
- /**
- * Insert a BPEL event into the database.
- * @param event a BPEL event
- * @param process associated process (optional)
- * @param instance associated instance (optional)
- */
- void insertBpelEvent(BpelEvent event, ProcessDAO process,
- ProcessInstanceDAO instance);
-
- /**
- * Execute a query for the timeline for BPEL events matching the criteria.
- * @param ifilter instance filter (optional)
- * @param efilter event filter (optional)
- * @return List of event timestamps of events matching the criteria
- */
- List<Date> bpelEventTimelineQuery(InstanceFilter ifilter, BpelEventFilter
efilter);
-
- /**
- * Execute a query to retrieve the BPEL events matching the criteria.
- * @param ifilter instance filter
- * @param efilter event filter
- * @return
- */
- List<BpelEvent> bpelEventQuery(InstanceFilter ifilter, BpelEventFilter
efilter);
-
- void close();
-
- Collection<ProcessInstanceDAO> instanceQuery(String expression);
-
- ProcessDAO createProcess(QName pid, QName type, String guid, long version);
-
-
- /**
- * Create a message exchange.
- * @param dir type of message exchange
- * @return
- */
- MessageExchangeDAO createMessageExchange(char dir);
+public interface BpelDAOConnection {
+ /**
+ * Return the DAO for a bpel process.
+ *
+ * @param processId
+ * name (identifier) of the process
+ *
+ * @return DAO
+ */
+ ProcessDAO getProcess(QName processId);
+
+ /**
+ * Retrieve a process instance from the database.
+ *
+ * @param iid
+ * instance identifier
+ * @return process instance
+ */
+ ProcessInstanceDAO getInstance(Long iid);
+
+ /**
+ * Retrieve a scope instance from the database.
+ *
+ * @param siidl
+ * scope instance identifier
+ * @return scope instance
+ */
+ ScopeDAO getScope(Long siidl);
+
+ /**
+ * Query instances in the database meeting the requested criteria.
+ *
+ * @param criteria
+ * @return Collection<ProcessInstanceDAO>
+ */
+ Collection<ProcessInstanceDAO> instanceQuery(InstanceFilter criteria);
+
+ /**
+ * Insert a BPEL event into the database.
+ *
+ * @param event
+ * a BPEL event
+ * @param process
+ * associated process (optional)
+ * @param instance
+ * associated instance (optional)
+ */
+ void insertBpelEvent(BpelEvent event, ProcessDAO process,
ProcessInstanceDAO instance);
+
+ /**
+ * Execute a query for the timeline for BPEL events matching the criteria.
+ *
+ * @param ifilter
+ * instance filter (optional)
+ * @param efilter
+ * event filter (optional)
+ * @return List of event timestamps of events matching the criteria
+ */
+ List<Date> bpelEventTimelineQuery(InstanceFilter ifilter, BpelEventFilter
efilter);
+
+ /**
+ * Execute a query to retrieve the BPEL events matching the criteria.
+ *
+ * @param ifilter
+ * instance filter
+ * @param efilter
+ * event filter
+ * @return
+ */
+ List<BpelEvent> bpelEventQuery(InstanceFilter ifilter, BpelEventFilter
efilter);
+
+ void close();
+
+ Collection<ProcessInstanceDAO> instanceQuery(String expression);
+
+ ProcessDAO createProcess(QName pid, QName type, String guid, long version);
+
+ /**
+ * Create a message exchange.
+ *
+ * @param mexId message exchange id (application-assigned)
+ * @param dir
+ * type of message exchange
+ * @return
+ */
+ MessageExchangeDAO createMessageExchange(String mexId, char dir);
- MessageExchangeDAO getMessageExchange(String mexid);
+ MessageExchangeDAO getMessageExchange(String mexid);
}
Modified:
ode/branches/bart/bpel-dao/src/main/java/org/apache/ode/bpel/dao/MessageExchangeDAO.java
URL:
http://svn.apache.org/viewvc/ode/branches/bart/bpel-dao/src/main/java/org/apache/ode/bpel/dao/MessageExchangeDAO.java?view=diff&rev=562193&r1=562192&r2=562193
==============================================================================
---
ode/branches/bart/bpel-dao/src/main/java/org/apache/ode/bpel/dao/MessageExchangeDAO.java
(original)
+++
ode/branches/bart/bpel-dao/src/main/java/org/apache/ode/bpel/dao/MessageExchangeDAO.java
Thu Aug 2 10:42:18 2007
@@ -258,8 +258,11 @@
void setFailureType(String failureType);
+ String getFailureType();
+
long getTimeout();
void setTimeout(long timeout);
+
}
