diff --git a/integration/automation-extensions/src/main/java/org/wso2/esb/integration/common/extensions/jmsserver/ActiveMQServerExtension.java b/integration/automation-extensions/src/main/java/org/wso2/esb/integration/common/extensions/jmsserver/ActiveMQServerExtension.java
index d51d5af9d9..b71c36875c 100644
--- a/integration/automation-extensions/src/main/java/org/wso2/esb/integration/common/extensions/jmsserver/ActiveMQServerExtension.java
+++ b/integration/automation-extensions/src/main/java/org/wso2/esb/integration/common/extensions/jmsserver/ActiveMQServerExtension.java
@@ -66,4 +66,8 @@ public static void stopMQServer() {
         activeMqBroker.stop();
 
     }
+
+    public static boolean isMQServerStarted() {
+        return activeMqBroker.isBrokerStarted();
+    }
 }
diff --git a/integration/mediation-tests/tests-transport/src/test/java/org/wso2/carbon/esb/jms/transport/test/MSMPCronForwarderCase.java b/integration/mediation-tests/tests-transport/src/test/java/org/wso2/carbon/esb/jms/transport/test/MSMPCronForwarderCase.java
index 0a652bed65..b6130a2c83 100644
--- a/integration/mediation-tests/tests-transport/src/test/java/org/wso2/carbon/esb/jms/transport/test/MSMPCronForwarderCase.java
+++ b/integration/mediation-tests/tests-transport/src/test/java/org/wso2/carbon/esb/jms/transport/test/MSMPCronForwarderCase.java
@@ -22,10 +22,13 @@
 import org.testng.annotations.AfterClass;
 import org.testng.annotations.BeforeClass;
 import org.testng.annotations.Test;
+import org.wso2.carbon.automation.extensions.servers.jmsserver.controller.config.JMSBrokerConfigurationProvider;
 import org.wso2.carbon.automation.extensions.servers.tomcatserver.TomcatServerManager;
 import org.wso2.carbon.automation.extensions.servers.tomcatserver.TomcatServerType;
 import org.wso2.carbon.automation.test.utils.http.client.HttpRequestUtil;
 import org.wso2.carbon.automation.test.utils.http.client.HttpResponse;
+import org.wso2.carbon.esb.jms.utils.JMSBroker;
+import org.wso2.esb.integration.common.extensions.jmsserver.ActiveMQServerExtension;
 import org.wso2.esb.integration.common.utils.CarbonLogReader;
 import org.wso2.esb.integration.common.utils.ESBIntegrationTest;
 import org.wso2.esb.integration.services.jaxrs.customersample.CustomerConfig;
@@ -52,6 +55,9 @@ public class MSMPCronForwarderCase extends ESBIntegrationTest {
     protected void init() throws Exception {
         // START THE ESB
         super.init();
+        if (!ActiveMQServerExtension.isMQServerStarted()) {
+            ActiveMQServerExtension.startMQServer();
+        }
         carbonLogReader.start();
     }