You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by je...@apache.org on 2018/03/16 16:06:09 UTC
[geode] branch develop updated: GEODE-4870: Categorize
AlterAsyncEventQueueCommandDUnitTest as DistributedTest (#1626)
This is an automated email from the ASF dual-hosted git repository.
jensdeppe pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/geode.git
The following commit(s) were added to refs/heads/develop by this push:
new 44dc697 GEODE-4870: Categorize AlterAsyncEventQueueCommandDUnitTest as DistributedTest (#1626)
44dc697 is described below
commit 44dc6970f44bb7a5424920d4dc205b0d3c5cd341
Author: Jens Deppe <jd...@pivotal.io>
AuthorDate: Fri Mar 16 09:06:05 2018 -0700
GEODE-4870: Categorize AlterAsyncEventQueueCommandDUnitTest as DistributedTest (#1626)
---
.../cli/commands/AlterAsyncEventQueueCommandDUnitTest.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git a/geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/AlterAsyncEventQueueCommandDUnitTest.java b/geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/AlterAsyncEventQueueCommandDUnitTest.java
index b7fa9db..f4d5934 100644
--- a/geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/AlterAsyncEventQueueCommandDUnitTest.java
+++ b/geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/AlterAsyncEventQueueCommandDUnitTest.java
@@ -27,11 +27,11 @@ import org.apache.geode.internal.cache.InternalCache;
import org.apache.geode.internal.cache.wan.MyAsyncEventListener;
import org.apache.geode.test.dunit.rules.ClusterStartupRule;
import org.apache.geode.test.dunit.rules.MemberVM;
-import org.apache.geode.test.junit.categories.AcceptanceTest;
+import org.apache.geode.test.junit.categories.DistributedTest;
import org.apache.geode.test.junit.rules.GfshCommandRule;
-@Category(AcceptanceTest.class)
+@Category(DistributedTest.class)
public class AlterAsyncEventQueueCommandDUnitTest {
@Rule
@@ -40,7 +40,7 @@ public class AlterAsyncEventQueueCommandDUnitTest {
@Rule
public GfshCommandRule gfsh = new GfshCommandRule();
- private static MemberVM locator, server1, server2;
+ private static MemberVM locator, server1;
@Before
public void beforeClass() throws Exception {
@@ -63,7 +63,7 @@ public class AlterAsyncEventQueueCommandDUnitTest {
InternalCache cache = ClusterStartupRule.getCache();
AsyncEventQueue queue = cache.getAsyncEventQueue("queue1");
assertThat(queue.getBatchSize()).isEqualTo(100);
- assertThat(queue.getBatchTimeInterval()).isEqualTo(1000);
+ assertThat(queue.getBatchTimeInterval()).isEqualTo(5);
assertThat(queue.getMaximumQueueMemory()).isEqualTo(100);
});
@@ -76,7 +76,7 @@ public class AlterAsyncEventQueueCommandDUnitTest {
InternalCache cache = ClusterStartupRule.getCache();
AsyncEventQueue queue = cache.getAsyncEventQueue("queue1");
assertThat(queue.getBatchSize()).isEqualTo(100);
- assertThat(queue.getBatchTimeInterval()).isEqualTo(1000);
+ assertThat(queue.getBatchTimeInterval()).isEqualTo(5);
assertThat(queue.getMaximumQueueMemory()).isEqualTo(100);
assertThat(cache.getAsyncEventQueue("queue2")).isNull();
});
--
To stop receiving notification emails like this one, please contact
jensdeppe@apache.org.