commit ed1ca663994d63040e3d979996e6bcc5a212da70
author Yuta HIGUCHI <y-higuchi@ak.jp.nec.com> Thu Aug 11 11:11:37 2016 -0700
committer Gerrit Code Review <gerrit@onlab.us> Thu Aug 11 23:16:58 2016 +0000
tree 5181e5955cc3c8a516a36915127e648d5735ca71
parent 287b9389e2cf4f9c72aea30b070a54b41bae0b84

Attempt to fix sporadic NettyMessagingManagerTest failure.

Change-Id: Iae570c329a3fe0e7e46f9caf13a5b283a2153ed4

core/store/dist/src/main/java/org/onosproject/store/cluster/messaging/impl/NettyMessagingManager.java

diff --git a/core/store/dist/src/main/java/org/onosproject/store/cluster/messaging/impl/NettyMessagingManager.java b/core/store/dist/src/main/java/org/onosproject/store/cluster/messaging/impl/NettyMessagingManager.java
index aefea6c..4f303a5 100644
--- a/core/store/dist/src/main/java/org/onosproject/store/cluster/messaging/impl/NettyMessagingManager.java
+++ b/core/store/dist/src/main/java/org/onosproject/store/cluster/messaging/impl/NettyMessagingManager.java
@@ -280,7 +280,7 @@
             if (e != null) {
                 callbacks.invalidate(messageId);
             }
-        }).thenCompose(v -> response);
+        }).thenComposeAsync(v -> response, executor);
     }
 
     @Override