ignite-1361: Fixed.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/cd81fff6 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/cd81fff6 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/cd81fff6 Branch: refs/heads/ignite-264 Commit: cd81fff65d6788e33a0065976ce4c3d3d1c68247 Parents: 83b6e5f Author: ashutak <[email protected]> Authored: Fri Sep 4 14:02:13 2015 +0300 Committer: ashutak <[email protected]> Committed: Fri Sep 4 14:02:13 2015 +0300 ---------------------------------------------------------------------- .../ignite/examples/messaging/MessagingPingPongExample.java | 6 +++++- .../examples/java8/messaging/MessagingPingPongExample.java | 2 +- .../org/apache/ignite/examples/MessagingExamplesSelfTest.java | 3 +-- .../ignite/java8/examples/MessagingExamplesSelfTest.java | 3 ++- 4 files changed, 9 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/cd81fff6/examples/src/main/java/org/apache/ignite/examples/messaging/MessagingPingPongExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/messaging/MessagingPingPongExample.java b/examples/src/main/java/org/apache/ignite/examples/messaging/MessagingPingPongExample.java index eca4a2c..a2ba227 100644 --- a/examples/src/main/java/org/apache/ignite/examples/messaging/MessagingPingPongExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/messaging/MessagingPingPongExample.java @@ -26,6 +26,7 @@ import org.apache.ignite.cluster.ClusterGroup; import org.apache.ignite.examples.ExampleNodeStartup; import org.apache.ignite.examples.ExamplesUtils; import org.apache.ignite.lang.IgniteBiPredicate; +import org.apache.ignite.resources.IgniteInstanceResource; /** * Demonstrates simple message exchange between local and remote nodes. @@ -64,6 +65,9 @@ public class MessagingPingPongExample { // Set up remote player. ignite.message(nodeB).remoteListen(null, new IgniteBiPredicate<UUID, String>() { + @IgniteInstanceResource + private Ignite ignite; + @Override public boolean apply(UUID nodeId, String rcvMsg) { System.out.println("Received message [msg=" + rcvMsg + ", sender=" + nodeId + ']'); @@ -116,4 +120,4 @@ public class MessagingPingPongExample { } } } -} \ No newline at end of file +} http://git-wip-us.apache.org/repos/asf/ignite/blob/cd81fff6/examples/src/main/java8/org/apache/ignite/examples/java8/messaging/MessagingPingPongExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java8/org/apache/ignite/examples/java8/messaging/MessagingPingPongExample.java b/examples/src/main/java8/org/apache/ignite/examples/java8/messaging/MessagingPingPongExample.java index 9962748..133e735 100644 --- a/examples/src/main/java8/org/apache/ignite/examples/java8/messaging/MessagingPingPongExample.java +++ b/examples/src/main/java8/org/apache/ignite/examples/java8/messaging/MessagingPingPongExample.java @@ -110,4 +110,4 @@ public class MessagingPingPongExample { } } } -} \ No newline at end of file +} http://git-wip-us.apache.org/repos/asf/ignite/blob/cd81fff6/examples/src/test/java/org/apache/ignite/examples/MessagingExamplesSelfTest.java ---------------------------------------------------------------------- diff --git a/examples/src/test/java/org/apache/ignite/examples/MessagingExamplesSelfTest.java b/examples/src/test/java/org/apache/ignite/examples/MessagingExamplesSelfTest.java index a5b4329..66cddb4 100644 --- a/examples/src/test/java/org/apache/ignite/examples/MessagingExamplesSelfTest.java +++ b/examples/src/test/java/org/apache/ignite/examples/MessagingExamplesSelfTest.java @@ -39,7 +39,6 @@ public class MessagingExamplesSelfTest extends GridAbstractExamplesTest { } /** - * TODO IGNITE-533 * @throws Exception If failed. */ public void testMessagingPingPongExample() throws Exception { @@ -52,4 +51,4 @@ public class MessagingExamplesSelfTest extends GridAbstractExamplesTest { public void testMessagingPingPongListenActorExample() throws Exception { MessagingPingPongListenActorExample.main(EMPTY_ARGS); } -} \ No newline at end of file +} http://git-wip-us.apache.org/repos/asf/ignite/blob/cd81fff6/examples/src/test/java8/org/apache/ignite/java8/examples/MessagingExamplesSelfTest.java ---------------------------------------------------------------------- diff --git a/examples/src/test/java8/org/apache/ignite/java8/examples/MessagingExamplesSelfTest.java b/examples/src/test/java8/org/apache/ignite/java8/examples/MessagingExamplesSelfTest.java index 0948a2a..c77e4b6 100644 --- a/examples/src/test/java8/org/apache/ignite/java8/examples/MessagingExamplesSelfTest.java +++ b/examples/src/test/java8/org/apache/ignite/java8/examples/MessagingExamplesSelfTest.java @@ -38,10 +38,11 @@ public class MessagingExamplesSelfTest extends GridAbstractExamplesTest { } /** - * TODO IGNITE-533 * @throws Exception If failed. */ public void testMessagingPingPongExample() throws Exception { + fail("https://issues.apache.org/jira/browse/IGNITE-10";); + MessagingPingPongExample.main(EMPTY_ARGS); }
