#ignite-168: Renaming in java8 examples.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/8db2a83f Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/8db2a83f Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/8db2a83f Branch: refs/heads/ignite-160 Commit: 8db2a83fe50ed51e4bdf5b94e7bbb0b555229403 Parents: 5190174 Author: ivasilinets <ivasilin...@gridgain.com> Authored: Wed Feb 4 15:05:54 2015 +0300 Committer: ivasilinets <ivasilin...@gridgain.com> Committed: Wed Feb 4 15:05:54 2015 +0300 ---------------------------------------------------------------------- .../java8/org/apache/ignite/examples/ComputeExample.java | 6 +++--- .../org/apache/ignite/examples/MessagingExample.java | 10 +++++----- 2 files changed, 8 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8db2a83f/examples/src/main/java8/org/apache/ignite/examples/ComputeExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java8/org/apache/ignite/examples/ComputeExample.java b/examples/src/main/java8/org/apache/ignite/examples/ComputeExample.java index f89915e..a85c22b 100644 --- a/examples/src/main/java8/org/apache/ignite/examples/ComputeExample.java +++ b/examples/src/main/java8/org/apache/ignite/examples/ComputeExample.java @@ -39,13 +39,13 @@ public class ComputeExample { System.out.println(">>> Compute broadcast example started."); // Broadcast closure to all cluster nodes. - ignite.compute().broadcast((IgniteRunnable) () -> System.out.println("Hello World")); + ignite.compute().broadcast((IgniteRunnable)() -> System.out.println("Hello World")); // Unicast closure to some cluster node picked by load balancer. - ignite.compute().run((IgniteRunnable) () -> System.out.println("Hello World")); + ignite.compute().run((IgniteRunnable)() -> System.out.println("Hello World")); // Unicast closure to some cluster node picked by load balancer and return result. - int length = ignite.compute().call((IgniteCallable<Integer>) "Hello World"::length); + int length = ignite.compute().call((IgniteCallable<Integer>)"Hello World"::length); System.out.println(); System.out.println(">>> Computed length: " + length); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8db2a83f/examples/src/main/java8/org/apache/ignite/examples/MessagingExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java8/org/apache/ignite/examples/MessagingExample.java b/examples/src/main/java8/org/apache/ignite/examples/MessagingExample.java index 10612e5..71fa1b4 100644 --- a/examples/src/main/java8/org/apache/ignite/examples/MessagingExample.java +++ b/examples/src/main/java8/org/apache/ignite/examples/MessagingExample.java @@ -62,10 +62,10 @@ public final class MessagingExample { System.out.println(">>> Messaging example started."); // Projection for remote nodes. - ClusterGroup rmtPrj = ignite.cluster().forRemotes(); + ClusterGroup rmtGrp = ignite.cluster().forRemotes(); // Listen for messages from remote nodes to make sure that they received all the messages. - int msgCnt = rmtPrj.nodes().size() * MESSAGES_NUM; + int msgCnt = rmtGrp.nodes().size() * MESSAGES_NUM; CountDownLatch orderedLatch = new CountDownLatch(msgCnt); CountDownLatch unorderedLatch = new CountDownLatch(msgCnt); @@ -73,17 +73,17 @@ public final class MessagingExample { localListen(ignite.message(ignite.cluster().forLocal()), orderedLatch, unorderedLatch); // Register listeners on all cluster nodes. - startListening(ignite, ignite.message(rmtPrj)); + startListening(ignite, ignite.message(rmtGrp)); // Send unordered messages to all remote nodes. for (int i = 0; i < MESSAGES_NUM; i++) - ignite.message(rmtPrj).send(TOPIC.UNORDERED, Integer.toString(i)); + ignite.message(rmtGrp).send(TOPIC.UNORDERED, Integer.toString(i)); System.out.println(">>> Finished sending unordered messages."); // Send ordered messages to all remote nodes. for (int i = 0; i < MESSAGES_NUM; i++) - ignite.message(rmtPrj).sendOrdered(TOPIC.ORDERED, Integer.toString(i), 0); + ignite.message(rmtGrp).sendOrdered(TOPIC.ORDERED, Integer.toString(i), 0); System.out.println(">>> Finished sending ordered messages."); System.out.println(">>> Check output on all nodes for message printouts.");
