ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From yzhda...@apache.org
Subject [31/50] [abbrv] incubator-ignite git commit: IGNITE-142 Rename IgniteAsyncSupport.enableAsync() to IgniteAsyncSupport.withAsync()
Date Wed, 28 Jan 2015 13:51:09 GMT
IGNITE-142 Rename IgniteAsyncSupport.enableAsync() to IgniteAsyncSupport.withAsync()


Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/bceabb1d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/bceabb1d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/bceabb1d

Branch: refs/heads/ignite-113
Commit: bceabb1d167c825250994fb5995d2167bb1dd22d
Parents: 0e110c0
Author: sevdokimov <sevdokimov@gridgain.com>
Authored: Wed Jan 28 13:29:56 2015 +0300
Committer: sevdokimov <sevdokimov@gridgain.com>
Committed: Wed Jan 28 13:29:56 2015 +0300

----------------------------------------------------------------------
 .../ComputeFibonacciContinuationExample.java    |  2 +-
 .../compute/ComputeRunnableExample.java         |  2 +-
 .../singlesplit/SingleSplitsLoadTest.java       |  2 +-
 .../ignite/client/ClientStartNodeTask.java      |  2 +-
 .../java/org/apache/ignite/IgniteCache.java     |  2 +-
 .../java/org/apache/ignite/IgniteCluster.java   |  2 +-
 .../java/org/apache/ignite/IgniteCompute.java   |  2 +-
 .../java/org/apache/ignite/IgniteEvents.java    |  2 +-
 .../main/java/org/apache/ignite/IgniteFs.java   |  2 +-
 .../java/org/apache/ignite/IgniteManaged.java   |  2 +-
 .../java/org/apache/ignite/IgniteMessaging.java |  2 +-
 .../org/apache/ignite/internal/GridKernal.java  |  2 +-
 .../ignite/internal/IgniteManagedImpl.java      |  2 +-
 .../internal/executor/GridExecutorService.java  |  2 +-
 .../processors/cache/GridCacheAdapter.java      |  5 +--
 .../cache/transactions/IgniteTxAdapter.java     |  6 ++--
 .../cache/transactions/IgniteTxProxyImpl.java   |  2 +-
 .../internal/processors/fs/GridGgfsImpl.java    |  2 +-
 .../handlers/cache/GridCacheCommandHandler.java |  4 +--
 .../cache/GridCacheQueryCommandHandler.java     |  4 +--
 .../handlers/task/GridTaskCommandHandler.java   |  4 +--
 .../apache/ignite/lang/IgniteAsyncSupport.java  |  2 +-
 .../ignite/lang/IgniteAsyncSupportAdapter.java  |  2 +-
 .../ignite/lang/IgniteAsyncSupported.java       |  2 +-
 .../internal/GridCancelOnGridStopSelfTest.java  |  2 +-
 .../GridCancelledJobsMetricsSelfTest.java       |  2 +-
 .../internal/GridContinuousTaskSelfTest.java    |  4 +--
 .../GridEventStorageCheckAllEventsSelfTest.java |  2 +-
 .../GridFailoverCustomTopologySelfTest.java     |  2 +-
 .../GridJobMasterLeaveAwareSelfTest.java        | 34 ++++++++++----------
 .../internal/GridMultipleJobsSelfTest.java      |  2 +-
 .../internal/GridProjectionAbstractTest.java    | 20 ++++++------
 .../ignite/internal/GridReduceSelfTest.java     |  2 +-
 .../GridTaskCancelSingleNodeSelfTest.java       |  2 +-
 .../internal/GridTaskExecutionSelfTest.java     |  2 +-
 .../GridTaskInstanceExecutionSelfTest.java      |  2 +-
 .../internal/GridTaskJobRejectSelfTest.java     |  2 +-
 .../cache/GridCacheAbstractFullApiSelfTest.java |  8 ++---
 .../GridCacheConcurrentTxMultiNodeTest.java     |  2 +-
 .../GridCacheGroupLockFailoverSelfTest.java     |  2 +-
 .../cache/GridCachePutAllFailoverSelfTest.java  |  4 +--
 .../cache/IgniteCacheInvokeAbstractTest.java    |  4 +--
 .../GridCacheCountDownLatchSelfTest.java        |  2 +-
 ...ridCacheQueueJoinedNodeSelfAbstractTest.java |  4 +--
 .../GridCacheAbstractJobExecutionTest.java      |  2 +-
 ...cOriginatingNodeFailureAbstractSelfTest.java |  2 +-
 .../dht/GridCacheGlobalLoadTest.java            |  2 +-
 .../GridCachePartitionedEntryLockSelfTest.java  |  2 +-
 .../GridCachePartitionedLoadCacheSelfTest.java  |  2 +-
 ...achePartitionedMultiNodeFullApiSelfTest.java |  2 +-
 .../closure/GridClosureProcessorSelfTest.java   | 16 ++++-----
 .../continuous/GridEventConsumeSelfTest.java    |  8 ++---
 .../processors/fs/GridGgfsTaskSelfTest.java     |  2 +-
 .../GridServiceProcessorAbstractSelfTest.java   | 18 +++++------
 .../GridServiceProcessorMultiNodeSelfTest.java  |  6 ++--
 .../loadtest/GridSingleExecutionTest.java       |  2 +-
 .../loadtests/colocation/GridTestMain.java      |  2 +-
 .../multisplit/GridMultiSplitsLoadTest.java     |  2 +-
 ...ridSingleSplitsNewNodesAbstractLoadTest.java |  2 +-
 .../ignite/loadtests/dsi/GridDsiClient.java     |  2 +-
 ...GridJobExecutionLoadTestClientSemaphore.java |  2 +-
 ...JobExecutionSingleNodeSemaphoreLoadTest.java |  2 +-
 .../loadtests/job/GridJobLoadTestSubmitter.java |  2 +-
 .../mergesort/GridMergeSortLoadTask.java        |  2 +-
 .../ignite/messaging/GridMessagingSelfTest.java |  2 +-
 ...idSessionFutureWaitJobAttributeSelfTest.java |  2 +-
 ...GridSessionSetJobAttributeOrderSelfTest.java |  2 +-
 ...sionSetJobAttributeWaitListenerSelfTest.java |  2 +-
 .../GridSessionSetTaskAttributeSelfTest.java    |  2 +-
 ...GridSessionTaskWaitJobAttributeSelfTest.java |  2 +-
 .../GridSessionWaitAttributeSelfTest.java       |  2 +-
 .../cache/GridAbstractCacheStoreSelfTest.java   |  2 +-
 .../junits/common/GridCommonAbstractTest.java   |  8 ++---
 ...idHadoopDefaultMapReducePlannerSelfTest.java |  4 +--
 .../GridProjectionStartStopRestartSelfTest.java |  2 +-
 75 files changed, 138 insertions(+), 137 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/examples/src/main/java/org/apache/ignite/examples/compute/ComputeFibonacciContinuationExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeFibonacciContinuationExample.java b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeFibonacciContinuationExample.java
index 9d8bbca..7309f7e 100644
--- a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeFibonacciContinuationExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeFibonacciContinuationExample.java
@@ -131,7 +131,7 @@ public final class ComputeFibonacciContinuationExample {
 
                     ClusterGroup p = g.cluster().forPredicate(nodeFilter);
 
-                    IgniteCompute compute = g.compute(p).enableAsync();
+                    IgniteCompute compute = g.compute(p).withAsync();
 
                     // If future is not cached in node-local-map, cache it.
                     if (fut1 == null) {

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/examples/src/main/java/org/apache/ignite/examples/compute/ComputeRunnableExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeRunnableExample.java b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeRunnableExample.java
index 147e98a..c70360f 100644
--- a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeRunnableExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeRunnableExample.java
@@ -47,7 +47,7 @@ public class ComputeRunnableExample {
             Collection<IgniteFuture> futs = new ArrayList<>();
 
             // Enable asynchronous mode.
-            IgniteCompute compute = g.compute().enableAsync();
+            IgniteCompute compute = g.compute().withAsync();
 
             // Iterate through all words in the sentence and create callable jobs.
             for (final String word : "Print words using runnable".split(" ")) {

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/aop/src/test/java/org/apache/loadtests/direct/singlesplit/SingleSplitsLoadTest.java
----------------------------------------------------------------------
diff --git a/modules/aop/src/test/java/org/apache/loadtests/direct/singlesplit/SingleSplitsLoadTest.java b/modules/aop/src/test/java/org/apache/loadtests/direct/singlesplit/SingleSplitsLoadTest.java
index a4bc6d7..7239b25 100644
--- a/modules/aop/src/test/java/org/apache/loadtests/direct/singlesplit/SingleSplitsLoadTest.java
+++ b/modules/aop/src/test/java/org/apache/loadtests/direct/singlesplit/SingleSplitsLoadTest.java
@@ -105,7 +105,7 @@ public class SingleSplitsLoadTest extends GridCommonAbstractTest {
                     try {
                         int levels = 20;
 
-                        IgniteCompute comp = ignite.compute().enableAsync();
+                        IgniteCompute comp = ignite.compute().withAsync();
 
                         comp.execute(new SingleSplitTestTask(), levels);
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/clients/src/test/java/org/apache/ignite/client/ClientStartNodeTask.java
----------------------------------------------------------------------
diff --git a/modules/clients/src/test/java/org/apache/ignite/client/ClientStartNodeTask.java b/modules/clients/src/test/java/org/apache/ignite/client/ClientStartNodeTask.java
index bd1ea93..5560593 100644
--- a/modules/clients/src/test/java/org/apache/ignite/client/ClientStartNodeTask.java
+++ b/modules/clients/src/test/java/org/apache/ignite/client/ClientStartNodeTask.java
@@ -151,7 +151,7 @@ public class ClientStartNodeTask extends TaskSingleJobSplitAdapter<String, Integ
     private static void changeTopology(Ignite parent, int add, int rmv, String type) throws IgniteCheckedException {
         Collection<ComputeTaskFuture<?>> tasks = new ArrayList<>();
 
-        IgniteCompute comp = parent.compute().enableAsync();
+        IgniteCompute comp = parent.compute().withAsync();
 
         // Start nodes in parallel.
         while (add-- > 0) {

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/IgniteCache.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/IgniteCache.java b/modules/core/src/main/java/org/apache/ignite/IgniteCache.java
index c8539cb..8430ec4 100644
--- a/modules/core/src/main/java/org/apache/ignite/IgniteCache.java
+++ b/modules/core/src/main/java/org/apache/ignite/IgniteCache.java
@@ -66,7 +66,7 @@ import java.util.concurrent.locks.*;
  */
 public interface IgniteCache<K, V> extends javax.cache.Cache<K, V>, IgniteAsyncSupport {
     /** {@inheritDoc} */
-    public @Override IgniteCache<K, V> enableAsync();
+    public @Override IgniteCache<K, V> withAsync();
 
     /** {@inheritDoc} */
     public @Override <C extends Configuration<K, V>> C getConfiguration(Class<C> clazz);

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/IgniteCluster.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/IgniteCluster.java b/modules/core/src/main/java/org/apache/ignite/IgniteCluster.java
index 5d17bca..b5bdbd9 100644
--- a/modules/core/src/main/java/org/apache/ignite/IgniteCluster.java
+++ b/modules/core/src/main/java/org/apache/ignite/IgniteCluster.java
@@ -335,5 +335,5 @@ public interface IgniteCluster extends ClusterGroup, IgniteAsyncSupport {
     public void resetMetrics();
 
     /** {@inheritDoc} */
-    public IgniteCluster enableAsync();
+    public IgniteCluster withAsync();
 }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/IgniteCompute.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/IgniteCompute.java b/modules/core/src/main/java/org/apache/ignite/IgniteCompute.java
index 798c75d..da5ebb9 100644
--- a/modules/core/src/main/java/org/apache/ignite/IgniteCompute.java
+++ b/modules/core/src/main/java/org/apache/ignite/IgniteCompute.java
@@ -443,5 +443,5 @@ public interface IgniteCompute extends IgniteAsyncSupport {
     @Override public <R> ComputeTaskFuture<R> future();
 
     /** {@inheritDoc} */
-    @Override public IgniteCompute enableAsync();
+    @Override public IgniteCompute withAsync();
 }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/IgniteEvents.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/IgniteEvents.java b/modules/core/src/main/java/org/apache/ignite/IgniteEvents.java
index e6f411a..6a42639 100644
--- a/modules/core/src/main/java/org/apache/ignite/IgniteEvents.java
+++ b/modules/core/src/main/java/org/apache/ignite/IgniteEvents.java
@@ -257,5 +257,5 @@ public interface IgniteEvents extends IgniteAsyncSupport {
     public boolean isEnabled(int type);
 
     /** {@inheritDoc} */
-    @Override IgniteEvents enableAsync();
+    @Override IgniteEvents withAsync();
 }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/IgniteFs.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/IgniteFs.java b/modules/core/src/main/java/org/apache/ignite/IgniteFs.java
index 47ff289..ff7a9b6 100644
--- a/modules/core/src/main/java/org/apache/ignite/IgniteFs.java
+++ b/modules/core/src/main/java/org/apache/ignite/IgniteFs.java
@@ -341,5 +341,5 @@ public interface IgniteFs extends IgniteFsFileSystem, IgniteAsyncSupport {
         long maxRangeLen, @Nullable T arg) throws IgniteCheckedException;
 
     /** {@inheritDoc} */
-    @Override public IgniteFs enableAsync();
+    @Override public IgniteFs withAsync();
 }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/IgniteManaged.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/IgniteManaged.java b/modules/core/src/main/java/org/apache/ignite/IgniteManaged.java
index f711503..5c7aaa7 100644
--- a/modules/core/src/main/java/org/apache/ignite/IgniteManaged.java
+++ b/modules/core/src/main/java/org/apache/ignite/IgniteManaged.java
@@ -356,5 +356,5 @@ public interface IgniteManaged extends IgniteAsyncSupport {
     public <T> T serviceProxy(String name, Class<? super T> svcItf, boolean sticky) throws IgniteException;
 
     /** {@inheritDoc} */
-    @Override public IgniteManaged enableAsync();
+    @Override public IgniteManaged withAsync();
 }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/IgniteMessaging.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/IgniteMessaging.java b/modules/core/src/main/java/org/apache/ignite/IgniteMessaging.java
index 1a9f74f..68e4f48 100644
--- a/modules/core/src/main/java/org/apache/ignite/IgniteMessaging.java
+++ b/modules/core/src/main/java/org/apache/ignite/IgniteMessaging.java
@@ -147,5 +147,5 @@ public interface IgniteMessaging extends IgniteAsyncSupport {
     public void stopRemoteListen(UUID opId) throws IgniteCheckedException;
 
     /** {@inheritDoc} */
-    @Override IgniteMessaging enableAsync();
+    @Override IgniteMessaging withAsync();
 }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/internal/GridKernal.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/GridKernal.java b/modules/core/src/main/java/org/apache/ignite/internal/GridKernal.java
index fb31087..e13f48a 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/GridKernal.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/GridKernal.java
@@ -2637,7 +2637,7 @@ public class GridKernal extends ClusterGroupAdapter implements GridEx, IgniteMXB
     }
 
     /** {@inheritDoc} */
-    @Override public IgniteCluster enableAsync() {
+    @Override public IgniteCluster withAsync() {
         return new IgniteClusterAsyncImpl(this);
     }
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/internal/IgniteManagedImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/IgniteManagedImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/IgniteManagedImpl.java
index 9c5763b..7d68d96 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/IgniteManagedImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/IgniteManagedImpl.java
@@ -235,7 +235,7 @@ public class IgniteManagedImpl extends IgniteAsyncSupportAdapter implements Igni
     }
 
     /** {@inheritDoc} */
-    @Override public IgniteManaged enableAsync() {
+    @Override public IgniteManaged withAsync() {
         if (isAsync())
             return this;
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/internal/executor/GridExecutorService.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/executor/GridExecutorService.java b/modules/core/src/main/java/org/apache/ignite/internal/executor/GridExecutorService.java
index 86c041e..0f2b6eb 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/executor/GridExecutorService.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/executor/GridExecutorService.java
@@ -115,7 +115,7 @@ public class GridExecutorService implements ExecutorService, Externalizable {
         this.prj = prj;
         this.log = log.getLogger(GridExecutorService.class);
 
-        comp = prj.compute().enableAsync();
+        comp = prj.compute().withAsync();
     }
 
     /** {@inheritDoc} */

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java
index f2680fe..5b674fb 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java
@@ -2473,7 +2473,8 @@ public abstract class GridCacheAdapter<K, V> implements GridCache<K, V>,
             (IgniteFuture<GridCacheReturn<Map<K, EntryProcessorResult<T>>>>)fut;
 
         return fut0.chain(new CX1<IgniteFuture<GridCacheReturn<Map<K, EntryProcessorResult<T>>>>, Map<K, EntryProcessorResult<T>>>() {
-            @Override public Map<K, EntryProcessorResult<T>> applyx(IgniteFuture<GridCacheReturn<Map<K, EntryProcessorResult<T>>>> fut)
+            @Override public Map<K, EntryProcessorResult<T>> applyx(
+                IgniteFuture<GridCacheReturn<Map<K, EntryProcessorResult<T>>>> fut)
                 throws IgniteCheckedException {
                 GridCacheReturn<Map<K, EntryProcessorResult<T>>> ret = fut.get();
 
@@ -3830,7 +3831,7 @@ public abstract class GridCacheAdapter<K, V> implements GridCache<K, V>,
 
         IgniteCompute comp = ctx.kernalContext().grid().compute(nodes).withNoFailover();
 
-        comp = comp.enableAsync();
+        comp = comp.withAsync();
 
         comp.broadcast(new LoadCacheClosure<>(ctx.name(), p, args));
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxAdapter.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxAdapter.java
index aebf9db..47cd12b 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxAdapter.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxAdapter.java
@@ -547,8 +547,8 @@ public abstract class IgniteTxAdapter<K, V> extends GridMetadataAwareAdapter
     }
 
     /** {@inheritDoc} */
-    @Override public IgniteAsyncSupport enableAsync() {
-        throw new UnsupportedOperationException("enableAsync() should not be called on IgniteTxAdapter directly.");
+    @Override public IgniteAsyncSupport withAsync() {
+        throw new UnsupportedOperationException("withAsync() should not be called on IgniteTxAdapter directly.");
     }
 
     /** {@inheritDoc} */
@@ -1514,7 +1514,7 @@ public abstract class IgniteTxAdapter<K, V> extends GridMetadataAwareAdapter
         }
 
         /** {@inheritDoc} */
-        @Override public IgniteAsyncSupport enableAsync() {
+        @Override public IgniteAsyncSupport withAsync() {
             throw new IllegalStateException("Deserialized transaction can only be used as read-only.");
         }
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxProxyImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxProxyImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxProxyImpl.java
index 3ac8227..3bfebc8 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxProxyImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxProxyImpl.java
@@ -185,7 +185,7 @@ public class IgniteTxProxyImpl<K, V> implements IgniteTxProxy, Externalizable {
     }
 
     /** {@inheritDoc} */
-    @Override public IgniteAsyncSupport enableAsync() {
+    @Override public IgniteAsyncSupport withAsync() {
         return new IgniteTxProxyImpl<>(tx, cctx, true);
     }
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/internal/processors/fs/GridGgfsImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/fs/GridGgfsImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/fs/GridGgfsImpl.java
index 4fb77bc..84942ce 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/fs/GridGgfsImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/fs/GridGgfsImpl.java
@@ -1825,7 +1825,7 @@ public final class GridGgfsImpl implements GridGgfsEx {
     }
 
     /** {@inheritDoc} */
-    @Override public IgniteFs enableAsync() {
+    @Override public IgniteFs withAsync() {
         return new GridGgfsAsyncImpl(this);
     }
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/cache/GridCacheCommandHandler.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/cache/GridCacheCommandHandler.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/cache/GridCacheCommandHandler.java
index b76735a..8d67de4 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/cache/GridCacheCommandHandler.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/cache/GridCacheCommandHandler.java
@@ -361,7 +361,7 @@ public class GridCacheCommandHandler extends GridRestCommandHandlerAdapter {
         else {
             ClusterGroup prj = ctx.grid().forPredicate(F.nodeForNodeId(destId));
 
-            IgniteCompute comp = ctx.grid().compute(prj).withNoFailover().enableAsync();
+            IgniteCompute comp = ctx.grid().compute(prj).withNoFailover().withAsync();
 
             comp.call(new FlaggedCacheOperationCallable(clientId, cacheName, flags, op, key, keepPortable));
 
@@ -399,7 +399,7 @@ public class GridCacheCommandHandler extends GridRestCommandHandlerAdapter {
         else {
             ClusterGroup prj = ctx.grid().forPredicate(F.nodeForNodeId(destId));
 
-            IgniteCompute comp = ctx.grid().compute(prj).withNoFailover().enableAsync();
+            IgniteCompute comp = ctx.grid().compute(prj).withNoFailover().withAsync();
 
             comp.call(new CacheOperationCallable(clientId, cacheName, op, key));
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/cache/GridCacheQueryCommandHandler.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/cache/GridCacheQueryCommandHandler.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/cache/GridCacheQueryCommandHandler.java
index 71292e9..72236a0 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/cache/GridCacheQueryCommandHandler.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/cache/GridCacheQueryCommandHandler.java
@@ -125,7 +125,7 @@ public class GridCacheQueryCommandHandler extends GridRestCommandHandlerAdapter
                     "the query): " + destId));
 
             try {
-                IgniteCompute comp = ctx.grid().compute(ctx.grid().forNodeId(destId)).withNoFailover().enableAsync();
+                IgniteCompute comp = ctx.grid().compute(ctx.grid().forNodeId(destId)).withNoFailover().withAsync();
 
                 comp.call(c);
 
@@ -144,7 +144,7 @@ public class GridCacheQueryCommandHandler extends GridRestCommandHandlerAdapter
      * @return Execution future.
      */
     private IgniteFuture<GridRestResponse> broadcast(String cacheName, Callable<Object> c) {
-        IgniteCompute comp = ctx.grid().compute(ctx.grid().forCache(cacheName)).withNoFailover().enableAsync();
+        IgniteCompute comp = ctx.grid().compute(ctx.grid().forCache(cacheName)).withNoFailover().withAsync();
 
         try {
             comp.broadcast(c);

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskCommandHandler.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskCommandHandler.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskCommandHandler.java
index c3efcaa..0012712 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskCommandHandler.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskCommandHandler.java
@@ -190,7 +190,7 @@ public class GridTaskCommandHandler extends GridRestCommandHandlerAdapter {
                 if (locExec) {
                     ClusterGroup prj = ctx.grid().forSubjectId(clientId);
 
-                    IgniteCompute comp = ctx.grid().compute(prj).withTimeout(timeout).enableAsync();
+                    IgniteCompute comp = ctx.grid().compute(prj).withTimeout(timeout).withAsync();
 
                     Object arg = !F.isEmpty(params) ? params.size() == 1 ? params.get(0) : params.toArray() : null;
 
@@ -203,7 +203,7 @@ public class GridTaskCommandHandler extends GridRestCommandHandlerAdapter {
                     // in order to provide user well-structured EmptyProjectionException.
                     ClusterGroup prj = ctx.grid().forPredicate(F.nodeForNodeId(req.destinationId()));
 
-                    IgniteCompute comp = ctx.grid().compute(prj).withNoFailover().enableAsync();
+                    IgniteCompute comp = ctx.grid().compute(prj).withNoFailover().withAsync();
 
                     comp.call(new ExeCallable(name, params, timeout, clientId));
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/lang/IgniteAsyncSupport.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/lang/IgniteAsyncSupport.java b/modules/core/src/main/java/org/apache/ignite/lang/IgniteAsyncSupport.java
index 6e536d1..4540e8c 100644
--- a/modules/core/src/main/java/org/apache/ignite/lang/IgniteAsyncSupport.java
+++ b/modules/core/src/main/java/org/apache/ignite/lang/IgniteAsyncSupport.java
@@ -26,7 +26,7 @@ public interface IgniteAsyncSupport {
      *
      * @return Component with asynchronous mode enabled.
      */
-    public IgniteAsyncSupport enableAsync();
+    public IgniteAsyncSupport withAsync();
 
     /**
      * @return {@code True} if asynchronous mode is enabled.

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/lang/IgniteAsyncSupportAdapter.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/lang/IgniteAsyncSupportAdapter.java b/modules/core/src/main/java/org/apache/ignite/lang/IgniteAsyncSupportAdapter.java
index 99b1a1e..63cf9f5 100644
--- a/modules/core/src/main/java/org/apache/ignite/lang/IgniteAsyncSupportAdapter.java
+++ b/modules/core/src/main/java/org/apache/ignite/lang/IgniteAsyncSupportAdapter.java
@@ -51,7 +51,7 @@ public class IgniteAsyncSupportAdapter<T extends IgniteAsyncSupport> implements
     }
 
     /** {@inheritDoc} */
-    @Override public T enableAsync() {
+    @Override public T withAsync() {
         T res = asyncInstance;
 
         if (res == null) {

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/lang/IgniteAsyncSupported.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/lang/IgniteAsyncSupported.java b/modules/core/src/main/java/org/apache/ignite/lang/IgniteAsyncSupported.java
index 7f82c0c..e70c07a 100644
--- a/modules/core/src/main/java/org/apache/ignite/lang/IgniteAsyncSupported.java
+++ b/modules/core/src/main/java/org/apache/ignite/lang/IgniteAsyncSupported.java
@@ -21,7 +21,7 @@ import java.lang.annotation.*;
 
 /**
  * Annotation to indicate that method can be executed asynchronously if async mode is enabled.
- * To enable async mode, invoke {@link IgniteAsyncSupport#enableAsync()} method on the API.
+ * To enable async mode, invoke {@link IgniteAsyncSupport#withAsync()} method on the API.
  * The future for the async method can be retrieved via {@link IgniteAsyncSupport#future()} method
  * right after the execution of an asynchronous method.
  *

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/GridCancelOnGridStopSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridCancelOnGridStopSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridCancelOnGridStopSelfTest.java
index 730225f..42a15d2 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/GridCancelOnGridStopSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/GridCancelOnGridStopSelfTest.java
@@ -54,7 +54,7 @@ public class GridCancelOnGridStopSelfTest extends GridCommonAbstractTest {
         try (Ignite g = startGrid(1)) {
             cnt = new CountDownLatch(1);
 
-            g.compute().enableAsync().execute(CancelledTask.class, null);
+            g.compute().withAsync().execute(CancelledTask.class, null);
 
             cnt.await();
         }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/GridCancelledJobsMetricsSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridCancelledJobsMetricsSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridCancelledJobsMetricsSelfTest.java
index d37c57d..e04b9e0 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/GridCancelledJobsMetricsSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/GridCancelledJobsMetricsSelfTest.java
@@ -70,7 +70,7 @@ public class GridCancelledJobsMetricsSelfTest extends GridCommonAbstractTest {
 
         Collection<ComputeTaskFuture<?>> futs = new ArrayList<>();
 
-        IgniteCompute comp = ignite.compute().enableAsync();
+        IgniteCompute comp = ignite.compute().withAsync();
 
         for (int i = 1; i <= 10; i++) {
             comp.execute(CancelledTask.class, null);

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/GridContinuousTaskSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridContinuousTaskSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridContinuousTaskSelfTest.java
index f4729c4..90a6553 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/GridContinuousTaskSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/GridContinuousTaskSelfTest.java
@@ -45,7 +45,7 @@ public class GridContinuousTaskSelfTest extends GridCommonAbstractTest {
         try {
             Ignite ignite = startGrid(0);
 
-            IgniteCompute comp = ignite.compute().enableAsync();
+            IgniteCompute comp = ignite.compute().withAsync();
 
             comp.execute(TestJobsChainTask.class, true);
 
@@ -75,7 +75,7 @@ public class GridContinuousTaskSelfTest extends GridCommonAbstractTest {
                 /** {@inheritDoc} */
                 @Override public void run() {
                     try {
-                        IgniteCompute comp = ignite.compute().enableAsync();
+                        IgniteCompute comp = ignite.compute().withAsync();
 
                         comp.execute(TestJobsChainTask.class, true);
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/GridEventStorageCheckAllEventsSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridEventStorageCheckAllEventsSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridEventStorageCheckAllEventsSelfTest.java
index 384b953..ca71778 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/GridEventStorageCheckAllEventsSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/GridEventStorageCheckAllEventsSelfTest.java
@@ -289,7 +289,7 @@ public class GridEventStorageCheckAllEventsSelfTest extends GridCommonAbstractTe
      * @throws Exception If failed.
      */
     private ComputeTaskFuture<?> generateEvents(@Nullable Long timeout, ComputeJob job) throws Exception {
-        IgniteCompute comp = ignite.compute().enableAsync();
+        IgniteCompute comp = ignite.compute().withAsync();
 
         if (timeout == null)
             comp.execute(GridAllEventsTestTask.class.getName(), job);

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/GridFailoverCustomTopologySelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridFailoverCustomTopologySelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridFailoverCustomTopologySelfTest.java
index 025acdb..55b36f8 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/GridFailoverCustomTopologySelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/GridFailoverCustomTopologySelfTest.java
@@ -84,7 +84,7 @@ public class GridFailoverCustomTopologySelfTest extends GridCommonAbstractTest {
                 ComputeTaskFuture<String> fut;
 
                 synchronized(mux){
-                    IgniteCompute comp = ignite1.compute().enableAsync();
+                    IgniteCompute comp = ignite1.compute().withAsync();
 
                     comp.execute(JobTask.class, null);
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/GridJobMasterLeaveAwareSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridJobMasterLeaveAwareSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridJobMasterLeaveAwareSelfTest.java
index aff0eaf..f79a68a 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/GridJobMasterLeaveAwareSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/GridJobMasterLeaveAwareSelfTest.java
@@ -134,7 +134,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest {
 
         Ignite g = startGrid(0);
 
-        g.compute().enableAsync().execute(new TestTask(1), null);
+        g.compute().withAsync().execute(new TestTask(1), null);
 
         jobLatch.await();
 
@@ -171,7 +171,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest {
 
         int lastGridIdx = GRID_CNT - 1;
 
-        compute(grid(lastGridIdx).forPredicate(excludeLastPredicate())).enableAsync().
+        compute(grid(lastGridIdx).forPredicate(excludeLastPredicate())).withAsync().
             execute(new TestTask(GRID_CNT - 1), null);
 
         jobLatch.await();
@@ -196,7 +196,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest {
 
         int lastGridIdx = GRID_CNT - 1;
 
-        compute(grid(lastGridIdx).forPredicate(excludeLastPredicate())).enableAsync().
+        compute(grid(lastGridIdx).forPredicate(excludeLastPredicate())).withAsync().
             execute(new TestTask(GRID_CNT - 1), null);
 
         jobLatch.await();
@@ -225,7 +225,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest {
 
         int lastGridIdx = GRID_CNT - 1;
 
-        compute(grid(lastGridIdx).forPredicate(excludeLastPredicate())).enableAsync().
+        compute(grid(lastGridIdx).forPredicate(excludeLastPredicate())).withAsync().
             execute(new TestTask(GRID_CNT - 1), null);
 
         jobLatch.await();
@@ -255,7 +255,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest {
     public void testApply1() throws Exception {
         testMasterLeaveAwareCallback(1, new CX1<ClusterGroup, IgniteFuture<?>>() {
             @Override public IgniteFuture<?> applyx(ClusterGroup grid) throws IgniteCheckedException {
-                IgniteCompute comp = compute(grid).enableAsync();
+                IgniteCompute comp = compute(grid).withAsync();
 
                 comp.apply(new TestClosure(), "arg");
 
@@ -270,7 +270,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest {
     public void testApply2() throws Exception {
         testMasterLeaveAwareCallback(2, new CX1<ClusterGroup, IgniteFuture<?>>() {
             @Override public IgniteFuture<?> applyx(ClusterGroup grid) throws IgniteCheckedException {
-                IgniteCompute comp = compute(grid).enableAsync();
+                IgniteCompute comp = compute(grid).withAsync();
 
                 comp.apply(new TestClosure(), Arrays.asList("arg1", "arg2"));
 
@@ -285,7 +285,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest {
     public void testApply3() throws Exception {
         testMasterLeaveAwareCallback(2, new CX1<ClusterGroup, IgniteFuture<?>>() {
             @Override public IgniteFuture<?> applyx(ClusterGroup grid) throws IgniteCheckedException {
-                IgniteCompute comp = compute(grid).enableAsync();
+                IgniteCompute comp = compute(grid).withAsync();
 
                 comp.apply(new TestClosure(),
                     Arrays.asList("arg1", "arg2"),
@@ -310,7 +310,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest {
     public void testRun1() throws Exception {
         testMasterLeaveAwareCallback(1, new CX1<ClusterGroup, IgniteFuture<?>>() {
             @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException {
-                IgniteCompute comp = compute(prj).enableAsync();
+                IgniteCompute comp = compute(prj).withAsync();
 
                 comp.run(new TestRunnable());
 
@@ -325,7 +325,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest {
     public void testRun2() throws Exception {
         testMasterLeaveAwareCallback(2, new CX1<ClusterGroup, IgniteFuture<?>>() {
             @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException {
-                IgniteCompute comp = compute(prj).enableAsync();
+                IgniteCompute comp = compute(prj).withAsync();
 
                 comp.run(Arrays.asList(new TestRunnable(), new TestRunnable()));
 
@@ -340,7 +340,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest {
     public void testCall1() throws Exception {
         testMasterLeaveAwareCallback(1, new CX1<ClusterGroup, IgniteFuture<?>>() {
             @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException {
-                IgniteCompute comp = compute(prj).enableAsync();
+                IgniteCompute comp = compute(prj).withAsync();
 
                 comp.call(new TestCallable());
 
@@ -355,7 +355,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest {
     public void testCall2() throws Exception {
         testMasterLeaveAwareCallback(2, new CX1<ClusterGroup, IgniteFuture<?>>() {
             @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException {
-                IgniteCompute comp = compute(prj).enableAsync();
+                IgniteCompute comp = compute(prj).withAsync();
 
                 comp.call(Arrays.asList(new TestCallable(), new TestCallable()));
 
@@ -370,7 +370,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest {
     public void testCall3() throws Exception {
         testMasterLeaveAwareCallback(2, new CX1<ClusterGroup, IgniteFuture<?>>() {
             @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException {
-                IgniteCompute comp = compute(prj).enableAsync();
+                IgniteCompute comp = compute(prj).withAsync();
 
                 comp.call(
                     Arrays.asList(new TestCallable(), new TestCallable()),
@@ -395,7 +395,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest {
     public void testBroadcast1() throws Exception {
         testMasterLeaveAwareCallback(1, new CX1<ClusterGroup, IgniteFuture<?>>() {
             @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException {
-                IgniteCompute comp = compute(prj).enableAsync();
+                IgniteCompute comp = compute(prj).withAsync();
 
                 comp.broadcast(new TestRunnable());
 
@@ -410,7 +410,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest {
     public void testBroadcast2() throws Exception {
         testMasterLeaveAwareCallback(1, new CX1<ClusterGroup, IgniteFuture<?>>() {
             @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException {
-                IgniteCompute comp = compute(prj).enableAsync();
+                IgniteCompute comp = compute(prj).withAsync();
 
                 comp.broadcast(new TestCallable());
 
@@ -425,7 +425,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest {
     public void testBroadcast3() throws Exception {
         testMasterLeaveAwareCallback(1, new CX1<ClusterGroup, IgniteFuture<?>>() {
             @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException {
-                IgniteCompute comp = compute(prj).enableAsync();
+                IgniteCompute comp = compute(prj).withAsync();
 
                 comp.broadcast(new TestClosure(), "arg");
 
@@ -440,7 +440,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest {
     public void testAffinityRun() throws Exception {
         testMasterLeaveAwareCallback(1, new CX1<ClusterGroup, IgniteFuture<?>>() {
             @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException {
-                IgniteCompute comp = compute(prj).enableAsync();
+                IgniteCompute comp = compute(prj).withAsync();
 
                 CacheAffinity<Object> aff = prj.ignite().cache(null).affinity();
 
@@ -459,7 +459,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest {
     public void testAffinityCall() throws Exception {
         testMasterLeaveAwareCallback(1, new CX1<ClusterGroup, IgniteFuture<?>>() {
             @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException {
-                IgniteCompute comp = compute(prj).enableAsync();
+                IgniteCompute comp = compute(prj).withAsync();
 
                 CacheAffinity<Object> aff = prj.ignite().cache(null).affinity();
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/GridMultipleJobsSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridMultipleJobsSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridMultipleJobsSelfTest.java
index 49635de..d6ec8ad 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/GridMultipleJobsSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/GridMultipleJobsSelfTest.java
@@ -148,7 +148,7 @@ public class GridMultipleJobsSelfTest extends GridCommonAbstractTest {
                         throw new IgniteCheckedException("Could not instantiate a job.", e);
                     }
 
-                    IgniteCompute comp = ignite1.compute().enableAsync();
+                    IgniteCompute comp = ignite1.compute().withAsync();
 
                     comp.call(job);
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/GridProjectionAbstractTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridProjectionAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridProjectionAbstractTest.java
index 96c6efa..9da8a0b 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/GridProjectionAbstractTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/GridProjectionAbstractTest.java
@@ -323,7 +323,7 @@ public abstract class GridProjectionAbstractTest extends GridCommonAbstractTest
      * @throws Exception If failed.
      */
     private void run1(AtomicInteger cnt) throws Exception {
-        IgniteCompute comp = compute(prj).enableAsync();
+        IgniteCompute comp = compute(prj).withAsync();
 
         comp.broadcast(runJob);
 
@@ -345,7 +345,7 @@ public abstract class GridProjectionAbstractTest extends GridCommonAbstractTest
     private void run2(AtomicInteger cnt) throws Exception {
         Collection<Runnable> jobs = F.asList(runJob);
 
-        IgniteCompute comp = compute(prj).enableAsync();
+        IgniteCompute comp = compute(prj).withAsync();
 
         comp.run(jobs);
 
@@ -365,7 +365,7 @@ public abstract class GridProjectionAbstractTest extends GridCommonAbstractTest
      * @throws Exception If failed.
      */
     private void call1(AtomicInteger cnt) throws Exception {
-        IgniteCompute comp = compute(prj).enableAsync();
+        IgniteCompute comp = compute(prj).withAsync();
 
         comp.broadcast(calJob);
 
@@ -385,7 +385,7 @@ public abstract class GridProjectionAbstractTest extends GridCommonAbstractTest
      * @throws Exception If failed.
      */
     private void call2(AtomicInteger cnt) throws Exception {
-        IgniteCompute comp = compute(prj).enableAsync();
+        IgniteCompute comp = compute(prj).withAsync();
 
         Collection<Callable<String>> jobs = F.asList(calJob);
 
@@ -407,7 +407,7 @@ public abstract class GridProjectionAbstractTest extends GridCommonAbstractTest
      * @throws Exception If failed.
      */
     private void call3(AtomicInteger cnt) throws Exception {
-        IgniteCompute comp = compute(prj).enableAsync();
+        IgniteCompute comp = compute(prj).withAsync();
 
         comp.apply(clrJob, (String) null);
 
@@ -429,7 +429,7 @@ public abstract class GridProjectionAbstractTest extends GridCommonAbstractTest
     private void call4(AtomicInteger cnt) throws Exception {
         Collection<String> args = F.asList("a", "b", "c");
 
-        IgniteCompute comp = compute(prj).enableAsync();
+        IgniteCompute comp = compute(prj).withAsync();
 
         comp.apply(clrJob, args);
 
@@ -449,7 +449,7 @@ public abstract class GridProjectionAbstractTest extends GridCommonAbstractTest
      * @throws Exception If failed.
      */
     private void call5(AtomicInteger cnt) throws Exception {
-        IgniteCompute comp = compute(prj).enableAsync();
+        IgniteCompute comp = compute(prj).withAsync();
 
         comp.broadcast(new TestClosure(), "arg");
 
@@ -476,7 +476,7 @@ public abstract class GridProjectionAbstractTest extends GridCommonAbstractTest
     private void forkjoin1(AtomicInteger cnt) throws Exception {
         Collection<String> args = F.asList("a", "b", "c");
 
-        IgniteCompute comp = compute(prj).enableAsync();
+        IgniteCompute comp = compute(prj).withAsync();
 
         comp.apply(clrJob, args, rdc);
 
@@ -498,7 +498,7 @@ public abstract class GridProjectionAbstractTest extends GridCommonAbstractTest
     private void forkjoin2(AtomicInteger cnt) throws Exception {
         Collection<Callable<String>> jobs = F.asList(calJob);
 
-        IgniteCompute comp = compute(prj).enableAsync();
+        IgniteCompute comp = compute(prj).withAsync();
 
         comp.call(jobs, rdc);
 
@@ -643,7 +643,7 @@ public abstract class GridProjectionAbstractTest extends GridCommonAbstractTest
      * @throws Exception If test failed.
      */
     private void checkActiveFutures() throws Exception {
-        IgniteCompute comp = compute(prj).enableAsync();
+        IgniteCompute comp = compute(prj).withAsync();
 
         assertEquals(0, comp.activeTaskFutures().size());
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/GridReduceSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridReduceSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridReduceSelfTest.java
index f83b7e8..db2e960 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/GridReduceSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/GridReduceSelfTest.java
@@ -87,7 +87,7 @@ public class GridReduceSelfTest extends GridCommonAbstractTest {
 
             List<ReducerTestClosure> closures = closures(ignite.cluster().nodes().size());
 
-            IgniteCompute comp = compute(ignite.cluster().forLocal()).enableAsync();
+            IgniteCompute comp = compute(ignite.cluster().forLocal()).withAsync();
 
             comp.call(closures, new R1<Long, Long>() {
                 private long sum;

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/GridTaskCancelSingleNodeSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridTaskCancelSingleNodeSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridTaskCancelSingleNodeSelfTest.java
index c587e5d..c107914 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/GridTaskCancelSingleNodeSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/GridTaskCancelSingleNodeSelfTest.java
@@ -100,7 +100,7 @@ public class GridTaskCancelSingleNodeSelfTest extends GridCommonAbstractTest {
             }
         }, EVT_JOB_FINISHED, EVT_JOB_CANCELLED, EVT_JOB_REJECTED);
 
-        IgniteCompute comp = grid().compute().enableAsync();
+        IgniteCompute comp = grid().compute().withAsync();
 
         comp.execute(TestTask.class, null);
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/GridTaskExecutionSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridTaskExecutionSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridTaskExecutionSelfTest.java
index a843394..e12ae60 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/GridTaskExecutionSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/GridTaskExecutionSelfTest.java
@@ -55,7 +55,7 @@ public class GridTaskExecutionSelfTest extends GridCommonAbstractTest {
      * @throws Exception If failed.
      */
     public void testSynchronousExecute() throws Exception {
-        IgniteCompute comp = ignite.compute().enableAsync();
+        IgniteCompute comp = ignite.compute().withAsync();
 
         assertNull(comp.execute(GridTestTask.class,  "testArg"));
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/GridTaskInstanceExecutionSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridTaskInstanceExecutionSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridTaskInstanceExecutionSelfTest.java
index 80fe81f..1aebc39 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/GridTaskInstanceExecutionSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/GridTaskInstanceExecutionSelfTest.java
@@ -52,7 +52,7 @@ public class GridTaskInstanceExecutionSelfTest extends GridCommonAbstractTest {
         assert task.getState() != null;
         assert task.getState() == testState;
 
-        IgniteCompute comp = ignite.compute().enableAsync();
+        IgniteCompute comp = ignite.compute().withAsync();
 
         assertNull(comp.execute(task,  "testArg"));
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/GridTaskJobRejectSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridTaskJobRejectSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridTaskJobRejectSelfTest.java
index 9b055a8..062c42b 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/GridTaskJobRejectSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/GridTaskJobRejectSelfTest.java
@@ -116,7 +116,7 @@ public class GridTaskJobRejectSelfTest extends GridCommonAbstractTest {
 
         final ClusterNode node = grid(1).localNode();
 
-        IgniteCompute comp = grid(1).compute().enableAsync();
+        IgniteCompute comp = grid(1).compute().withAsync();
 
         comp.execute(new ComputeTaskAdapter<Void, Void>() {
             @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid,

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java
index 237ab68..e7b93bf 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java
@@ -1245,7 +1245,7 @@ public abstract class GridCacheAbstractFullApiSelfTest extends GridCacheAbstract
         cache.put("key2", 1);
         cache.put("key3", 3);
 
-        IgniteCache<String, Integer> asyncCache = cache.enableAsync();
+        IgniteCache<String, Integer> asyncCache = cache.withAsync();
 
         assertNull(asyncCache.invoke("key1", INCR_PROCESSOR));
 
@@ -1619,7 +1619,7 @@ public abstract class GridCacheAbstractFullApiSelfTest extends GridCacheAbstract
         IgniteFuture<IgniteTx> f = null;
 
         if (tx != null) {
-            tx = (IgniteTx)tx.enableAsync();
+            tx = (IgniteTx)tx.withAsync();
 
             tx.commit();
 
@@ -3480,7 +3480,7 @@ public abstract class GridCacheAbstractFullApiSelfTest extends GridCacheAbstract
 
             final CountDownLatch latch = new CountDownLatch(1);
 
-            IgniteCompute comp = forLocal(dfltIgnite).enableAsync();
+            IgniteCompute comp = forLocal(dfltIgnite).withAsync();
 
             comp.call(new Callable<Boolean>() {
                 @Override public Boolean call() throws Exception {
@@ -3550,7 +3550,7 @@ public abstract class GridCacheAbstractFullApiSelfTest extends GridCacheAbstract
 
             final CountDownLatch syncLatch = new CountDownLatch(1);
 
-            IgniteCompute comp = forLocal(dfltIgnite).enableAsync();
+            IgniteCompute comp = forLocal(dfltIgnite).withAsync();
 
             comp.call(new Callable<Boolean>() {
                 @Override public Boolean call() throws Exception {

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheConcurrentTxMultiNodeTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheConcurrentTxMultiNodeTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheConcurrentTxMultiNodeTest.java
index 56ce912..3e537c5 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheConcurrentTxMultiNodeTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheConcurrentTxMultiNodeTest.java
@@ -309,7 +309,7 @@ public class GridCacheConcurrentTxMultiNodeTest extends GridCommonAbstractTest {
 
                     long submitTime1 = t0;
 
-                    IgniteCompute comp = g.compute(g.cluster().forPredicate(serverNode)).enableAsync();
+                    IgniteCompute comp = g.compute(g.cluster().forPredicate(serverNode)).withAsync();
 
                     comp.execute(RequestTask.class, new Message(terminalId, nodeId));
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheGroupLockFailoverSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheGroupLockFailoverSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheGroupLockFailoverSelfTest.java
index 534daf0..96879cf 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheGroupLockFailoverSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheGroupLockFailoverSelfTest.java
@@ -320,7 +320,7 @@ public class GridCacheGroupLockFailoverSelfTest extends GridCommonAbstractTest {
         throws IgniteCheckedException {
         ClusterGroup prj = master.cluster().forPredicate(workerNodesFilter);
 
-        IgniteCompute comp = master.compute(prj).enableAsync();
+        IgniteCompute comp = master.compute(prj).withAsync();
 
         comp.execute(new GridCacheGroupLockPutTask(preferredNodeId, CACHE_NAME, optimisticTx()), dataChunk);
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCachePutAllFailoverSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCachePutAllFailoverSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCachePutAllFailoverSelfTest.java
index bea2421..a21eb18 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCachePutAllFailoverSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCachePutAllFailoverSelfTest.java
@@ -235,7 +235,7 @@ public class GridCachePutAllFailoverSelfTest extends GridCommonAbstractTest {
 
             final AtomicBoolean inputExhausted = new AtomicBoolean();
 
-            IgniteCompute comp = compute(master.cluster().forPredicate(workerNodesFilter)).enableAsync();
+            IgniteCompute comp = compute(master.cluster().forPredicate(workerNodesFilter)).withAsync();
 
             for (Integer key : testKeys) {
                 dataChunk.add(key);
@@ -402,7 +402,7 @@ public class GridCachePutAllFailoverSelfTest extends GridCommonAbstractTest {
 
             final AtomicBoolean inputExhausted = new AtomicBoolean();
 
-            IgniteCompute comp = compute(master.cluster().forPredicate(workerNodesFilter)).enableAsync();
+            IgniteCompute comp = compute(master.cluster().forPredicate(workerNodesFilter)).withAsync();
 
             for (Integer key : testKeys) {
                 ClusterNode mappedNode = master.cluster().mapKeyToNode(CACHE_NAME, key);

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheInvokeAbstractTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheInvokeAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheInvokeAbstractTest.java
index fa12084..63c42c9 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheInvokeAbstractTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheInvokeAbstractTest.java
@@ -147,7 +147,7 @@ public abstract class IgniteCacheInvokeAbstractTest extends IgniteCacheAbstractT
 
             checkValue(key, 63);
 
-            IgniteCache<Integer, Integer> asyncCache = cache.enableAsync();
+            IgniteCache<Integer, Integer> asyncCache = cache.withAsync();
 
             assertTrue(asyncCache.isAsync());
 
@@ -398,7 +398,7 @@ public abstract class IgniteCacheInvokeAbstractTest extends IgniteCacheAbstractT
         for (Integer key : keys)
             checkValue(key, null);
 
-        IgniteCache<Integer, Integer> asyncCache = cache.enableAsync();
+        IgniteCache<Integer, Integer> asyncCache = cache.withAsync();
 
         assertTrue(asyncCache.isAsync());
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheCountDownLatchSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheCountDownLatchSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheCountDownLatchSelfTest.java
index ea1d2ed..3860d1a 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheCountDownLatchSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheCountDownLatchSelfTest.java
@@ -208,7 +208,7 @@ public class GridCacheCountDownLatchSelfTest extends GridCommonAbstractTest impl
 
         assert latch1.count() == 2;
 
-        IgniteCompute comp = grid(0).compute().enableAsync();
+        IgniteCompute comp = grid(0).compute().withAsync();
 
         comp.call(new IgniteCallable<Object>() {
             @IgniteInstanceResource

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheQueueJoinedNodeSelfAbstractTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheQueueJoinedNodeSelfAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheQueueJoinedNodeSelfAbstractTest.java
index 36ecfe1..2268044 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheQueueJoinedNodeSelfAbstractTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheQueueJoinedNodeSelfAbstractTest.java
@@ -85,7 +85,7 @@ public abstract class GridCacheQueueJoinedNodeSelfAbstractTest extends GridCommo
 
         PutJob putJob = new PutJob(queueName);
 
-        IgniteCompute comp = compute(grid(0).forLocal()).enableAsync();
+        IgniteCompute comp = compute(grid(0).forLocal()).withAsync();
 
         comp.run(putJob);
 
@@ -104,7 +104,7 @@ public abstract class GridCacheQueueJoinedNodeSelfAbstractTest extends GridCommo
 
             jobs.add(job);
 
-            comp = compute(grid(i).forLocal()).enableAsync();
+            comp = compute(grid(i).forLocal()).withAsync();
 
             comp.call(job);
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheAbstractJobExecutionTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheAbstractJobExecutionTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheAbstractJobExecutionTest.java
index c5c0752..9878cb5 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheAbstractJobExecutionTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheAbstractJobExecutionTest.java
@@ -123,7 +123,7 @@ public abstract class GridCacheAbstractJobExecutionTest extends GridCommonAbstra
 
         Collection<IgniteFuture<?>> futs = new LinkedList<>();
 
-        IgniteCompute comp = ignite.compute().enableAsync();
+        IgniteCompute comp = ignite.compute().withAsync();
 
         for (int i = 0; i < jobCnt; i++) {
             comp.apply(new CX1<Integer, Void>() {

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteTxPessimisticOriginatingNodeFailureAbstractSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteTxPessimisticOriginatingNodeFailureAbstractSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteTxPessimisticOriginatingNodeFailureAbstractSelfTest.java
index 4d8fee4..c6b3adc 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteTxPessimisticOriginatingNodeFailureAbstractSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteTxPessimisticOriginatingNodeFailureAbstractSelfTest.java
@@ -186,7 +186,7 @@ public abstract class IgniteTxPessimisticOriginatingNodeFailureAbstractSelfTest
 
                     info("Before commitAsync");
 
-                    tx = (IgniteTx)tx.enableAsync();
+                    tx = (IgniteTx)tx.withAsync();
 
                     tx.commit();
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridCacheGlobalLoadTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridCacheGlobalLoadTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridCacheGlobalLoadTest.java
index aabcc3a..999f527 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridCacheGlobalLoadTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridCacheGlobalLoadTest.java
@@ -85,7 +85,7 @@ public class GridCacheGlobalLoadTest extends IgniteCacheAbstractTest {
     private void loadCache(boolean async) throws Exception {
         IgniteCache<Integer, Integer> cache = jcache();
 
-        IgniteCache<Integer, Integer> asyncCache = cache.enableAsync();
+        IgniteCache<Integer, Integer> asyncCache = cache.withAsync();
 
         assertTrue(asyncCache.isAsync());
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedEntryLockSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedEntryLockSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedEntryLockSelfTest.java
index b8cab48..cf93827 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedEntryLockSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedEntryLockSelfTest.java
@@ -57,7 +57,7 @@ public class GridCachePartitionedEntryLockSelfTest extends GridCacheAbstractSelf
 
                 assert e.isLocked();
 
-                IgniteCompute comp = compute(grid(i).forLocal()).enableAsync();
+                IgniteCompute comp = compute(grid(i).forLocal()).withAsync();
 
                 comp.call(new Callable<Boolean>() {
                     @Override public Boolean call() throws Exception {

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedLoadCacheSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedLoadCacheSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedLoadCacheSelfTest.java
index 79ab0b8..1563356 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedLoadCacheSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedLoadCacheSelfTest.java
@@ -100,7 +100,7 @@ public class GridCachePartitionedLoadCacheSelfTest extends GridCommonAbstractTes
             IgniteCache<Integer, String> cache = jcache(0);
 
             if (async) {
-                IgniteCache<Integer, String> asyncCache = cache.enableAsync();
+                IgniteCache<Integer, String> asyncCache = cache.withAsync();
 
                 asyncCache.localLoadCache(null, PUT_CNT);
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedMultiNodeFullApiSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedMultiNodeFullApiSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedMultiNodeFullApiSelfTest.java
index 5d89685..86ba60b 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedMultiNodeFullApiSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedMultiNodeFullApiSelfTest.java
@@ -446,7 +446,7 @@ public class GridCachePartitionedMultiNodeFullApiSelfTest extends GridCacheParti
 
             final CountDownLatch syncLatch = new CountDownLatch(1);
 
-            IgniteCompute comp = compute(dfltIgnite.cluster().forLocal()).enableAsync();
+            IgniteCompute comp = compute(dfltIgnite.cluster().forLocal()).withAsync();
 
             comp.call(new Callable<Boolean>() {
                     @Override public Boolean call() throws Exception {

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/processors/closure/GridClosureProcessorSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/closure/GridClosureProcessorSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/closure/GridClosureProcessorSelfTest.java
index 58db968..964fdc9 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/closure/GridClosureProcessorSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/closure/GridClosureProcessorSelfTest.java
@@ -198,7 +198,7 @@ public class GridClosureProcessorSelfTest extends GridCommonAbstractTest {
 
         IgniteCompute comp = p != null ? compute(grid(idx).forPredicate(p)) : grid(idx).compute();
 
-        comp = comp.enableAsync();
+        comp = comp.withAsync();
 
         comp.run(job);
 
@@ -224,7 +224,7 @@ public class GridClosureProcessorSelfTest extends GridCommonAbstractTest {
         if (p != null)
             prj = prj.forPredicate(p);
 
-        IgniteCompute comp = compute(prj).enableAsync();
+        IgniteCompute comp = compute(prj).withAsync();
 
         comp.broadcast(job);
 
@@ -247,7 +247,7 @@ public class GridClosureProcessorSelfTest extends GridCommonAbstractTest {
 
         IgniteCompute comp = p != null ? compute(grid(idx).forPredicate(p)) : grid(idx).compute();
 
-        comp = comp.enableAsync();
+        comp = comp.withAsync();
 
         comp.run(jobs);
 
@@ -270,7 +270,7 @@ public class GridClosureProcessorSelfTest extends GridCommonAbstractTest {
 
         IgniteCompute comp = p != null ? compute(grid(idx).forPredicate(p)) : grid(idx).compute();
 
-        comp = comp.enableAsync();
+        comp = comp.withAsync();
 
         comp.call(job);
 
@@ -293,7 +293,7 @@ public class GridClosureProcessorSelfTest extends GridCommonAbstractTest {
 
         IgniteCompute comp = p != null ? compute(grid(idx).forPredicate(p)) : grid(idx).compute();
 
-        comp = comp.enableAsync();
+        comp = comp.withAsync();
 
         comp.broadcast(job);
 
@@ -316,7 +316,7 @@ public class GridClosureProcessorSelfTest extends GridCommonAbstractTest {
 
         IgniteCompute comp = p != null ? compute(grid(idx).forPredicate(p)) : grid(idx).compute();
 
-        comp = comp.enableAsync();
+        comp = comp.withAsync();
 
         comp.call(jobs);
 
@@ -407,7 +407,7 @@ public class GridClosureProcessorSelfTest extends GridCommonAbstractTest {
      * @throws Exception If failed.
      */
     public void testCallAsyncErrorNoFailover() throws Exception {
-        IgniteCompute comp = compute(grid(0).forPredicate(F.notEqualTo(grid(0).localNode()))).enableAsync();
+        IgniteCompute comp = compute(grid(0).forPredicate(F.notEqualTo(grid(0).localNode()))).withAsync();
 
         comp.withNoFailover().call(new TestCallableError());
 
@@ -486,7 +486,7 @@ public class GridClosureProcessorSelfTest extends GridCommonAbstractTest {
     public void testReduceAsync() throws Exception {
         Collection<TestCallable> jobs = F.asList(new TestCallable(), new TestCallable());
 
-        IgniteCompute comp = grid(0).compute().enableAsync();
+        IgniteCompute comp = grid(0).compute().withAsync();
 
         comp.call(jobs, F.sumIntReducer());
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java
index 2db4e33..a67d1cd 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java
@@ -964,7 +964,7 @@ public class GridEventConsumeSelfTest extends GridCommonAbstractTest {
                     int idx = rnd.nextInt(GRID_CNT);
 
                     try {
-                        IgniteEvents evts = grid(idx).events().enableAsync();
+                        IgniteEvents evts = grid(idx).events().withAsync();
 
                         evts.remoteListen(new P2<UUID, IgniteEvent>() {
                             @Override public boolean apply(UUID uuid, IgniteEvent evt) {
@@ -1003,7 +1003,7 @@ public class GridEventConsumeSelfTest extends GridCommonAbstractTest {
                     UUID consumeId = t.get2();
 
                     try {
-                        IgniteEvents evts = grid(idx).events().enableAsync();
+                        IgniteEvents evts = grid(idx).events().withAsync();
 
                         evts.stopRemoteListen(consumeId);
 
@@ -1037,7 +1037,7 @@ public class GridEventConsumeSelfTest extends GridCommonAbstractTest {
                     int idx = rnd.nextInt(GRID_CNT);
 
                     try {
-                        IgniteCompute comp = grid(idx).compute().enableAsync();
+                        IgniteCompute comp = grid(idx).compute().withAsync();
 
                         comp.run(F.noop());
 
@@ -1063,7 +1063,7 @@ public class GridEventConsumeSelfTest extends GridCommonAbstractTest {
             int idx = t.get1();
             UUID consumeId = t.get2();
 
-            IgniteEvents evts = grid(idx).events().enableAsync();
+            IgniteEvents evts = grid(idx).events().withAsync();
 
             evts.stopRemoteListen(consumeId);
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/processors/fs/GridGgfsTaskSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/fs/GridGgfsTaskSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/fs/GridGgfsTaskSelfTest.java
index b11d7bb..1211797 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/fs/GridGgfsTaskSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/fs/GridGgfsTaskSelfTest.java
@@ -172,7 +172,7 @@ public class GridGgfsTaskSelfTest extends GridGgfsCommonAbstractTest {
 
         assertFalse(ggfs.isAsync());
 
-        IgniteFs ggfsAsync = ggfs.enableAsync();
+        IgniteFs ggfsAsync = ggfs.withAsync();
 
         assertTrue(ggfsAsync.isAsync());
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/processors/service/GridServiceProcessorAbstractSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/service/GridServiceProcessorAbstractSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/service/GridServiceProcessorAbstractSelfTest.java
index f5e6c86..a0469b3 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/service/GridServiceProcessorAbstractSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/service/GridServiceProcessorAbstractSelfTest.java
@@ -141,8 +141,8 @@ public abstract class GridServiceProcessorAbstractSelfTest extends GridCommonAbs
     public void testSameConfiguration() throws Exception {
         String name = "dupService";
 
-        IgniteManaged svcs1 = randomGrid().managed().enableAsync();
-        IgniteManaged svcs2 = randomGrid().managed().enableAsync();
+        IgniteManaged svcs1 = randomGrid().managed().withAsync();
+        IgniteManaged svcs2 = randomGrid().managed().withAsync();
 
         svcs1.deployClusterSingleton(name, new DummyService());
 
@@ -170,8 +170,8 @@ public abstract class GridServiceProcessorAbstractSelfTest extends GridCommonAbs
     public void testDifferentConfiguration() throws Exception {
         String name = "dupService";
 
-        IgniteManaged svcs1 = randomGrid().managed().enableAsync();
-        IgniteManaged svcs2 = randomGrid().managed().enableAsync();
+        IgniteManaged svcs1 = randomGrid().managed().withAsync();
+        IgniteManaged svcs2 = randomGrid().managed().withAsync();
 
         svcs1.deployClusterSingleton(name, new DummyService());
 
@@ -255,7 +255,7 @@ public abstract class GridServiceProcessorAbstractSelfTest extends GridCommonAbs
 
         DummyService.exeLatch(name, latch);
 
-        IgniteManaged svcs = g.managed().enableAsync();
+        IgniteManaged svcs = g.managed().withAsync();
 
         svcs.deployNodeSingleton(name, new DummyService());
 
@@ -287,7 +287,7 @@ public abstract class GridServiceProcessorAbstractSelfTest extends GridCommonAbs
 
         DummyService.exeLatch(name, latch);
 
-        IgniteManaged svcs = g.managed().enableAsync();
+        IgniteManaged svcs = g.managed().withAsync();
 
         svcs.deployClusterSingleton(name, new DummyService());
 
@@ -320,7 +320,7 @@ public abstract class GridServiceProcessorAbstractSelfTest extends GridCommonAbs
 
         String name = "serviceAffinity";
 
-        IgniteManaged svcs = g.managed().enableAsync();
+        IgniteManaged svcs = g.managed().withAsync();
 
         svcs.deployKeyAffinitySingleton(name, new AffinityService(affKey),
                 CACHE_NAME, affKey);
@@ -348,7 +348,7 @@ public abstract class GridServiceProcessorAbstractSelfTest extends GridCommonAbs
 
         DummyService.exeLatch(name, latch);
 
-        IgniteManaged svcs = g.managed().enableAsync();
+        IgniteManaged svcs = g.managed().withAsync();
 
         svcs.deployMultiple(name, new DummyService(), nodeCount() * 2, 3);
 
@@ -382,7 +382,7 @@ public abstract class GridServiceProcessorAbstractSelfTest extends GridCommonAbs
 
         DummyService.exeLatch(name, latch);
 
-        IgniteManaged svcs = g.managed().enableAsync();
+        IgniteManaged svcs = g.managed().withAsync();
 
         svcs.deployMultiple(name, new DummyService(), cnt, 3);
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/processors/service/GridServiceProcessorMultiNodeSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/service/GridServiceProcessorMultiNodeSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/service/GridServiceProcessorMultiNodeSelfTest.java
index 9896ea5..fccbf85 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/service/GridServiceProcessorMultiNodeSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/service/GridServiceProcessorMultiNodeSelfTest.java
@@ -44,7 +44,7 @@ public class GridServiceProcessorMultiNodeSelfTest extends GridServiceProcessorA
 
         DummyService.exeLatch(name, latch);
 
-        IgniteManaged svcs = g.managed().enableAsync();
+        IgniteManaged svcs = g.managed().withAsync();
 
         svcs.deployClusterSingleton(name, new DummyService());
 
@@ -91,7 +91,7 @@ public class GridServiceProcessorMultiNodeSelfTest extends GridServiceProcessorA
 
         String name = "serviceAffinityUpdateTopology";
 
-        IgniteManaged svcs = g.managed().enableAsync();
+        IgniteManaged svcs = g.managed().withAsync();
 
         svcs.deployKeyAffinitySingleton(name, new AffinityService(affKey),
             CACHE_NAME, affKey);
@@ -130,7 +130,7 @@ public class GridServiceProcessorMultiNodeSelfTest extends GridServiceProcessorA
 
         DummyService.exeLatch(name, latch);
 
-        IgniteManaged svcs = g.managed().enableAsync();
+        IgniteManaged svcs = g.managed().withAsync();
 
         svcs.deployNodeSingleton(name, new DummyService());
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/loadtest/GridSingleExecutionTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/loadtest/GridSingleExecutionTest.java b/modules/core/src/test/java/org/apache/ignite/loadtest/GridSingleExecutionTest.java
index 8ca7e7e..c8c9371 100644
--- a/modules/core/src/test/java/org/apache/ignite/loadtest/GridSingleExecutionTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/loadtest/GridSingleExecutionTest.java
@@ -81,7 +81,7 @@ public final class GridSingleExecutionTest {
         try {
             Ignite ignite = G.ignite();
 
-            IgniteCompute comp = ignite.compute().enableAsync();
+            IgniteCompute comp = ignite.compute().withAsync();
 
             // Execute Hello World task.
             comp.execute(!useSes ? TestTask.class : TestSessionTask.class, null);

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/loadtests/colocation/GridTestMain.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/loadtests/colocation/GridTestMain.java b/modules/core/src/test/java/org/apache/ignite/loadtests/colocation/GridTestMain.java
index 4d8539c..0aed81d 100644
--- a/modules/core/src/test/java/org/apache/ignite/loadtests/colocation/GridTestMain.java
+++ b/modules/core/src/test/java/org/apache/ignite/loadtests/colocation/GridTestMain.java
@@ -77,7 +77,7 @@ public class GridTestMain {
 
         long start = System.currentTimeMillis();
 
-        IgniteCompute comp = g.compute().enableAsync();
+        IgniteCompute comp = g.compute().withAsync();
 
         // Collocate computations and data.
         for (long i = 0; i < GridTestConstants.ENTRY_COUNT; i++) {

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/loadtests/direct/multisplit/GridMultiSplitsLoadTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/loadtests/direct/multisplit/GridMultiSplitsLoadTest.java b/modules/core/src/test/java/org/apache/ignite/loadtests/direct/multisplit/GridMultiSplitsLoadTest.java
index 26043ac..0249cf8 100644
--- a/modules/core/src/test/java/org/apache/ignite/loadtests/direct/multisplit/GridMultiSplitsLoadTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/loadtests/direct/multisplit/GridMultiSplitsLoadTest.java
@@ -107,7 +107,7 @@ public class GridMultiSplitsLoadTest extends GridCommonAbstractTest {
         GridTestUtils.runMultiThreaded(new Runnable() {
             /** {@inheritDoc} */
             @Override public void run() {
-                IgniteCompute comp = ignite.compute().enableAsync();
+                IgniteCompute comp = ignite.compute().withAsync();
 
                 while (end - System.currentTimeMillis() > 0) {
                     int levels = 3;


Mime
View raw message