Refactor to avoid trivial errors in transactions

Include Fixing a bug not to commit the transaction on success

Change-Id: Ie1f823ab6d8fc6f54091d443d24ecc61336155da

@@ -96,16 +96,14 @@ public class ConsistentResourceStore implements ResourceStore {
                 ResourceConsumer existing = txMap.putIfAbsent(resource, consumer);
                 ResourceConsumer existing = txMap.putIfAbsent(resource, consumer);
                 // if the resource is already allocated to another consumer, the whole allocation fails
                 // if the resource is already allocated to another consumer, the whole allocation fails
                 if (existing != null) {
                 if (existing != null) {
-                    tx.abort();
-                    return false;
+                    return abortTransaction(tx);
                 }
                 }
             }
             }
-            tx.commit();
-            return true;
+
+            return commitTransaction(tx);
         } catch (TransactionException e) {
         } catch (TransactionException e) {
             log.error("Exception thrown, abort the transaction", e);
             log.error("Exception thrown, abort the transaction", e);
-            tx.abort();
-            return false;
+            return abortTransaction(tx);
         }
         }
     }
     }
 
 
@@ -130,16 +128,14 @@ public class ConsistentResourceStore implements ResourceStore {
                 // if this single release fails (because the resource is allocated to another consumer,
                 // if this single release fails (because the resource is allocated to another consumer,
                 // the whole release fails
                 // the whole release fails
                 if (!txMap.remove(resource, consumer)) {
                 if (!txMap.remove(resource, consumer)) {
-                    tx.abort();
-                    return false;
+                    return abortTransaction(tx);
                 }
                 }
             }
             }
 
 
-            return true;
+            return commitTransaction(tx);
         } catch (TransactionException e) {
         } catch (TransactionException e) {
             log.error("Exception thrown, abort the transaction", e);
             log.error("Exception thrown, abort the transaction", e);
-            tx.abort();
-            return false;
+            return abortTransaction(tx);
         }
         }
     }
     }
 
 
@@ -169,4 +165,26 @@ public class ConsistentResourceStore implements ResourceStore {
                 .map(x -> (Resource<S, T>) x.getKey())
                 .map(x -> (Resource<S, T>) x.getKey())
                 .collect(Collectors.toList());
                 .collect(Collectors.toList());
     }
     }
+
+    /**
+     * Abort the transaction.
+     *
+     * @param tx transaction context
+     * @return always false
+     */
+    private boolean abortTransaction(TransactionContext tx) {
+        tx.abort();
+        return false;
+    }
+
+    /**
+     * Commit the transaction.
+     *
+     * @param tx transaction context
+     * @return always true
+     */
+    private boolean commitTransaction(TransactionContext tx) {
+        tx.commit();
+        return true;
+    }
 }
 }