You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ode.apache.org by bo...@apache.org on 2007/12/06 22:11:03 UTC
svn commit: r601857 -
/ode/branches/APACHE_ODE_1.1/bpel-runtime/src/main/java/org/apache/ode/bpel/runtime/INVOKE.java
Author: boisvert
Date: Thu Dec 6 13:11:01 2007
New Revision: 601857
URL: http://svn.apache.org/viewvc?rev=601857&view=rev
Log:
Remove dead code; moved to ACTIVITYGUARD
Modified:
ode/branches/APACHE_ODE_1.1/bpel-runtime/src/main/java/org/apache/ode/bpel/runtime/INVOKE.java
Modified: ode/branches/APACHE_ODE_1.1/bpel-runtime/src/main/java/org/apache/ode/bpel/runtime/INVOKE.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.1/bpel-runtime/src/main/java/org/apache/ode/bpel/runtime/INVOKE.java?rev=601857&r1=601856&r2=601857&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.1/bpel-runtime/src/main/java/org/apache/ode/bpel/runtime/INVOKE.java (original)
+++ ode/branches/APACHE_ODE_1.1/bpel-runtime/src/main/java/org/apache/ode/bpel/runtime/INVOKE.java Thu Dec 6 13:11:01 2007
@@ -199,54 +199,6 @@
} else return null;
}
- private void retryOrFailure(String reason, Element data) {
- _lastFailure = new Date();
- _failureReason = reason;
- _failureData = data;
-
- OFailureHandling failureHandling = _oinvoke.getFailureHandling();
- if (failureHandling != null && failureHandling.faultOnFailure) {
- // No attempt to retry or enter activity recovery state, simply fault.
- if (__log.isDebugEnabled())
- __log.debug("ActivityRecovery: Invoke activity " + _self.aId + " faulting on failure");
- FaultData faultData = createFault(OFailureHandling.FAILURE_FAULT_NAME, _oinvoke, reason);
- _self.parent.completed(faultData, CompensationHandler.emptySet());
- return;
- }
- // If maximum number of retries, enter activity recovery state.
- if (failureHandling == null || _invoked > failureHandling.retryFor) {
- requireRecovery();
- return;
- }
-
- if (__log.isDebugEnabled())
- __log.debug("ActivityRecovery: Retrying invoke activity " + _self.aId);
- Date future = new Date(new Date().getTime() +
- (failureHandling == null ? 0L : failureHandling.retryDelay * 1000));
- final TimerResponseChannel timerChannel = newChannel(TimerResponseChannel.class);
- getBpelRuntimeContext().registerTimer(timerChannel, future);
- object(false, new TimerResponseChannelListener(timerChannel) {
- private static final long serialVersionUID = -261911108068231376L;
- public void onTimeout() {
- instance(INVOKE.this);
- }
- public void onCancel() {
- INVOKE.this.requireRecovery();
- }
- }.or(new TerminationChannelListener(_self.self) {
- private static final long serialVersionUID = -4416795170896911290L;
-
- public void terminate() {
- _self.parent.completed(null, CompensationHandler.emptySet());
- object(new TimerResponseChannelListener(timerChannel) {
- private static final long serialVersionUID = 4822348066868313717L;
- public void onTimeout() { }
- public void onCancel() { }
- });
- }
- }));
- }
-
private void requireRecovery() {
if (__log.isDebugEnabled())
__log.debug("ActivityRecovery: Invoke activity " + _self.aId + " requires recovery");