mirror of
https://github.com/apache/rocketmq.git
synced 2026-10-30 18:44:38 +08:00
Ignore all container tests because they cost too much time and are unstable
This commit is contained in:
@@ -25,11 +25,12 @@ import org.apache.rocketmq.remoting.exception.RemotingSendRequestException;
|
||||
import org.apache.rocketmq.remoting.exception.RemotingTimeoutException;
|
||||
import org.junit.AfterClass;
|
||||
import org.junit.BeforeClass;
|
||||
import org.junit.Ignore;
|
||||
import org.junit.Test;
|
||||
|
||||
import static org.assertj.core.api.Assertions.assertThat;
|
||||
|
||||
|
||||
@Ignore
|
||||
public class AddAndRemoveBrokerIT extends ContainerIntegrationTestBase {
|
||||
private static BrokerContainer brokerContainer4;
|
||||
|
||||
|
||||
@@ -22,12 +22,13 @@ import org.apache.rocketmq.container.InnerSalveBrokerController;
|
||||
import org.apache.rocketmq.common.protocol.RequestCode;
|
||||
import org.apache.rocketmq.remoting.RPCHook;
|
||||
import org.apache.rocketmq.remoting.protocol.RemotingCommand;
|
||||
import org.junit.Ignore;
|
||||
import org.junit.Test;
|
||||
|
||||
import static org.assertj.core.api.Assertions.assertThat;
|
||||
import static org.awaitility.Awaitility.await;
|
||||
|
||||
|
||||
@Ignore
|
||||
public class BrokerFailoverIT extends ContainerIntegrationTestBase {
|
||||
|
||||
@Test
|
||||
|
||||
@@ -20,11 +20,12 @@ package org.apache.rocketmq.test.container;
|
||||
import java.time.Duration;
|
||||
import org.apache.rocketmq.common.BrokerConfig;
|
||||
import org.apache.rocketmq.common.protocol.body.BrokerMemberGroup;
|
||||
import org.junit.Ignore;
|
||||
import org.junit.Test;
|
||||
|
||||
import static org.awaitility.Awaitility.await;
|
||||
|
||||
|
||||
@Ignore
|
||||
public class BrokerMemberGroupIT extends ContainerIntegrationTestBase {
|
||||
@Test
|
||||
public void testSyncBrokerMemberGroup() throws Exception {
|
||||
|
||||
@@ -34,12 +34,13 @@ import org.apache.rocketmq.remoting.exception.RemotingException;
|
||||
import org.apache.rocketmq.store.DefaultMessageStore;
|
||||
import org.junit.AfterClass;
|
||||
import org.junit.BeforeClass;
|
||||
import org.junit.Ignore;
|
||||
import org.junit.Test;
|
||||
|
||||
import static org.assertj.core.api.Java6Assertions.assertThat;
|
||||
import static org.awaitility.Awaitility.await;
|
||||
|
||||
|
||||
@Ignore
|
||||
public class GetMaxOffsetFromSlaveIT extends ContainerIntegrationTestBase {
|
||||
private static DefaultMQProducer mqProducer;
|
||||
|
||||
|
||||
@@ -44,11 +44,13 @@ import org.apache.rocketmq.remoting.exception.RemotingException;
|
||||
import org.apache.rocketmq.store.DefaultMessageStore;
|
||||
import org.junit.AfterClass;
|
||||
import org.junit.BeforeClass;
|
||||
import org.junit.Ignore;
|
||||
import org.junit.Test;
|
||||
|
||||
import static org.assertj.core.api.Java6Assertions.assertThat;
|
||||
import static org.awaitility.Awaitility.await;
|
||||
|
||||
@Ignore
|
||||
public class PullMultipleReplicasIT extends ContainerIntegrationTestBase {
|
||||
private static DefaultMQPullConsumer pullConsumer;
|
||||
private static DefaultMQProducer producer;
|
||||
|
||||
@@ -31,10 +31,12 @@ import org.apache.rocketmq.common.consumer.ConsumeFromWhere;
|
||||
import org.apache.rocketmq.common.message.Message;
|
||||
import org.junit.AfterClass;
|
||||
import org.junit.BeforeClass;
|
||||
import org.junit.Ignore;
|
||||
import org.junit.Test;
|
||||
|
||||
import static org.awaitility.Awaitility.await;
|
||||
|
||||
@Ignore
|
||||
public class PushMultipleReplicasIT extends ContainerIntegrationTestBase {
|
||||
private static DefaultMQProducer producer;
|
||||
|
||||
|
||||
@@ -43,6 +43,7 @@ import static org.awaitility.Awaitility.await;
|
||||
/**
|
||||
* Test lock on slave when acting master enabled
|
||||
*/
|
||||
@Ignore
|
||||
public class RebalanceLockOnSlaveIT extends ContainerIntegrationTestBase {
|
||||
private static final String THREE_REPLICA_CONSUMER_GROUP = "SyncConsumerOffsetIT_ConsumerThreeReplica";
|
||||
|
||||
|
||||
@@ -41,6 +41,7 @@ import org.junit.Test;
|
||||
import static org.assertj.core.api.Java6Assertions.assertThat;
|
||||
import static org.awaitility.Awaitility.await;
|
||||
|
||||
@Ignore
|
||||
public class ScheduledMessageIT extends ContainerIntegrationTestBase {
|
||||
private static DefaultMQProducer producer;
|
||||
|
||||
|
||||
@@ -32,11 +32,13 @@ import org.apache.rocketmq.remoting.exception.RemotingException;
|
||||
import org.apache.rocketmq.store.DefaultMessageStore;
|
||||
import org.junit.AfterClass;
|
||||
import org.junit.BeforeClass;
|
||||
import org.junit.Ignore;
|
||||
import org.junit.Test;
|
||||
|
||||
import static org.assertj.core.api.Java6Assertions.assertThat;
|
||||
import static org.awaitility.Awaitility.await;
|
||||
|
||||
@Ignore
|
||||
public class SendMultipleReplicasIT extends ContainerIntegrationTestBase {
|
||||
private static DefaultMQProducer mqProducer;
|
||||
|
||||
|
||||
@@ -21,11 +21,13 @@ import java.time.Duration;
|
||||
import java.util.concurrent.TimeUnit;
|
||||
import org.apache.rocketmq.common.protocol.body.ClusterInfo;
|
||||
import org.apache.rocketmq.store.DefaultMessageStore;
|
||||
import org.junit.Ignore;
|
||||
import org.junit.Test;
|
||||
|
||||
import static org.assertj.core.api.Assertions.assertThat;
|
||||
import static org.awaitility.Awaitility.await;
|
||||
|
||||
@Ignore
|
||||
public class SlaveBrokerIT extends ContainerIntegrationTestBase {
|
||||
@Test
|
||||
public void reAddSlaveBroker() throws Exception {
|
||||
|
||||
@@ -44,11 +44,13 @@ import org.apache.rocketmq.remoting.common.RemotingHelper;
|
||||
import org.apache.rocketmq.remoting.exception.RemotingException;
|
||||
import org.junit.AfterClass;
|
||||
import org.junit.BeforeClass;
|
||||
import org.junit.Ignore;
|
||||
import org.junit.Test;
|
||||
|
||||
import static org.assertj.core.api.Java6Assertions.assertThat;
|
||||
import static org.awaitility.Awaitility.await;
|
||||
|
||||
@Ignore
|
||||
public class SyncConsumerOffsetIT extends ContainerIntegrationTestBase {
|
||||
private static final String THREE_REPLICA_CONSUMER_GROUP = "SyncConsumerOffsetIT_ConsumerThreeReplica";
|
||||
private static final String TEST_SYNC_TOPIC = SyncConsumerOffsetIT.class.getSimpleName() + "_topic";
|
||||
|
||||
Reference in New Issue
Block a user