You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sh...@apache.org on 2017/04/27 01:21:05 UTC
ignite git commit: Set cache name to DEFAULT_CACHE_NAME for RocketMQ
tests.
Repository: ignite
Updated Branches:
refs/heads/ignite-2.0 4d260619b -> f4d233ced
Set cache name to DEFAULT_CACHE_NAME for RocketMQ tests.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/f4d233ce
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/f4d233ce
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/f4d233ce
Branch: refs/heads/ignite-2.0
Commit: f4d233cedebdf9d7487bf733fcde2f72adebd8c0
Parents: 4d26061
Author: shtykh_roman <rs...@yahoo.com>
Authored: Thu Apr 27 10:20:38 2017 +0900
Committer: shtykh_roman <rs...@yahoo.com>
Committed: Thu Apr 27 10:20:38 2017 +0900
----------------------------------------------------------------------
.../apache/ignite/stream/rocketmq/RocketMQStreamerTest.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/f4d233ce/modules/rocketmq/src/test/java/org/apache/ignite/stream/rocketmq/RocketMQStreamerTest.java
----------------------------------------------------------------------
diff --git a/modules/rocketmq/src/test/java/org/apache/ignite/stream/rocketmq/RocketMQStreamerTest.java b/modules/rocketmq/src/test/java/org/apache/ignite/stream/rocketmq/RocketMQStreamerTest.java
index 59451e9..44b0030 100644
--- a/modules/rocketmq/src/test/java/org/apache/ignite/stream/rocketmq/RocketMQStreamerTest.java
+++ b/modules/rocketmq/src/test/java/org/apache/ignite/stream/rocketmq/RocketMQStreamerTest.java
@@ -67,7 +67,7 @@ public class RocketMQStreamerTest extends GridCommonAbstractTest {
/** {@inheritDoc} */
@Override protected void afterTest() throws Exception {
- grid().cache(null).clear();
+ grid().cache(DEFAULT_CACHE_NAME).clear();
}
/** {@inheritDoc} */
@@ -97,7 +97,7 @@ public class RocketMQStreamerTest extends GridCommonAbstractTest {
Ignite ignite = grid();
- try (IgniteDataStreamer<String, byte[]> dataStreamer = ignite.dataStreamer(null)) {
+ try (IgniteDataStreamer<String, byte[]> dataStreamer = ignite.dataStreamer(DEFAULT_CACHE_NAME)) {
dataStreamer.allowOverwrite(true);
dataStreamer.autoFlushFrequency(10);
@@ -113,7 +113,7 @@ public class RocketMQStreamerTest extends GridCommonAbstractTest {
streamer.start();
- IgniteCache<String, String> cache = ignite.cache(null);
+ IgniteCache<String, String> cache = ignite.cache(DEFAULT_CACHE_NAME);
assertEquals(0, cache.size(CachePeekMode.PRIMARY));
@@ -129,7 +129,7 @@ public class RocketMQStreamerTest extends GridCommonAbstractTest {
}
};
- ignite.events(ignite.cluster().forCacheNodes(null)).remoteListen(putLsnr, null, EVT_CACHE_OBJECT_PUT);
+ ignite.events(ignite.cluster().forCacheNodes(DEFAULT_CACHE_NAME)).remoteListen(putLsnr, null, EVT_CACHE_OBJECT_PUT);
produceData();