Clean up

[bgpcep.git] / pcep / topology-provider / src / main / java / org / opendaylight / bgpcep / pcep / topology / provider / TopologyNodeState.java

diff --git a/pcep/topology-provider/src/main/java/org/opendaylight/bgpcep/pcep/topology/provider/TopologyNodeState.java b/pcep/topology-provider/src/main/java/org/opendaylight/bgpcep/pcep/topology/provider/TopologyNodeState.java
index b9403da534b15501996713a113cb35d59257def4..607c3ce35bf33aa85f88adf2a45cc10063992213 100644 (file)
--- a/pcep/topology-provider/src/main/java/org/opendaylight/bgpcep/pcep/topology/provider/TopologyNodeState.java
+++ b/pcep/topology-provider/src/main/java/org/opendaylight/bgpcep/pcep/topology/provider/TopologyNodeState.java
@@ -12,6 +12,7 @@ import com.google.common.base.Preconditions;
 import com.google.common.util.concurrent.FutureCallback;
 import com.google.common.util.concurrent.Futures;
 import com.google.common.util.concurrent.ListenableFuture;
+import com.google.common.util.concurrent.MoreExecutors;
 import java.util.Collection;
 import java.util.HashMap;
 import java.util.Map;
@@ -91,7 +92,7 @@ final class TopologyNodeState implements AutoCloseable, TransactionChainListener
                 public void onFailure(final Throwable t) {
                     LOG.error("Failed to cleanup internal state for session {}", TopologyNodeState.this.nodeId, t);
                 }
-            });
+            }, MoreExecutors.directExecutor());
         }
 
         this.lastReleased = System.nanoTime();
@@ -122,7 +123,7 @@ final class TopologyNodeState implements AutoCloseable, TransactionChainListener
                 public void onFailure(final Throwable t) {
                     LOG.error("Failed to get topology node {}", TopologyNodeState.this.nodeId, t);
                 }
-            });
+            }, MoreExecutors.directExecutor());
         } else {
             putTopologyNode();
         }