diff --git a/payment/src/main/java/org/killbill/billing/payment/core/janitor/AttemptCompletionTask.java b/payment/src/main/java/org/killbill/billing/payment/core/janitor/AttemptCompletionTask.java
index e3d4018..fe0d6b1 100644
--- a/payment/src/main/java/org/killbill/billing/payment/core/janitor/AttemptCompletionTask.java
+++ b/payment/src/main/java/org/killbill/billing/payment/core/janitor/AttemptCompletionTask.java
@@ -112,7 +112,7 @@ final class AttemptCompletionTask extends CompletionTaskBase<PaymentAttemptModel
paymentStateContext.setAttemptId(attempt.getId()); // Normally set by leavingState Callback
paymentStateContext.setPaymentTransactionModelDao(transaction); // Normally set by raw state machine
//
- // Will rerun the state machine with special callbacks to only make the onCompletion call
+ // Will rerun the state machine with special callbacks to only make the executePluginOnSuccessCalls call
// to the PaymentControlPluginApi plugin and transition the state.
//
pluginControlledPaymentAutomatonRunner.completeRun(paymentStateContext);
diff --git a/payment/src/main/java/org/killbill/billing/payment/core/sm/RetryCompletionOperationCallback.java b/payment/src/main/java/org/killbill/billing/payment/core/sm/RetryCompletionOperationCallback.java
index 8b6a41a..689ac9b 100644
--- a/payment/src/main/java/org/killbill/billing/payment/core/sm/RetryCompletionOperationCallback.java
+++ b/payment/src/main/java/org/killbill/billing/payment/core/sm/RetryCompletionOperationCallback.java
@@ -60,7 +60,7 @@ public class RetryCompletionOperationCallback extends RetryOperationCallback {
retryablePaymentStateContext.isApiPayment(),
paymentStateContext.callContext);
- onCompletion(retryablePaymentStateContext.getPaymentControlPluginNames(), updatedPaymentControlContext);
+ executePluginOnSuccessCalls(retryablePaymentStateContext.getPaymentControlPluginNames(), updatedPaymentControlContext);
return PluginDispatcher.createPluginDispatcherReturnType(OperationResult.SUCCESS);
}
});
diff --git a/payment/src/main/java/org/killbill/billing/payment/core/sm/RetryOperationCallback.java b/payment/src/main/java/org/killbill/billing/payment/core/sm/RetryOperationCallback.java
index c9fb5b1..7c8ba21 100644
--- a/payment/src/main/java/org/killbill/billing/payment/core/sm/RetryOperationCallback.java
+++ b/payment/src/main/java/org/killbill/billing/payment/core/sm/RetryOperationCallback.java
@@ -95,7 +95,7 @@ public abstract class RetryOperationCallback extends OperationCallbackBase<Payme
final PriorPaymentRoutingResult pluginResult;
try {
- pluginResult = getPluginResult(retryablePaymentStateContext.getPaymentControlPluginNames(), paymentControlContext);
+ pluginResult = executePluginPriorCalls(retryablePaymentStateContext.getPaymentControlPluginNames(), paymentControlContext);
if (pluginResult != null && pluginResult.isAborted()) {
// Transition to ABORTED
return PluginDispatcher.createPluginDispatcherReturnType(OperationResult.EXCEPTION);
@@ -132,17 +132,17 @@ public abstract class RetryOperationCallback extends OperationCallbackBase<Payme
retryablePaymentStateContext.isApiPayment(),
paymentStateContext.callContext);
- onCompletion(retryablePaymentStateContext.getPaymentControlPluginNames(), updatedPaymentRoutingContext);
+ executePluginOnSuccessCalls(retryablePaymentStateContext.getPaymentControlPluginNames(), updatedPaymentRoutingContext);
return PluginDispatcher.createPluginDispatcherReturnType(OperationResult.SUCCESS);
} else {
- throw new OperationException(null, getOperationResultAndSetContext(retryablePaymentStateContext, paymentControlContext));
+ throw new OperationException(null, executePluginOnFailureCallsAndSetRetryDate(retryablePaymentStateContext, paymentControlContext));
}
} catch (final PaymentApiException e) {
// Wrap PaymentApiException, and throw a new OperationException with an ABORTED/FAILURE state based on the retry result.
- throw new OperationException(e, getOperationResultAndSetContext(retryablePaymentStateContext, paymentControlContext));
+ throw new OperationException(e, executePluginOnFailureCallsAndSetRetryDate(retryablePaymentStateContext, paymentControlContext));
} catch (final RuntimeException e) {
// Attempts to set the retry date in context if needed.
- getOperationResultAndSetContext(retryablePaymentStateContext, paymentControlContext);
+ executePluginOnFailureCallsAndSetRetryDate(retryablePaymentStateContext, paymentControlContext);
throw e;
}
}
@@ -175,14 +175,14 @@ public abstract class RetryOperationCallback extends OperationCallbackBase<Payme
return new OperationException(e, getOperationResultOnException(paymentStateContext));
}
- protected void onCompletion(final List<String> paymentControlPluginNames, final PaymentRoutingContext paymentControlContext) {
+ protected void executePluginOnSuccessCalls(final List<String> paymentControlPluginNames, final PaymentRoutingContext paymentControlContext) {
for (final String pluginName : paymentControlPluginNames) {
final PaymentRoutingPluginApi plugin = paymentControlPluginRegistry.getServiceForName(pluginName);
if (plugin != null) {
try {
plugin.onSuccessCall(paymentControlContext, paymentStateContext.getProperties());
} catch (final PaymentRoutingApiException e) {
- logger.warn("Plugin " + pluginName + " failed to complete onCompletion call for " + paymentControlContext.getPaymentExternalKey(), e);
+ logger.warn("Plugin " + pluginName + " failed to complete executePluginOnSuccessCalls call for " + paymentControlContext.getPaymentExternalKey(), e);
}
}
}
@@ -214,7 +214,7 @@ public abstract class RetryOperationCallback extends OperationCallbackBase<Payme
return operationResult;
}
- private PriorPaymentRoutingResult getPluginResult(final List<String> paymentControlPluginNames, final PaymentRoutingContext paymentControlContextArg) throws PaymentRoutingApiException {
+ private PriorPaymentRoutingResult executePluginPriorCalls(final List<String> paymentControlPluginNames, final PaymentRoutingContext paymentControlContextArg) throws PaymentRoutingApiException {
// Return as soon as the first plugin aborts, or the last result for the last plugin
PriorPaymentRoutingResult prevResult = null;
@@ -248,8 +248,8 @@ public abstract class RetryOperationCallback extends OperationCallbackBase<Payme
return prevResult;
}
- private OperationResult getOperationResultAndSetContext(final RetryablePaymentStateContext retryablePaymentStateContext, final PaymentRoutingContext paymentControlContext) {
- final DateTime retryDate = getNextRetryDate(retryablePaymentStateContext.getPaymentControlPluginNames(), paymentControlContext);
+ private OperationResult executePluginOnFailureCallsAndSetRetryDate(final RetryablePaymentStateContext retryablePaymentStateContext, final PaymentRoutingContext paymentControlContext) {
+ final DateTime retryDate = executePluginOnFailureCalls(retryablePaymentStateContext.getPaymentControlPluginNames(), paymentControlContext);
if (retryDate != null) {
((RetryablePaymentStateContext) paymentStateContext).setRetryDate(retryDate);
return OperationResult.FAILURE;
@@ -258,7 +258,7 @@ public abstract class RetryOperationCallback extends OperationCallbackBase<Payme
}
}
- private DateTime getNextRetryDate(final List<String> paymentControlPluginNames, final PaymentRoutingContext paymentControlContext) {
+ private DateTime executePluginOnFailureCalls(final List<String> paymentControlPluginNames, final PaymentRoutingContext paymentControlContext) {
DateTime candidate = null;
for (final String pluginName : paymentControlPluginNames) {
final PaymentRoutingPluginApi plugin = paymentControlPluginRegistry.getServiceForName(pluginName);