ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vkuliche...@apache.org
Subject [27/50] [abbrv] incubator-ignite git commit: sprint-1
Date Wed, 04 Mar 2015 01:31:57 GMT
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 <yzhdanov@gridgain.com>
Authored: Mon Feb 16 16:23:28 2015 +0300
Committer: Yakov Zhdanov <yzhdanov@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() + ']');


Mime
View raw message