sprint-1
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/d7866660 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/d7866660 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/d7866660 Branch: refs/heads/master Commit: d78666605989c9e23250726e5fed513fa5bbe215 Parents: 3ba4f3c Author: Yakov Zhdanov <yzhda...@gridgain.com> Authored: Mon Feb 16 16:23:28 2015 +0300 Committer: Yakov Zhdanov <yzhda...@gridgain.com> Committed: Mon Feb 16 16:23:28 2015 +0300 ---------------------------------------------------------------------- .../apache/ignite/examples/datastructures/IgniteQueueExample.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d7866660/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteQueueExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteQueueExample.java b/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteQueueExample.java index df043c8..4219dd1 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteQueueExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteQueueExample.java @@ -121,7 +121,7 @@ public class IgniteQueueExample { final String queueName = queue.name(); // Write queue items on each node. - ignite.compute().run(new QueueClosure(queueName, true)); + ignite.compute().broadcast(new QueueClosure(queueName, true)); System.out.println("Queue size after writing [expected=" + ignite.cluster().nodes().size() * RETRIES + ", actual=" + queue.size() + ']');
