fix RocksdbTransferOffsetAndCqTest

Change-Id: I11a92eaa95f83afdda9533cd0de6857a3fbde127

Author: lizhimins

broker/src/test/java/org/apache/rocketmq/broker/offset/RocksdbTransferOffsetAndCqTest.java

@@ -42,6 +42,7 @@
 import org.apache.rocketmq.store.queue.RocksDBConsumeQueueStore;
 import org.apache.rocketmq.store.stats.BrokerStatsManager;
 import org.awaitility.Awaitility;
+import org.junit.After;
 import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;
@@ -73,9 +74,6 @@ public class RocksdbTransferOffsetAndCqTest {
 
     @Before
     public void init() throws IOException {
-        if (notToBeExecuted()) {
-            return;
-        }
         BrokerConfig brokerConfig = new BrokerConfig();
         brokerConfig.setConsumerOffsetUpdateVersionStep(10);
         MessageStoreConfig messageStoreConfig = new MessageStoreConfig();
@@ -94,12 +92,15 @@ public void init() throws IOException {
         rocksdbConsumerOffsetManager = new RocksDBConsumerOffsetManager(brokerController);
     }
 
+    @After
+    public void shutdown() {
+        consumerOffsetManager.shutdown();
+        rocksdbConsumerOffsetManager.shutdown();
+        defaultMessageStore.shutdown();
+    }
+
     @Test
     public void testTransferOffset() {
-        if (notToBeExecuted()) {
-            return;
-        }
-
         for (int i = 0; i < 200; i++) {
             consumerOffsetManager.commitOffset(clientHost, group, topic, queueId, i);
         }
@@ -133,9 +134,6 @@ public void testTransferOffset() {
 
     @Test
     public void testRocksdbCqWrite() throws RocksDBException {
-        if (notToBeExecuted()) {
-            return;
-        }
         long startTimestamp = System.currentTimeMillis();
 
         ConsumeQueueStoreInterface combineConsumeQueueStore = defaultMessageStore.getQueueStore();
@@ -166,13 +164,4 @@ public void testRocksdbCqWrite() throws RocksDBException {
         CheckRocksdbCqWriteResult result = ((CombineConsumeQueueStore) combineConsumeQueueStore).doCheckCqWriteProgress(topic, startTimestamp, StoreType.DEFAULT, StoreType.DEFAULT_ROCKSDB);
         Assert.assertEquals(CheckRocksdbCqWriteResult.CheckStatus.CHECK_OK.getValue(), result.getCheckStatus());
     }
-
-    /**
-     * No need to skip macOS platform.
-     * @return true if some platform is NOT a good fit for this test case.
-     */
-    private boolean notToBeExecuted() {
-        return false;
-    }
-
 }