You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2015/03/02 14:29:56 UTC
[6/6] incubator-ignite git commit: # ignite-51 minor
# ignite-51 minor
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/7f9a6630
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/7f9a6630
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/7f9a6630
Branch: refs/heads/ignite-51
Commit: 7f9a6630b9480c580b4312a44e20eeac866fe4a0
Parents: 810be9a
Author: sboikov <sb...@gridgain.com>
Authored: Mon Mar 2 16:29:23 2015 +0300
Committer: sboikov <sb...@gridgain.com>
Committed: Mon Mar 2 16:29:23 2015 +0300
----------------------------------------------------------------------
.../spi/communication/GridCacheMessageSelfTest.java | 12 ++++++++----
1 file changed, 8 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7f9a6630/modules/core/src/test/java/org/apache/ignite/spi/communication/GridCacheMessageSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/spi/communication/GridCacheMessageSelfTest.java b/modules/core/src/test/java/org/apache/ignite/spi/communication/GridCacheMessageSelfTest.java
index c011bbc..226e35b 100644
--- a/modules/core/src/test/java/org/apache/ignite/spi/communication/GridCacheMessageSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/spi/communication/GridCacheMessageSelfTest.java
@@ -101,16 +101,16 @@ public class GridCacheMessageSelfTest extends GridCommonAbstractTest {
}
});
- TestMessage message = new TestMessage();
+ TestMessage msg = new TestMessage();
for (int i = 1; i <= SAMPLE_CNT; i++) {
- mgr0.send(grid(1).localNode(), topic, message, GridIoPolicy.PUBLIC_POOL);
+ mgr0.send(grid(1).localNode(), topic, msg, GridIoPolicy.PUBLIC_POOL);
TestMessage1 mes1 = new TestMessage1();
mes1.init(new GridTestMessage(grid(1).localNode().id(), i, 0));
- message.add(mes1);
+ msg.add(mes1);
}
assert latch.await(3, SECONDS);
@@ -180,7 +180,11 @@ public class GridCacheMessageSelfTest extends GridCommonAbstractTest {
}
}
+ /**
+ *
+ */
private static class TestMessage1 extends GridCacheMessage {
+ /** */
GridTestMessage mes;
public void init(GridTestMessage mes) {
@@ -189,7 +193,7 @@ public class GridCacheMessageSelfTest extends GridCommonAbstractTest {
/** {@inheritDoc} */
@Override public byte directType() {
- return 0;
+ return DIRECT_TYPE1;
}
/** {@inheritDoc} */