BUG 2676 : Use custom client-dispatcher when configured

[controller.git] / opendaylight / md-sal / sal-distributed-datastore / src / main / java / org / opendaylight / controller / cluster / datastore / ThreePhaseCommitCohortProxy.java

diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ThreePhaseCommitCohortProxy.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ThreePhaseCommitCohortProxy.java
index c51ea80726e54d9cf656e193ca8521d242206c76..4445b14e2edc1b48b5c92012e8a659275357f433 100644 (file)
--- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ThreePhaseCommitCohortProxy.java
+++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ThreePhaseCommitCohortProxy.java
@@ -71,7 +71,7 @@ public class ThreePhaseCommitCohortProxy implements DOMStoreThreePhaseCommitCoho
     private Future<Void> buildCohortList() {
 
         Future<Iterable<ActorSelection>> combinedFutures = Futures.sequence(cohortFutures,
     private Future<Void> buildCohortList() {
 
         Future<Iterable<ActorSelection>> combinedFutures = Futures.sequence(cohortFutures,

-                actorContext.getActorSystem().dispatcher());
+                actorContext.getClientDispatcher());

 
         return combinedFutures.transform(new AbstractFunction1<Iterable<ActorSelection>, Void>() {
             @Override
 
         return combinedFutures.transform(new AbstractFunction1<Iterable<ActorSelection>, Void>() {
             @Override


@@ -83,7 +83,7 @@ public class ThreePhaseCommitCohortProxy implements DOMStoreThreePhaseCommitCoho
                 }
                 return null;
             }
                 }
                 return null;
             }

-        }, TransactionProxy.SAME_FAILURE_TRANSFORMER, actorContext.getActorSystem().dispatcher());
+        }, TransactionProxy.SAME_FAILURE_TRANSFORMER, actorContext.getClientDispatcher());

     }
 
     @Override
     }
 
     @Override


@@ -111,7 +111,7 @@ public class ThreePhaseCommitCohortProxy implements DOMStoreThreePhaseCommitCoho
                     finishCanCommit(returnFuture);
                 }
             }
                     finishCanCommit(returnFuture);
                 }
             }

-        }, actorContext.getActorSystem().dispatcher());
+        }, actorContext.getClientDispatcher());

 
         return returnFuture;
     }
 
         return returnFuture;
     }


@@ -158,7 +158,7 @@ public class ThreePhaseCommitCohortProxy implements DOMStoreThreePhaseCommitCoho
                 }
                 returnFuture.set(Boolean.valueOf(result));
             }
                 }
                 returnFuture.set(Boolean.valueOf(result));
             }

-        }, actorContext.getActorSystem().dispatcher());
+        }, actorContext.getClientDispatcher());

     }
 
     private Future<Iterable<Object>> invokeCohorts(Object message) {
     }
 
     private Future<Iterable<Object>> invokeCohorts(Object message) {


@@ -170,7 +170,7 @@ public class ThreePhaseCommitCohortProxy implements DOMStoreThreePhaseCommitCoho
             futureList.add(actorContext.executeOperationAsync(cohort, message, actorContext.getTransactionCommitOperationTimeout()));
         }
 
             futureList.add(actorContext.executeOperationAsync(cohort, message, actorContext.getTransactionCommitOperationTimeout()));
         }
 

-        return Futures.sequence(futureList, actorContext.getActorSystem().dispatcher());
+        return Futures.sequence(futureList, actorContext.getClientDispatcher());

     }
 
     @Override
     }
 
     @Override


@@ -239,7 +239,7 @@ public class ThreePhaseCommitCohortProxy implements DOMStoreThreePhaseCommitCoho
                                 propagateException, returnFuture, callback);
                     }
                 }
                                 propagateException, returnFuture, callback);
                     }
                 }

-            }, actorContext.getActorSystem().dispatcher());
+            }, actorContext.getClientDispatcher());

         }
 
         return returnFuture;
         }
 
         return returnFuture;


@@ -304,7 +304,7 @@ public class ThreePhaseCommitCohortProxy implements DOMStoreThreePhaseCommitCoho
                     callback.success();
                 }
             }
                     callback.success();
                 }
             }

-        }, actorContext.getActorSystem().dispatcher());
+        }, actorContext.getClientDispatcher());

     }
 
     @VisibleForTesting
     }
 
     @VisibleForTesting