diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/QueuePurgeTest.java b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/QueuePurgeTest.java
index 30b2cb23c5..3e8b647e5f 100644
--- a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/QueuePurgeTest.java
+++ b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/QueuePurgeTest.java
@@ -191,9 +191,9 @@ public class QueuePurgeTest extends CombinationTestSupport {
     private void testConcurrentPurgeAndSend(boolean prioritizedMessages) throws Exception {
         applyBrokerSpoolingPolicy(false);
         createProducerAndSendMessages(NUM_TO_SEND / 2);
-        QueueViewMBean proxy = getProxyToQueueViewMBean();
+        final QueueViewMBean proxy = getProxyToQueueViewMBean();
         createConsumer();
-        long start = System.currentTimeMillis();
+        final long start = System.currentTimeMillis();
         ExecutorService service = Executors.newFixedThreadPool(1);
         try {
             LOG.info("purging..");
diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/transport/tcp/TcpTransportCloseSocketTest.java b/activemq-unit-tests/src/test/java/org/apache/activemq/transport/tcp/TcpTransportCloseSocketTest.java
index ad2080beae..252dd22a65 100644
--- a/activemq-unit-tests/src/test/java/org/apache/activemq/transport/tcp/TcpTransportCloseSocketTest.java
+++ b/activemq-unit-tests/src/test/java/org/apache/activemq/transport/tcp/TcpTransportCloseSocketTest.java
@@ -105,7 +105,7 @@ public class TcpTransportCloseSocketTest {
         factory.setBrokerURL(uri);
         factory.setClientID("id");
 
-        TcpTransportServer server = (TcpTransportServer) brokerService.getTransportConnectorByName("tcp").getServer();
+        final TcpTransportServer server = (TcpTransportServer) brokerService.getTransportConnectorByName("tcp").getServer();
 
         //Try and create 2 connections, the second should fail because of a duplicate clientId
         int failed = 0;