ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From agoncha...@apache.org
Subject [30/37] ignite git commit: Set cache name to DEFAULT_CACHE_NAME for RocketMQ tests.
Date Thu, 27 Apr 2017 07:17:32 GMT
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-5090
Commit: f4d233cedebdf9d7487bf733fcde2f72adebd8c0
Parents: 4d26061
Author: shtykh_roman <rshtykh@yahoo.com>
Authored: Thu Apr 27 10:20:38 2017 +0900
Committer: shtykh_roman <rshtykh@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();
 


Mime
View raw message