Fixed test.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/45ced671 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/45ced671 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/45ced671 Branch: refs/heads/ignite-843 Commit: 45ced671788bc804ca01ce17872316152dfe6acd Parents: 86f8037 Author: sboikov <[email protected]> Authored: Tue Sep 8 13:31:56 2015 +0300 Committer: sboikov <[email protected]> Committed: Tue Sep 8 13:31:56 2015 +0300 ---------------------------------------------------------------------- ...GridCacheQueueMultiNodeAbstractSelfTest.java | 34 ++++++++++---------- 1 file changed, 17 insertions(+), 17 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/45ced671/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheQueueMultiNodeAbstractSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheQueueMultiNodeAbstractSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheQueueMultiNodeAbstractSelfTest.java index 1dca379..097181c 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheQueueMultiNodeAbstractSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheQueueMultiNodeAbstractSelfTest.java @@ -466,8 +466,6 @@ public abstract class GridCacheQueueMultiNodeAbstractSelfTest extends IgniteColl * @throws Exception If failed. */ public void testIterator() throws Exception { - fail("https://issues.apache.org/jira/browse/IGNITE-583";); - final String queueName = UUID.randomUUID().toString(); info("Queue name: " + queueName); @@ -475,35 +473,37 @@ public abstract class GridCacheQueueMultiNodeAbstractSelfTest extends IgniteColl try (IgniteQueue<Integer> queue = grid(0).queue(queueName, QUEUE_CAPACITY, config(false))) { assertTrue(queue.isEmpty()); - grid(0).compute().call(new AddAllJob(queueName, RETRIES)); + grid(0).compute().broadcast(new AddAllJob(queueName, RETRIES)); assertEquals(GRID_CNT * RETRIES, queue.size()); Collection<ClusterNode> nodes = grid(0).cluster().nodes(); for (ClusterNode node : nodes) { - Collection<Integer> queueElements = compute(grid(0).cluster().forNode(node)).call(new IgniteCallable<Collection<Integer>>() { - @IgniteInstanceResource - private Ignite grid; + Collection<Integer> queueElements = compute(grid(0).cluster().forNode(node)).call( + new IgniteCallable<Collection<Integer>>() { + @IgniteInstanceResource + private Ignite grid; - /** {@inheritDoc} */ - @Override public Collection<Integer> call() throws Exception { - Collection<Integer> values = new ArrayList<>(); + /** {@inheritDoc} */ + @Override public Collection<Integer> call() throws Exception { + Collection<Integer> values = new ArrayList<>(); - grid.log().info("Running job [node=" + grid.cluster().localNode().id() + ", job=" + this + "]"); + grid.log().info("Running job [node=" + grid.cluster().localNode().id() + "]"); - IgniteQueue<Integer> locQueue = grid.queue(queueName, 0, null); + IgniteQueue<Integer> locQueue = grid.queue(queueName, 0, null); - grid.log().info("Queue size " + locQueue.size()); + grid.log().info("Queue size " + locQueue.size()); - for (Integer element : locQueue) - values.add(element); + for (Integer element : locQueue) + values.add(element); - grid.log().info("Returning: " + values); + grid.log().info("Returning: " + values); - return values; + return values; + } } - }); + ); assertTrue(F.eqOrdered(queue, queueElements)); }
