- });
- ListenableFuture<RpcResult<Void>> commitBundleFuture = Futures.transformAsync(addBundleMessagesFuture,
- rpcResult -> {
- if (rpcResult.isSuccessful()) {
- return JdkFutureAdapters
- .listenInPoolThread(salBundleService.controlBundle(commitBundleInput));
- }
- return Futures.immediateFuture(null);
- });
+ }, MoreExecutors.directExecutor());
+
+ /* Commit the bundle on the openflow switch */
+ ListenableFuture<RpcResult<ControlBundleOutput>> commitBundleFuture
+ = Futures.transformAsync(addBundleMessagesFuture, rpcResult -> {
+ if (rpcResult.isSuccessful()) {
+ return salBundleService.controlBundle(commitBundleInput);
+ }
+ return Futures.immediateFuture(null);
+ }, MoreExecutors.directExecutor());