Test for Network Pinger

MyTest.java

import org.apache.activemq.artemis.tests.util.ActiveMQTestBase;
import org.junit.Assert;
import org.junit.Test;

public class MyTest extends ActiveMQTestBase {

      @Test
      public void testNetworkPinger() throws Exception {
            Configuration configuration = createBasicConfig();
            configuration.setNetworkCheckPeriod(10);
            configuration.setNetworkCheckTimeout(10);
            ActiveMQServerImpl activeMQServer = new ActiveMQServerImpl(configuration);
            addServer(activeMQServer);
            activeMQServer.start();
            NetworkHealthCheck networkHealthCheck = activeMQServer.getNetworkHealthCheck();
            Thread.sleep(100);
            //Make ensure health check is ok
            Assert.assertTrue(networkHealthCheck.check());
            Assert.assertTrue(activeMQServer.isStarted());

            //Make health check fail
            System.out.println("Adding don't exist");
            networkHealthCheck.parseURIList("http://i.dont.exist");
            Thread.sleep(100);
            Assert.assertFalse(networkHealthCheck.check());
            Assert.assertFalse(activeMQServer.isStarted());

            //Make health check is ok again
            System.out.println("Clearing....");
            networkHealthCheck.clearURL();
            Thread.sleep(200);
            Assert.assertTrue(networkHealthCheck.check());
            Assert.assertTrue(activeMQServer.isStarted());

      }
}