Skip to content

Commit 2dbe73c

Browse files
committed
remove useless check in tests (#1471)
(cherry picked from commit 9e686d4)
1 parent f5b433a commit 2dbe73c

File tree

7 files changed

+0
-21
lines changed

7 files changed

+0
-21
lines changed

tests-qpid-jms-client/src/test/java/io/streamnative/pulsar/handlers/amqp/AmqpProtocolHandlerTestBase.java

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -374,12 +374,6 @@ public static void setFieldValue(Class clazz, Object classObj, String fieldName,
374374
field.set(classObj, fieldValue);
375375
}
376376

377-
public void checkPulsarServiceState() {
378-
for (PulsarService pulsarService : pulsarServiceList) {
379-
Mockito.when(pulsarService.getState()).thenReturn(PulsarService.State.Started);
380-
}
381-
}
382-
383377
/**
384378
* Get available proxy port.
385379
* @return random proxy port

tests-qpid-jms-client/src/test/java/io/streamnative/pulsar/handlers/amqp/AmqpTestBase.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -68,8 +68,6 @@ public void setup() throws Exception {
6868
NamespaceName.get(ns), "__lookup__").toString());
6969
}
7070
}
71-
72-
checkPulsarServiceState();
7371
}
7472

7573
@AfterClass

tests-qpid-jms-client/src/test/java/io/streamnative/pulsar/handlers/amqp/qpid/core/AoPBrokerAdmin.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -70,8 +70,6 @@ protected void setup() throws Exception {
7070
NamespaceName.get(ns), "__lookup__").toString());
7171
}
7272
}
73-
74-
checkPulsarServiceState();
7573
}
7674

7775
@Override

tests/src/test/java/com/rabbitmq/client/test/BrokerTestCase.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -126,7 +126,6 @@ public void setup() throws Exception {
126126
}
127127
((PulsarClientImpl) getPulsarServiceList().get(0).getClient()).getLookup().
128128
getBroker(TopicName.get("public/vhost1/test")).join();
129-
checkPulsarServiceState();
130129
assumeTrue(shouldRun());
131130
openConnection();
132131
openChannel();

tests/src/test/java/io/streamnative/pulsar/handlers/amqp/AmqpProtocolHandlerTestBase.java

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -401,12 +401,6 @@ public static void setFieldValue(Class clazz, Object classObj, String fieldName,
401401
field.set(classObj, fieldValue);
402402
}
403403

404-
public void checkPulsarServiceState() {
405-
for (PulsarService pulsarService : pulsarServiceList) {
406-
doReturn(PulsarService.State.Started).when(pulsarService).getState();
407-
}
408-
}
409-
410404
/**
411405
* Get available proxy port.
412406
* @return random proxy port

tests/src/test/java/io/streamnative/pulsar/handlers/amqp/AmqpTestBase.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -83,8 +83,6 @@ public void setup() throws Exception {
8383
NamespaceName.get(ns), "__lookup__").toString());
8484
}
8585
}
86-
87-
checkPulsarServiceState();
8886
}
8987

9088
@AfterClass

tests/src/test/java/io/streamnative/pulsar/handlers/amqp/AmqpTokenAuthenticationTestBase.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -93,8 +93,6 @@ public void setup() throws Exception {
9393
NamespaceName.get(ns), "__lookup__").toString());
9494
}
9595
}
96-
97-
checkPulsarServiceState();
9896
}
9997

10098
@AfterClass

0 commit comments

Comments
 (0)