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