You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ag...@apache.org on 2015/09/05 01:45:40 UTC
[16/30] ignite git commit: ignite-1361: Fixed.
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 <as...@gridgain.com>
Authored: Fri Sep 4 14:02:13 2015 +0300
Committer: ashutak <as...@gridgain.com>
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);
}