remove useless check in tests (#1471)

(cherry picked from commit 9e686d4)
streamnative · Dec 19, 2024 · 2dbe73c · 2dbe73c
1 parent f5b433a
commit 2dbe73c
Show file tree

Hide file tree

Showing 7 changed files with 0 additions and 21 deletions.
diff --git a/...lient/src/test/java/io/streamnative/pulsar/handlers/amqp/AmqpProtocolHandlerTestBase.java b/...lient/src/test/java/io/streamnative/pulsar/handlers/amqp/AmqpProtocolHandlerTestBase.java
@@ -374,12 +374,6 @@ public static void setFieldValue(Class clazz, Object classObj, String fieldName,
         field.set(classObj, fieldValue);
     }
 
-    public void checkPulsarServiceState() {
-        for (PulsarService pulsarService : pulsarServiceList) {
-            Mockito.when(pulsarService.getState()).thenReturn(PulsarService.State.Started);
-        }
-    }
-
     /**
      * Get available proxy port.
      * @return random proxy port

diff --git a/tests-qpid-jms-client/src/test/java/io/streamnative/pulsar/handlers/amqp/AmqpTestBase.java b/tests-qpid-jms-client/src/test/java/io/streamnative/pulsar/handlers/amqp/AmqpTestBase.java
@@ -68,8 +68,6 @@ public void setup() throws Exception {
                         NamespaceName.get(ns), "__lookup__").toString());
             }
         }
-
-        checkPulsarServiceState();
     }
 
     @AfterClass

diff --git a/...s-client/src/test/java/io/streamnative/pulsar/handlers/amqp/qpid/core/AoPBrokerAdmin.java b/...s-client/src/test/java/io/streamnative/pulsar/handlers/amqp/qpid/core/AoPBrokerAdmin.java
@@ -70,8 +70,6 @@ protected void setup() throws Exception {
                         NamespaceName.get(ns), "__lookup__").toString());
             }
         }
-
-        checkPulsarServiceState();
     }
 
     @Override

diff --git a/tests/src/test/java/com/rabbitmq/client/test/BrokerTestCase.java b/tests/src/test/java/com/rabbitmq/client/test/BrokerTestCase.java
@@ -126,7 +126,6 @@ public void setup() throws Exception {
         }
         ((PulsarClientImpl) getPulsarServiceList().get(0).getClient()).getLookup().
                 getBroker(TopicName.get("public/vhost1/test")).join();
-        checkPulsarServiceState();
         assumeTrue(shouldRun());
         openConnection();
         openChannel();

diff --git a/tests/src/test/java/io/streamnative/pulsar/handlers/amqp/AmqpProtocolHandlerTestBase.java b/tests/src/test/java/io/streamnative/pulsar/handlers/amqp/AmqpProtocolHandlerTestBase.java
@@ -401,12 +401,6 @@ public static void setFieldValue(Class clazz, Object classObj, String fieldName,
         field.set(classObj, fieldValue);
     }
 
-    public void checkPulsarServiceState() {
-        for (PulsarService pulsarService : pulsarServiceList) {
-            doReturn(PulsarService.State.Started).when(pulsarService).getState();
-        }
-    }
-
     /**
      * Get available proxy port.
      * @return random proxy port

diff --git a/tests/src/test/java/io/streamnative/pulsar/handlers/amqp/AmqpTestBase.java b/tests/src/test/java/io/streamnative/pulsar/handlers/amqp/AmqpTestBase.java
@@ -83,8 +83,6 @@ public void setup() throws Exception {
                         NamespaceName.get(ns), "__lookup__").toString());
             }
         }
-
-        checkPulsarServiceState();
     }
 
     @AfterClass

diff --git a/...s/src/test/java/io/streamnative/pulsar/handlers/amqp/AmqpTokenAuthenticationTestBase.java b/...s/src/test/java/io/streamnative/pulsar/handlers/amqp/AmqpTokenAuthenticationTestBase.java
@@ -93,8 +93,6 @@ public void setup() throws Exception {
                         NamespaceName.get(ns), "__lookup__").toString());
             }
         }
-
-        checkPulsarServiceState();
     }
 
     @AfterClass
-Original file line number
+Diff line change
@@ Expand Up / @@ -68,8 +68,6 @@ public void setup() throws Exception { @@
                             NamespaceName.get(ns), "__lookup__").toString());
                 }
             }
-            checkPulsarServiceState();
         }
         @AfterClass
@@ Expand Down @@