#ignite-738: IgniteTxMultiNodeAbstractTest uses new query Api.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/aad30f7f Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/aad30f7f Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/aad30f7f Branch: refs/heads/ignite-485 Commit: aad30f7ff8ee14e519e271dc124352f7aef4ed08 Parents: 0cdd605 Author: ivasilinets <ivasilin...@gridgain.com> Authored: Mon Apr 13 16:38:03 2015 +0300 Committer: ivasilinets <ivasilin...@gridgain.com> Committed: Mon Apr 13 16:38:03 2015 +0300 ---------------------------------------------------------------------- .../processors/cache/IgniteTxMultiNodeAbstractTest.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/aad30f7f/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteTxMultiNodeAbstractTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteTxMultiNodeAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteTxMultiNodeAbstractTest.java index a9aa484..9995099 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteTxMultiNodeAbstractTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteTxMultiNodeAbstractTest.java @@ -294,15 +294,15 @@ public abstract class IgniteTxMultiNodeAbstractTest extends GridCommonAbstractTe } while (true) { - CacheQuery<Map.Entry<String, Integer>> qry = - ((IgniteKernal)ignite).<String, Integer>getCache(null).queries() - .createSqlQuery(Integer.class, "_key != 'RMVD_CNTR_KEY' and _val >= 0"); + + SqlQuery<String, Integer> qry = + new SqlQuery<>(Integer.class, "_key != 'RMVD_CNTR_KEY' and _val >= 0"); if (DEBUG) ignite.log().info("Before executing query [retry=" + retry + ", locId=" + locId + ", txId=" + tx.xid() + ']'); - Map.Entry<String, Integer> entry = qry.execute().next(); + Cache.Entry<String, Integer> entry = F.first(cache.query(qry).getAll()); if (entry == null) { ignite.log().info("*** Queue is empty.");
