remove useless check in tests (#1471)

Author: gaoran10

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

@@ -373,12 +373,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

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

tests-qpid-jms-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

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();

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

@@ -400,12 +400,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

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

tests/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