You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vk...@apache.org on 2015/03/04 02:31:57 UTC

[27/50] [abbrv] incubator-ignite git commit: sprint-1

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 <yz...@gridgain.com>
Authored: Mon Feb 16 16:23:28 2015 +0300
Committer: Yakov Zhdanov <yz...@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() + ']');