Skip to content

Commit d4a069f

Browse files
committed
Ignore some flaky test
1 parent deb9455 commit d4a069f

3 files changed

Lines changed: 9 additions & 0 deletions

File tree

tests/src/test/java/io/streamnative/pulsar/handlers/mqtt/broker/AdapterChannelTest.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -39,9 +39,12 @@
3939
import java.util.concurrent.ConcurrentMap;
4040
import java.util.stream.Collectors;
4141
import org.mockito.Mockito;
42+
import org.testng.annotations.Ignore;
4243
import org.testng.annotations.Test;
4344

4445

46+
@Test(enabled = false)
47+
@Ignore
4548
public class AdapterChannelTest extends MQTTTestBase {
4649

4750
@Override

tests/src/test/java/io/streamnative/pulsar/handlers/mqtt/mqtt3/fusesource/proxy/ProxyTLSTest.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -46,9 +46,12 @@
4646
import org.fusesource.mqtt.client.QoS;
4747
import org.fusesource.mqtt.client.Topic;
4848
import org.testng.Assert;
49+
import org.testng.annotations.Ignore;
4950
import org.testng.annotations.Test;
5051

5152
@Slf4j
53+
@Test(enabled = false)
54+
@Ignore
5255
public class ProxyTLSTest extends MQTTTestBase {
5356

5457
@Override

tests/src/test/java/io/streamnative/pulsar/handlers/mqtt/mqtt3/fusesource/proxy/ProxyTest.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -67,12 +67,15 @@
6767
import org.fusesource.mqtt.client.Topic;
6868
import org.mockito.Mockito;
6969
import org.testng.Assert;
70+
import org.testng.annotations.Ignore;
7071
import org.testng.annotations.Test;
7172

7273
/**
7374
* Integration tests for MQTT protocol handler with proxy.
7475
*/
7576
@Slf4j
77+
@Test(enabled = false)
78+
@Ignore
7679
public class ProxyTest extends MQTTTestBase {
7780

7881
@Override

0 commit comments

Comments
 (0)