You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ode.apache.org by ms...@apache.org on 2007/08/06 22:56:05 UTC
svn commit: r563276 - in
/ode/branches/bart/dao-hibernate/src/main/java/org/apache/ode/daohib/bpel:
MessageExchangeDaoImpl.java hobj/HMessageExchange.java
Author: mszefler
Date: Mon Aug 6 13:56:04 2007
New Revision: 563276
URL: http://svn.apache.org/viewvc?view=rev&rev=563276
Log:
BART, some additinal refactorings. New model to fix concurrency problems in Partner invokes.
Modified:
ode/branches/bart/dao-hibernate/src/main/java/org/apache/ode/daohib/bpel/MessageExchangeDaoImpl.java
ode/branches/bart/dao-hibernate/src/main/java/org/apache/ode/daohib/bpel/hobj/HMessageExchange.java
Modified: ode/branches/bart/dao-hibernate/src/main/java/org/apache/ode/daohib/bpel/MessageExchangeDaoImpl.java
URL: http://svn.apache.org/viewvc/ode/branches/bart/dao-hibernate/src/main/java/org/apache/ode/daohib/bpel/MessageExchangeDaoImpl.java?view=diff&rev=563276&r1=563275&r2=563276
==============================================================================
--- ode/branches/bart/dao-hibernate/src/main/java/org/apache/ode/daohib/bpel/MessageExchangeDaoImpl.java (original)
+++ ode/branches/bart/dao-hibernate/src/main/java/org/apache/ode/daohib/bpel/MessageExchangeDaoImpl.java Mon Aug 6 13:56:04 2007
@@ -30,6 +30,7 @@
import org.apache.ode.bpel.dao.PartnerLinkDAO;
import org.apache.ode.bpel.dao.ProcessDAO;
import org.apache.ode.bpel.dao.ProcessInstanceDAO;
+import org.apache.ode.bpel.iapi.MessageExchange.AckType;
import org.apache.ode.daohib.SessionManager;
import org.apache.ode.daohib.bpel.hobj.HLargeData;
import org.apache.ode.daohib.bpel.hobj.HMessage;
@@ -334,5 +335,13 @@
public void setTimeout(long timeout) {
_hself.setTimeout(timeout);
+ }
+
+ public AckType getAckType() {
+ return _hself.getAckType() == null ? null : AckType.valueOf(_hself.getAckType());
+ }
+
+ public void setAckType(AckType ackType) {
+ _hself.setAckType(ackType == null ? null : ackType.toString());
}
}
Modified: ode/branches/bart/dao-hibernate/src/main/java/org/apache/ode/daohib/bpel/hobj/HMessageExchange.java
URL: http://svn.apache.org/viewvc/ode/branches/bart/dao-hibernate/src/main/java/org/apache/ode/daohib/bpel/hobj/HMessageExchange.java?view=diff&rev=563276&r1=563275&r2=563276
==============================================================================
--- ode/branches/bart/dao-hibernate/src/main/java/org/apache/ode/daohib/bpel/hobj/HMessageExchange.java (original)
+++ ode/branches/bart/dao-hibernate/src/main/java/org/apache/ode/daohib/bpel/hobj/HMessageExchange.java Mon Aug 6 13:56:04 2007
@@ -22,6 +22,8 @@
import java.util.HashMap;
import java.util.Map;
+import org.apache.ode.bpel.iapi.MessageExchange.AckType;
+
/**
* Hibernate-managed table for keeping track of message exchanges.
*
@@ -81,6 +83,8 @@
private String _mexId;
+ private String _ackType;
+
/**
*
*/
@@ -391,4 +395,15 @@
_istyle = invocationStyle;
}
+ /**
+ * @hibernate.property column="ACK_TYPE"
+ * @return
+ */
+ public String getAckType() {
+ return _ackType;
+ }
+
+ public void setAckType(String ackType) {
+ _ackType = ackType;
+ }
}