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/07 20:40:09 UTC
svn commit: r563614 -
/ode/branches/bart/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/MyRoleMessageExchangeImpl.java
Author: mszefler
Date: Tue Aug 7 11:40:09 2007
New Revision: 563614
URL: http://svn.apache.org/viewvc?view=rev&rev=563614
Log:
BART: Update JBI to use UNRELIABLE instead of BLOCKING/ASYNC
Modified:
ode/branches/bart/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/MyRoleMessageExchangeImpl.java
Modified: ode/branches/bart/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/MyRoleMessageExchangeImpl.java
URL: http://svn.apache.org/viewvc/ode/branches/bart/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/MyRoleMessageExchangeImpl.java?view=diff&rev=563614&r1=563613&r2=563614
==============================================================================
--- ode/branches/bart/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/MyRoleMessageExchangeImpl.java (original)
+++ ode/branches/bart/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/MyRoleMessageExchangeImpl.java Tue Aug 7 11:40:09 2007
@@ -65,6 +65,13 @@
}
+ public FailureType getFailureType() {
+ if (getStatus() != Status.ACK || getAckType() != AckType.FAILURE)
+ throw new IllegalStateException("MessageExchange did not fail!");
+
+ return _failureType;
+ }
+
public String getClientId() {
return _clientId;
}