Remove dead code

artemis-rest/src/main/java/org/apache/activemq/artemis/rest/util/TimeoutTask.java

@@ -153,7 +153,6 @@ public class TimeoutTask implements Runnable {
 
          // Finally, freely shutdown all expired consumers.
          if (expiredCallbacks.size() > 0) {
-            long startTime = System.currentTimeMillis();
             List<String> tokens = new ArrayList<>(expiredCallbacks.size());
             for (String token : expiredCallbacks.keySet()) {
                tokens.add(token);

artemis-server/src/test/java/org/apache/activemq/artemis/tests/util/ColocatedActiveMQServer.java

@@ -68,7 +68,6 @@ public class ColocatedActiveMQServer extends ActiveMQServerImpl {
    @Override
    protected NodeManager createNodeManager(final File directory, boolean replicatingBackup) {
       if (replicatingBackup) {
-         NodeManager manager;
          if (getConfiguration().getJournalType() == JournalType.ASYNCIO && LibaioContext.isLoaded()) {
             return new AIOFileLockNodeManager(directory, replicatingBackup, getConfiguration().getJournalLockAcquisitionTimeout());
          }

examples/features/clustered/clustered-topic-uri/src/main/java/org/apache/activemq/artemis/jms/example/ClusteredTopicExample.java

@@ -39,10 +39,6 @@ public class ClusteredTopicExample {
 
       Connection connection1 = null;
 
-      InitialContext ic0 = null;
-
-      InitialContext ic1 = null;
-
       try {
 
          // Step 1. Instantiate topic
@@ -116,14 +112,6 @@ public class ClusteredTopicExample {
          if (connection1 != null) {
             connection1.close();
          }
-
-         if (ic0 != null) {
-            ic0.close();
-         }
-
-         if (ic1 != null) {
-            ic1.close();
-         }
       }
    }
 }

tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/partition/SpringPartitionBrokerTest.java

@@ -35,7 +35,6 @@ public class SpringPartitionBrokerTest extends TestCase {
       Partitioning config = plugin.getConfig();
       assertEquals(2, config.getBrokers().size());
 
-      Object o;
       String json = "{\n" +
          "  \"by_client_id\":{\n" +
          "    \"client1\":{\"ids\":[\"broker1\"]},\n" +

tests/extra-tests/src/test/java/org/apache/activemq/artemis/tests/extras/byteman/GroupingTest.java

@@ -91,8 +91,6 @@ public class GroupingTest extends JMSTestBase {
          connection.start();
          connection2.start();
 
-         final String jmsxgroupID = null;
-
          Thread t = new Thread(new Runnable() {
             @Override
             public void run() {

tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/WildCardRoutingTest.java

@@ -484,7 +484,6 @@ public class WildCardRoutingTest extends ActiveMQTestBase {
    public void testWildcardRoutingWithHashMultiLengthAddresses() throws Exception {
       SimpleString addressAB = new SimpleString("a.b.c.f");
       SimpleString addressAC = new SimpleString("a.c.f");
-      SimpleString addressAD = new SimpleString("a.d");
       SimpleString address = new SimpleString("a.#.f");
       SimpleString queueName1 = new SimpleString("Q1");
       SimpleString queueName2 = new SimpleString("Q2");

tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/jms/ActiveMQConnectionFactoryTest.java

@@ -215,9 +215,6 @@ public class ActiveMQConnectionFactoryTest extends ActiveMQTestBase {
 
    private void testSettersThrowException(final ActiveMQConnectionFactory cf) {
 
-      String discoveryAddress = RandomUtil.randomString();
-      int discoveryPort = RandomUtil.randomPositiveInt();
-      long discoveryRefreshTimeout = RandomUtil.randomPositiveLong();
       String clientID = RandomUtil.randomString();
       long clientFailureCheckPeriod = RandomUtil.randomPositiveLong();
       long connectionTTL = RandomUtil.randomPositiveLong();
@@ -235,14 +232,12 @@ public class ActiveMQConnectionFactoryTest extends ActiveMQTestBase {
       String loadBalancingPolicyClassName = RandomUtil.randomString();
       int dupsOKBatchSize = RandomUtil.randomPositiveInt();
       int transactionBatchSize = RandomUtil.randomPositiveInt();
-      long initialWaitTimeout = RandomUtil.randomPositiveLong();
       boolean useGlobalPools = RandomUtil.randomBoolean();
       int scheduledThreadPoolMaxSize = RandomUtil.randomPositiveInt();
       int threadPoolMaxSize = RandomUtil.randomPositiveInt();
       long retryInterval = RandomUtil.randomPositiveLong();
       double retryIntervalMultiplier = RandomUtil.randomDouble();
       int reconnectAttempts = RandomUtil.randomPositiveInt();
-      boolean failoverOnServerShutdown = RandomUtil.randomBoolean();
 
       try {
          cf.setClientID(clientID);

tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/OpenWireTestBase.java

@@ -133,7 +133,6 @@ public class OpenWireTestBase extends ActiveMQTestBase {
       final double retryIntervalMultiplier = 1.0;
       final int reconnectAttempts = -1;
       final int callTimeout = 30000;
-      final boolean ha = false;
       List<String> connectorNames = registerConnectors(server, connectorConfigs);
 
       String cfName = name.getMethodName();

tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/persistence/RestartSMTest.java

@@ -20,7 +20,6 @@ import org.apache.activemq.artemis.core.persistence.GroupingInfo;
 import org.apache.activemq.artemis.core.persistence.QueueBindingInfo;
 import org.apache.activemq.artemis.core.persistence.impl.journal.JournalStorageManager;
 import org.apache.activemq.artemis.core.postoffice.PostOffice;
-import org.apache.activemq.artemis.core.server.Queue;
 import org.apache.activemq.artemis.tests.integration.IntegrationTestLogger;
 import org.apache.activemq.artemis.tests.unit.core.server.impl.fakes.FakeJournalLoader;
 import org.apache.activemq.artemis.tests.unit.core.server.impl.fakes.FakePostOffice;
@@ -31,9 +30,7 @@ import org.junit.Test;
 
 import java.io.File;
 import java.util.ArrayList;
-import java.util.HashMap;
 import java.util.List;
-import java.util.Map;
 import java.util.concurrent.ExecutorService;
 
 public class RestartSMTest extends ActiveMQTestBase {
@@ -78,8 +75,6 @@ public class RestartSMTest extends ActiveMQTestBase {
 
          journal.loadBindingJournal(queueBindingInfos, new ArrayList<GroupingInfo>());
 
-         Map<Long, Queue> queues = new HashMap<>();
-
          journal.loadMessageJournal(postOffice, null, null, null, null, null, null, new FakeJournalLoader());
 
          journal.stop();
@@ -88,8 +83,6 @@ public class RestartSMTest extends ActiveMQTestBase {
 
          journal.start();
 
-         queues = new HashMap<>();
-
          journal.loadMessageJournal(postOffice, null, null, null, null, null, null, new FakeJournalLoader());
 
          queueBindingInfos = new ArrayList<>();

tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQClusteredTest.java

@@ -142,9 +142,6 @@ public class ActiveMQClusteredTest extends ActiveMQRAClusteredTestBase {
          managedConnections.add(mc);
          ActiveMQConnectionFactory cf1 = mc.getConnectionFactory();
 
-         long timeout = 10000;
-         long now = System.currentTimeMillis();
-
          while (!((ServerLocatorImpl)cf1.getServerLocator()).isReceivedTopology()) {
             Thread.sleep(50);
          }

tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ResourceAdapterTest.java

@@ -133,7 +133,6 @@ public class ResourceAdapterTest extends ActiveMQRATestBase {
       String testBalancer = "testBalancer";
       String testParams = "key=val";
       String testaddress = "testaddress";
-      String loadbalancer = "loadbalancer";
       String testpass = "testpass";
       String testuser = "testuser";
       ActiveMQResourceAdapter qResourceAdapter = new ActiveMQResourceAdapter();
@@ -153,7 +152,6 @@ public class ResourceAdapterTest extends ActiveMQRATestBase {
       String testBalancer = "testBalancer2";
       String testParams = "key=val2";
       String testaddress = "testaddress2";
-      String loadbalancer = "loadbalancer2";
       String testpass = "testpass2";
       String testuser = "testuser2";
       ActiveMQResourceAdapter qResourceAdapter = new ActiveMQResourceAdapter();

tests/performance-tests/src/test/java/org/apache/activemq/artemis/tests/performance/sends/PreACKPerf.java

@@ -60,8 +60,6 @@ public class PreACKPerf extends AbstractSendReceivePerfTest {
 
       }
 
-      long end = System.currentTimeMillis();
-
       printMsgsSec(start, nmessages);
    }