activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [23/42] activemq-artemis git commit: Add missing @Override annotations
Date Mon, 07 Dec 2015 18:39:35 GMT
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/DestinationInterceptorDurableSubTest.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/DestinationInterceptorDurableSubTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/DestinationInterceptorDurableSubTest.java
index fb001ee..205a7b9 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/DestinationInterceptorDurableSubTest.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/DestinationInterceptorDurableSubTest.java
@@ -199,10 +199,12 @@ public class DestinationInterceptorDurableSubTest extends EmbeddedBrokerTestSupp
       return false;
    }
 
+   @Override
    protected void tearDown() throws Exception {
       super.tearDown();
    }
 
+   @Override
    protected BrokerService createBroker() throws Exception {
       XBeanBrokerFactory factory = new XBeanBrokerFactory();
       BrokerService answer = factory.createBroker(new URI(getBrokerConfigUri()));
@@ -241,11 +243,13 @@ public class DestinationInterceptorDurableSubTest extends EmbeddedBrokerTestSupp
       /* (non-Javadoc)
        * @see org.apache.activemq.broker.region.DestinationInterceptor#intercept(org.apache.activemq.broker.region.Destination)
        */
+      @Override
       public Destination intercept(final Destination destination) {
          LOG.info("intercept({})", destination.getName());
 
          if (!destination.getActiveMQDestination().getPhysicalName().startsWith("ActiveMQ")) {
             return new DestinationFilter(destination) {
+               @Override
                public void send(ProducerBrokerExchange context, Message message) throws Exception {
                   // Send message to Destination
                   if (LOG.isDebugEnabled()) {
@@ -262,6 +266,7 @@ public class DestinationInterceptorDurableSubTest extends EmbeddedBrokerTestSupp
       /* (non-Javadoc)
        * @see org.apache.activemq.broker.region.DestinationInterceptor#remove(org.apache.activemq.broker.region.Destination)
        */
+      @Override
       public void remove(Destination destination) {
          LOG.info("remove({})", destination.getName());
          this.broker = null;
@@ -270,6 +275,7 @@ public class DestinationInterceptorDurableSubTest extends EmbeddedBrokerTestSupp
       /* (non-Javadoc)
        * @see org.apache.activemq.broker.region.DestinationInterceptor#create(org.apache.activemq.broker.Broker, org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ActiveMQDestination)
        */
+      @Override
       public void create(Broker broker, ConnectionContext context, ActiveMQDestination destination) throws Exception {
          LOG.info("create(" + broker.getBrokerName() + ", " + context.toString() + ", " + destination.getPhysicalName());
       }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/MirroredQueueCorrectMemoryUsageTest.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/MirroredQueueCorrectMemoryUsageTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/MirroredQueueCorrectMemoryUsageTest.java
index 3b0c03d..47fa95f 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/MirroredQueueCorrectMemoryUsageTest.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/MirroredQueueCorrectMemoryUsageTest.java
@@ -132,11 +132,13 @@ public class MirroredQueueCorrectMemoryUsageTest extends EmbeddedBrokerTestSuppo
       return broker;
    }
 
+   @Override
    @Before
    protected void setUp() throws Exception {
       super.setUp();
    }
 
+   @Override
    @After
    protected void tearDown() throws Exception {
       super.tearDown();

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/VirtualTopicDLQTest.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/VirtualTopicDLQTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/VirtualTopicDLQTest.java
index 9abcbc7..9e8974b 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/VirtualTopicDLQTest.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/VirtualTopicDLQTest.java
@@ -74,6 +74,7 @@ public class VirtualTopicDLQTest extends TestCase {
    // Number of messages
    private static final int numberMessages = 6;
 
+   @Override
    @Before
    public void setUp() throws Exception {
       try {
@@ -87,6 +88,7 @@ public class VirtualTopicDLQTest extends TestCase {
       }
    }
 
+   @Override
    @After
    public void tearDown() throws Exception {
       try {
@@ -235,6 +237,7 @@ public class VirtualTopicDLQTest extends TestCase {
          return latch;
       }
 
+      @Override
       public void run() {
          ActiveMQConnectionFactory connectionFactory = null;
          ActiveMQConnection connection = null;
@@ -326,6 +329,7 @@ public class VirtualTopicDLQTest extends TestCase {
          return latch;
       }
 
+      @Override
       public void run() {
 
          try {
@@ -383,6 +387,7 @@ public class VirtualTopicDLQTest extends TestCase {
          }
       }
 
+      @Override
       public synchronized void onException(JMSException ex) {
          ex.printStackTrace();
          LOG.error("Consumer for destination, (" + destinationName + "), JMS Exception occurred.  Shutting down client.");
@@ -392,6 +397,7 @@ public class VirtualTopicDLQTest extends TestCase {
          this.bStop = bStop;
       }
 
+      @Override
       public synchronized void onMessage(Message message) {
          receivedMessageCounter++;
          latch.countDown();

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/VirtualTopicDisconnectSelectorTest.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/VirtualTopicDisconnectSelectorTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/VirtualTopicDisconnectSelectorTest.java
index 7b5fc7b..925b82c 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/VirtualTopicDisconnectSelectorTest.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/VirtualTopicDisconnectSelectorTest.java
@@ -73,6 +73,7 @@ public class VirtualTopicDisconnectSelectorTest extends EmbeddedBrokerTestSuppor
       MessageConsumer consumer = createConsumer(session, destination, messageSelector);
 
       MessageListener listener = new MessageListener() {
+         @Override
          public void onMessage(Message message) {
             messageList.onMessage(message);
             try {
@@ -116,6 +117,7 @@ public class VirtualTopicDisconnectSelectorTest extends EmbeddedBrokerTestSuppor
       return new ActiveMQTopic("VirtualTopic.TEST");
    }
 
+   @Override
    protected void setUp() throws Exception {
       super.setUp();
    }
@@ -176,6 +178,7 @@ public class VirtualTopicDisconnectSelectorTest extends EmbeddedBrokerTestSuppor
       return "org/apache/activemq/broker/virtual/disconnected-selector.xml";
    }
 
+   @Override
    protected BrokerService createBroker() throws Exception {
       XBeanBrokerFactory factory = new XBeanBrokerFactory();
       BrokerService answer = factory.createBroker(new URI(getBrokerConfigUri()));

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/VirtualTopicPubSubTest.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/VirtualTopicPubSubTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/VirtualTopicPubSubTest.java
index 0fcbf0b..e203fb9 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/VirtualTopicPubSubTest.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/VirtualTopicPubSubTest.java
@@ -58,6 +58,7 @@ public class VirtualTopicPubSubTest extends EmbeddedBrokerTestSupport {
    public void doTestVirtualTopicCreation(int total) throws Exception {
 
       ConsumerBean messageList = new ConsumerBean() {
+         @Override
          public synchronized void onMessage(Message message) {
             super.onMessage(message);
             if (ackMode == Session.CLIENT_ACKNOWLEDGE) {
@@ -120,6 +121,7 @@ public class VirtualTopicPubSubTest extends EmbeddedBrokerTestSupport {
       return "Consumer.A.VirtualTopic.TEST";
    }
 
+   @Override
    protected void tearDown() throws Exception {
       for (Connection connection : connections) {
          connection.close();

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/VirtualTopicPubSubUsingXBeanTest.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/VirtualTopicPubSubUsingXBeanTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/VirtualTopicPubSubUsingXBeanTest.java
index 3c1c092..1d7ea71 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/VirtualTopicPubSubUsingXBeanTest.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/VirtualTopicPubSubUsingXBeanTest.java
@@ -27,14 +27,17 @@ import org.apache.activemq.xbean.XBeanBrokerFactory;
  */
 public class VirtualTopicPubSubUsingXBeanTest extends VirtualTopicPubSubTest {
 
+   @Override
    protected String getVirtualTopicConsumerName() {
       return "VirtualTopicConsumers.ConsumerNumberOne.FOO";
    }
 
+   @Override
    protected String getVirtualTopicName() {
       return "FOO";
    }
 
+   @Override
    protected BrokerService createBroker() throws Exception {
       XBeanBrokerFactory factory = new XBeanBrokerFactory();
       BrokerService answer = factory.createBroker(new URI(getBrokerConfigUri()));

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/VirtualTopicSelectorTest.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/VirtualTopicSelectorTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/VirtualTopicSelectorTest.java
index f8a95a2..d94dd18 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/VirtualTopicSelectorTest.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/VirtualTopicSelectorTest.java
@@ -37,14 +37,17 @@ public class VirtualTopicSelectorTest extends CompositeTopicTest {
 
    private static final Logger LOG = LoggerFactory.getLogger(VirtualTopicSelectorTest.class);
 
+   @Override
    protected Destination getConsumer1Dsetination() {
       return new ActiveMQQueue("Consumer.1.VirtualTopic.TEST");
    }
 
+   @Override
    protected Destination getConsumer2Dsetination() {
       return new ActiveMQQueue("Consumer.2.VirtualTopic.TEST");
    }
 
+   @Override
    protected Destination getProducerDestination() {
       return new ActiveMQTopic("VirtualTopic.TEST");
    }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/VirtualTopicsAndDurableSubsTest.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/VirtualTopicsAndDurableSubsTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/VirtualTopicsAndDurableSubsTest.java
index 2587cda..4abf811 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/VirtualTopicsAndDurableSubsTest.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/virtual/VirtualTopicsAndDurableSubsTest.java
@@ -86,6 +86,7 @@ public class VirtualTopicsAndDurableSubsTest extends MBeanTest {
       return "simple.topic";
    }
 
+   @Override
    protected void tearDown() throws Exception {
       if (connection != null) {
          connection.close();
@@ -94,18 +95,23 @@ public class VirtualTopicsAndDurableSubsTest extends MBeanTest {
    }
 
    //Overrides test cases from MBeanTest to avoid having them run.
+   @Override
    public void testMBeans() throws Exception {
    }
 
+   @Override
    public void testMoveMessages() throws Exception {
    }
 
+   @Override
    public void testRetryMessages() throws Exception {
    }
 
+   @Override
    public void testMoveMessagesBySelector() throws Exception {
    }
 
+   @Override
    public void testCopyMessagesBySelector() throws Exception {
    }
 }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ1687Test.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ1687Test.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ1687Test.java
index 0366b6c..78a6088 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ1687Test.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ1687Test.java
@@ -90,11 +90,13 @@ public class AMQ1687Test extends EmbeddedBrokerTestSupport {
       return "Consumer.B.VirtualTopic.TEST";
    }
 
+   @Override
    protected void setUp() throws Exception {
       this.bindAddress = "tcp://localhost:0";
       super.setUp();
    }
 
+   @Override
    protected void tearDown() throws Exception {
       if (connection != null) {
          connection.close();

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ1853Test.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ1853Test.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ1853Test.java
index 6d378d6..85d6c83 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ1853Test.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ1853Test.java
@@ -170,6 +170,7 @@ public class AMQ1853Test {
          return latch;
       }
 
+      @Override
       public void run() {
 
          ActiveMQConnectionFactory connectionFactory = null;
@@ -264,6 +265,7 @@ public class AMQ1853Test {
          return bMessageReceiptIsOrdered;
       }
 
+      @Override
       public void run() {
 
          try {
@@ -317,6 +319,7 @@ public class AMQ1853Test {
          }
       }
 
+      @Override
       public synchronized void onException(JMSException ex) {
          LOG.error("Consumer for destination, (" + destinationName + "), JMS Exception occurred.  Shutting down client.");
       }
@@ -325,6 +328,7 @@ public class AMQ1853Test {
          this.bStop = bStop;
       }
 
+      @Override
       public synchronized void onMessage(Message message) {
          receivedMessageCounter++;
          latch.countDown();

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ1866.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ1866.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ1866.java
index 9a3aab2..4b960c4 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ1866.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ1866.java
@@ -185,6 +185,7 @@ public class AMQ1866 extends TestCase {
          super(threadId);
       }
 
+      @Override
       public void run() {
          Connection connection = null;
          try {

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ1893Test.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ1893Test.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ1893Test.java
index 701b2f1..b9cb919 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ1893Test.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ1893Test.java
@@ -129,6 +129,7 @@ public class AMQ1893Test extends TestCase {
          final int totalMessageCount = MESSAGE_COUNT_OF_ONE_GROUP * PRIORITIES.length;
          final AtomicInteger counter = new AtomicInteger();
          final MessageListener listener = new MessageListener() {
+            @Override
             public void onMessage(Message message) {
 
                if (debug) {

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ1917Test.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ1917Test.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ1917Test.java
index abb331c..3ae47ad 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ1917Test.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ1917Test.java
@@ -61,6 +61,7 @@ public class AMQ1917Test extends TestCase {
    final Session[] sessions = new Session[NUM_THREADS];
    final MessageProducer[] producers = new MessageProducer[NUM_THREADS];
 
+   @Override
    public void setUp() throws Exception {
       broker = new BrokerService();
       broker.setPersistent(false);
@@ -75,6 +76,7 @@ public class AMQ1917Test extends TestCase {
       tpe.setThreadFactory(limitedthreadFactory);
    }
 
+   @Override
    public void tearDown() throws Exception {
       broker.stop();
       tpe.shutdown();
@@ -118,6 +120,7 @@ public class AMQ1917Test extends TestCase {
       connection.start();
 
       new Thread() {
+         @Override
          public void run() {
             while (working) {
                // wait for messages in infinitive loop
@@ -169,6 +172,7 @@ public class AMQ1917Test extends TestCase {
          return idx;
       }
 
+      @Override
       public void run() {
          try {
             // get thread session and producer from pool
@@ -212,6 +216,7 @@ public class AMQ1917Test extends TestCase {
          this.factory = threadFactory;
       }
 
+      @Override
       public Thread newThread(Runnable arg0) {
          if (++threadCount > NUM_THREADS) {
             errorLatch.countDown();

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2084Test.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2084Test.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2084Test.java
index 8009699..de9f2b5 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2084Test.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2084Test.java
@@ -86,6 +86,7 @@ public class AMQ2084Test {
          QueueReceiver receiver = session.createReceiver(queue, selectors);
          System.out.println("Message Selector: " + receiver.getMessageSelector());
          receiver.setMessageListener(new MessageListener() {
+            @Override
             public void onMessage(Message message) {
                try {
                   if (message instanceof TextMessage) {
@@ -124,6 +125,7 @@ public class AMQ2084Test {
          TopicSubscriber receiver = session.createSubscriber(topic, selectors, false);
 
          receiver.setMessageListener(new MessageListener() {
+            @Override
             public void onMessage(Message message) {
                try {
                   if (message instanceof TextMessage) {

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2149Test.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2149Test.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2149Test.java
index bc610de..ae8ca8c 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2149Test.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2149Test.java
@@ -191,6 +191,7 @@ public class AMQ2149Test {
       final int TRANSACITON_BATCH = 500;
       boolean resumeOnNextOrPreviousIsOk = false;
 
+      @Override
       public void onMessage(Message message) {
          try {
             final long seqNum = message.getLongProperty(SEQ_NUM_PROPERTY);
@@ -267,6 +268,7 @@ public class AMQ2149Test {
          connections.add(connection);
       }
 
+      @Override
       public void run() {
          final String longString = buildLongString();
          long nextSequenceNumber = this.nextSequenceNumber;
@@ -318,6 +320,7 @@ public class AMQ2149Test {
    // attempt to simply replicate leveldb failure. no joy yet
    public void x_testRestartReReceive() throws Exception {
       createBroker(new Configurer() {
+         @Override
          public void configure(BrokerService broker) throws Exception {
             broker.deleteAllMessages();
          }
@@ -338,6 +341,7 @@ public class AMQ2149Test {
       long expectedSeq;
 
       final TimerTask restartTask = scheduleRestartTask(null, new Configurer() {
+         @Override
          public void configure(BrokerService broker) throws Exception {
          }
       });
@@ -364,6 +368,7 @@ public class AMQ2149Test {
    public void vanilaVerify_testOrder() throws Exception {
 
       createBroker(new Configurer() {
+         @Override
          public void configure(BrokerService broker) throws Exception {
             broker.deleteAllMessages();
          }
@@ -376,6 +381,7 @@ public class AMQ2149Test {
    @Test(timeout = 5 * 60 * 1000)
    public void testOrderWithRestart() throws Exception {
       createBroker(new Configurer() {
+         @Override
          public void configure(BrokerService broker) throws Exception {
             broker.deleteAllMessages();
          }
@@ -383,6 +389,7 @@ public class AMQ2149Test {
 
       final Timer timer = new Timer();
       scheduleRestartTask(timer, new Configurer() {
+         @Override
          public void configure(BrokerService broker) throws Exception {
          }
       });
@@ -400,6 +407,7 @@ public class AMQ2149Test {
    @Test(timeout = 5 * 60 * 1000)
    public void testTopicOrderWithRestart() throws Exception {
       createBroker(new Configurer() {
+         @Override
          public void configure(BrokerService broker) throws Exception {
             broker.deleteAllMessages();
          }
@@ -434,6 +442,7 @@ public class AMQ2149Test {
       brokerStopPeriod = 10 * 1000;
 
       createBroker(new Configurer() {
+         @Override
          public void configure(BrokerService broker) throws Exception {
             broker.deleteAllMessages();
          }
@@ -472,6 +481,7 @@ public class AMQ2149Test {
    private TimerTask scheduleRestartTask(final Timer timer, final Configurer configurer) {
       class RestartTask extends TimerTask {
 
+         @Override
          public void run() {
             synchronized (brokerLock) {
                LOG.info("stopping broker..");

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2171Test.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2171Test.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2171Test.java
index 80dd013..510ccb1 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2171Test.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2171Test.java
@@ -144,6 +144,7 @@ public class AMQ2171Test implements Thread.UncaughtExceptionHandler {
       }
    }
 
+   @Override
    public void uncaughtException(Thread t, Throwable e) {
       exceptions.add(e);
    }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2314Test.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2314Test.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2314Test.java
index a0baf1d..fde821f 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2314Test.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2314Test.java
@@ -82,6 +82,7 @@ public class AMQ2314Test extends CombinationTestSupport {
       connection.start();
 
       Thread producingThread = new Thread("Producing thread") {
+         @Override
          public void run() {
             try {
                Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
@@ -101,6 +102,7 @@ public class AMQ2314Test extends CombinationTestSupport {
       };
 
       Thread consumingThread = new Thread("Consuming thread") {
+         @Override
          public void run() {
             try {
                int count = 0;
@@ -143,12 +145,14 @@ public class AMQ2314Test extends CombinationTestSupport {
       LOG.info("Subscription Usage: " + tempUsageBySubscription + ", endUsage: " + broker.getSystemUsage().getTempUsage().getUsage());
 
       assertTrue("temp usage decreased with removed sub", Wait.waitFor(new Wait.Condition() {
+         @Override
          public boolean isSatisified() throws Exception {
             return broker.getSystemUsage().getTempUsage().getUsage() < tempUsageBySubscription;
          }
       }));
    }
 
+   @Override
    public void setUp() throws Exception {
       super.setAutoFail(true);
       super.setUp();
@@ -166,6 +170,7 @@ public class AMQ2314Test extends CombinationTestSupport {
       connectionUri = broker.getTransportConnectors().get(0).getPublishableConnectString();
    }
 
+   @Override
    public void tearDown() throws Exception {
       broker.stop();
    }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2439Test.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2439Test.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2439Test.java
index 67b5c43..f4fb8a2 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2439Test.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2439Test.java
@@ -47,6 +47,7 @@ public class AMQ2439Test extends JmsMultipleBrokersTestSupport {
       assertEquals("enequeue is correct", 1000, brokerView.getTotalEnqueueCount());
 
       assertTrue("dequeue is correct", Wait.waitFor(new Wait.Condition() {
+         @Override
          public boolean isSatisified() throws Exception {
             LOG.info("dequeue count (want 1000), is : " + brokerView.getTotalDequeueCount());
             return 1000 == brokerView.getTotalDequeueCount();
@@ -77,6 +78,7 @@ public class AMQ2439Test extends JmsMultipleBrokersTestSupport {
       return i;
    }
 
+   @Override
    public void setUp() throws Exception {
       super.setUp();
       createBroker(new URI("broker:(tcp://localhost:61616)/BrokerA?persistent=true&deleteAllMessagesOnStartup=true&advisorySupport=false"));

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2489Test.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2489Test.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2489Test.java
index 423285e..cc9630f 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2489Test.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2489Test.java
@@ -60,11 +60,13 @@ public class AMQ2489Test extends TestSupport {
 
    private Connection connection;
 
+   @Override
    protected void setUp() throws Exception {
       super.setUp();
       connection = createConnection();
    }
 
+   @Override
    protected void tearDown() throws Exception {
       if (connection != null) {
          connection.close();
@@ -162,6 +164,7 @@ public class AMQ2489Test extends TestSupport {
          }
       }
 
+      @Override
       public void onMessage(Message message) {
          try {
             // retrieve sequence number assigned by producer...
@@ -208,6 +211,7 @@ public class AMQ2489Test extends TestSupport {
 
       private final java.util.Queue<Exception> exceptions = new ConcurrentLinkedQueue<Exception>();
 
+      @Override
       public void onException(JMSException e) {
          exceptions.add(e);
       }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2512Test.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2512Test.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2512Test.java
index 2d3c06d..d950459 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2512Test.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2512Test.java
@@ -112,6 +112,7 @@ public class AMQ2512Test extends EmbeddedBrokerTestSupport {
          }
       }
 
+      @Override
       public void onMessage(Message message) {
          final TextMessage msg = (TextMessage) message;
          try {

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2528Test.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2528Test.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2528Test.java
index f6f0b24..148ab32 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2528Test.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2528Test.java
@@ -35,6 +35,7 @@ public class AMQ2528Test extends EmbeddedBrokerTestSupport {
    /**
     * Setup the test so that the destination is a queue.
     */
+   @Override
    protected void setUp() throws Exception {
       useTopic = false;
       super.setUp();

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2571Test.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2571Test.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2571Test.java
index 1e4d440..0c3ef45 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2571Test.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2571Test.java
@@ -56,6 +56,7 @@ public class AMQ2571Test extends EmbeddedBrokerTestSupport {
          final TextMessage message = sessionB.createTextMessage("Testing AMQ TempQueue.");
 
          Thread sendingThread = new Thread(new Runnable() {
+            @Override
             public void run() {
                try {
                   long end = System.currentTimeMillis() + 5 * 60 * 1000;

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2580Test.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2580Test.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2580Test.java
index 2b295fc..9d79a8e 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2580Test.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2580Test.java
@@ -55,6 +55,7 @@ public class AMQ2580Test extends TestSupport {
       return suite(AMQ2580Test.class);
    }
 
+   @Override
    protected void setUp() throws Exception {
       super.setUp();
       initDurableBroker();
@@ -62,6 +63,7 @@ public class AMQ2580Test extends TestSupport {
       initTopic();
    }
 
+   @Override
    protected void tearDown() throws Exception {
       shutdownClient();
       service.stop();

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2584ConcurrentDlqTest.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2584ConcurrentDlqTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2584ConcurrentDlqTest.java
index 62d73f1..35ac1f8 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2584ConcurrentDlqTest.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2584ConcurrentDlqTest.java
@@ -99,6 +99,7 @@ public class AMQ2584ConcurrentDlqTest extends org.apache.activemq.TestSupport {
       Thread.sleep(5000);
 
       FilenameFilter justLogFiles = new FilenameFilter() {
+         @Override
          public boolean accept(File file, String s) {
             return s.endsWith(".log");
          }
@@ -118,6 +119,7 @@ public class AMQ2584ConcurrentDlqTest extends org.apache.activemq.TestSupport {
       consumerSession = consumerConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
 
       MessageListener listener = new MessageListener() {
+         @Override
          public void onMessage(Message message) {
             latch.countDown();
             try {
@@ -142,6 +144,7 @@ public class AMQ2584ConcurrentDlqTest extends org.apache.activemq.TestSupport {
       Session dlqSession = dlqConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
       MessageConsumer dlqConsumer = dlqSession.createConsumer(new ActiveMQQueue("ActiveMQ.DLQ"));
       dlqConsumer.setMessageListener(new MessageListener() {
+         @Override
          public void onMessage(Message message) {
             if (received.getCount() > 0 && received.getCount() % 200 == 0) {
                LOG.info("remaining on DLQ: " + received.getCount());
@@ -238,6 +241,7 @@ public class AMQ2584ConcurrentDlqTest extends org.apache.activemq.TestSupport {
       broker = null;
    }
 
+   @Override
    protected ActiveMQConnectionFactory createConnectionFactory() throws Exception {
       return new ActiveMQConnectionFactory("vm://testStoreSize?jms.watchTopicAdvisories=false&jms.redeliveryPolicy.maximumRedeliveries=1&jms.redeliveryPolicy.initialRedeliveryDelay=0&waitForStart=5000&create=false");
    }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2645Test.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2645Test.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2645Test.java
index 6f7c5da..61a5d1e 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2645Test.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2645Test.java
@@ -58,6 +58,7 @@ public class AMQ2645Test extends EmbeddedBrokerTestSupport {
 
          final MessageConsumer consumer = session.createConsumer(session.createQueue(QUEUE_NAME));
          consumer.setMessageListener(new MessageListener() {
+            @Override
             public void onMessage(Message message) {
                try {
                   afterRestart.await();

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2751Test.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2751Test.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2751Test.java
index 80b6cfa..539354c 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2751Test.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2751Test.java
@@ -57,6 +57,7 @@ public class AMQ2751Test extends EmbeddedBrokerTestSupport {
          MessageConsumer consumer = session.createConsumer(queue);
 
          consumer.setMessageListener(new MessageListener() {
+            @Override
             public void onMessage(Message message) {
                try {
                   LOG.info("Got message: " + message.getJMSMessageID());

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3014Test.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3014Test.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3014Test.java
index b3908d6..a67ef33 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3014Test.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3014Test.java
@@ -153,6 +153,7 @@ public class AMQ3014Test {
       // local VMTransport dispatcher is artificially delayed.
       final TaskRunnerFactory realTaskRunnerFactory = localBroker.getTaskRunnerFactory();
       localBroker.setTaskRunnerFactory(new TaskRunnerFactory() {
+         @Override
          public TaskRunner createTaskRunner(Task task, String name) {
             final TaskRunner realTaskRunner = realTaskRunnerFactory.createTaskRunner(task, name);
             if (name.startsWith("ActiveMQ Connection Dispatcher: ")) {

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3274Test.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3274Test.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3274Test.java
index cdfe17b..08c2f78 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3274Test.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3274Test.java
@@ -294,6 +294,7 @@ public class AMQ3274Test {
       // the remote must already be running.
 
       start1 = new Thread() {
+         @Override
          public void run() {
             try {
                broker1.start();
@@ -305,6 +306,7 @@ public class AMQ3274Test {
       };
 
       start2 = new Thread() {
+         @Override
          public void run() {
             try {
                broker2.start();
@@ -545,6 +547,7 @@ public class AMQ3274Test {
          shutdownLatch = new CountDownLatch(1);
       }
 
+      @Override
       public void run() {
          CountDownLatch latch;
 
@@ -681,6 +684,7 @@ public class AMQ3274Test {
          this(dest, ActiveMQConnection.makeConnection(broker_url));
       }
 
+      @Override
       public void run() {
          Message req;
 

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3436Test.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3436Test.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3436Test.java
index 05827d2..8fd2765 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3436Test.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3436Test.java
@@ -144,6 +144,7 @@ public class AMQ3436Test {
 
          boolean firstMessage = true;
 
+         @Override
          public void onMessage(Message msg) {
             try {
 

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3465Test.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3465Test.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3465Test.java
index 1d3d9ed..5e6b2ff 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3465Test.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3465Test.java
@@ -179,14 +179,17 @@ public class AMQ3465Test {
       final byte[] bs = baos.toByteArray();
 
       return new Xid() {
+         @Override
          public int getFormatId() {
             return 86;
          }
 
+         @Override
          public byte[] getGlobalTransactionId() {
             return bs;
          }
 
+         @Override
          public byte[] getBranchQualifier() {
             return bs;
          }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3678Test.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3678Test.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3678Test.java
index 92ae7d6..26bef7d 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3678Test.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3678Test.java
@@ -106,6 +106,7 @@ public class AMQ3678Test implements MessageListener {
 
          private boolean done = false;
 
+         @Override
          public void run() {
             while (!done) {
                if (messagesSent.get() == 50) {

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3932Test.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3932Test.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3932Test.java
index d42733d..f29ad94 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3932Test.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3932Test.java
@@ -83,6 +83,7 @@ public class AMQ3932Test {
       ExecutorService executor = Executors.newSingleThreadExecutor();
 
       executor.execute(new Runnable() {
+         @Override
          public void run() {
             try {
                started.countDown();
@@ -113,6 +114,7 @@ public class AMQ3932Test {
       ExecutorService executor = Executors.newSingleThreadExecutor();
 
       executor.execute(new Runnable() {
+         @Override
          public void run() {
             try {
                started.countDown();
@@ -143,6 +145,7 @@ public class AMQ3932Test {
       ExecutorService executor = Executors.newSingleThreadExecutor();
 
       executor.execute(new Runnable() {
+         @Override
          public void run() {
             try {
                started.countDown();

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4083Test.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4083Test.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4083Test.java
index c554af2..c655a22 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4083Test.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4083Test.java
@@ -113,6 +113,7 @@ public class AMQ4083Test {
       assertEquals(101, queueView.getInFlightCount());
 
       consumer.setMessageListener(new MessageListener() {
+         @Override
          public void onMessage(Message message) {
             try {
                message.acknowledge();
@@ -132,6 +133,7 @@ public class AMQ4083Test {
 
       assertTrue("Inflight count should reach zero, currently: " + queueView.getInFlightCount(), Wait.waitFor(new Wait.Condition() {
 
+         @Override
          public boolean isSatisified() throws Exception {
             return queueView.getInFlightCount() == 0;
          }
@@ -175,6 +177,7 @@ public class AMQ4083Test {
       assertEquals(101, queueView.getInFlightCount());
 
       consumer.setMessageListener(new MessageListener() {
+         @Override
          public void onMessage(Message message) {
             try {
                session.commit();

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4092Test.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4092Test.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4092Test.java
index 3a072c2..633d246 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4092Test.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4092Test.java
@@ -155,6 +155,7 @@ public class AMQ4092Test extends TestCase {
          final int totalMessageCount = NUM_TO_SEND_PER_PRODUCER * DESTINATIONS.length * NUM_PRODUCERS;
          final AtomicInteger counter = new AtomicInteger();
          final MessageListener listener = new MessageListener() {
+            @Override
             public void onMessage(Message message) {
 
                if (debug) {

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4160Test.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4160Test.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4160Test.java
index b32c76a..0cd8e0b 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4160Test.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4160Test.java
@@ -57,6 +57,7 @@ public class AMQ4160Test extends JmsMultipleBrokersTestSupport {
     * Since these tests involve wait conditions, protect against indefinite
     * waits (due to unanticipated issues).
     */
+   @Override
    public void setUp() throws Exception {
       setAutoFail(true);
       setMaxTestTime(MAX_TEST_TIME);
@@ -327,6 +328,7 @@ public class AMQ4160Test extends JmsMultipleBrokersTestSupport {
                   return next.getMbeanObjectName();
                }
 
+               @Override
                public void resetStats() {
                   next.resetStats();
                }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4221Test.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4221Test.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4221Test.java
index 8bb4f9a..5a6c630 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4221Test.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4221Test.java
@@ -93,6 +93,7 @@ public class AMQ4221Test extends TestSupport {
                System.err.println("exit on error: " + event.getMessage());
                done.set(true);
                new Thread() {
+                  @Override
                   public void run() {
                      System.exit(787);
                   }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4485LowLimitLevelDBTest.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4485LowLimitLevelDBTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4485LowLimitLevelDBTest.java
index 1a320c2..efaf484 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4485LowLimitLevelDBTest.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4485LowLimitLevelDBTest.java
@@ -28,6 +28,7 @@ public class AMQ4485LowLimitLevelDBTest extends AMQ4485LowLimitTest {
       numBrokers = 2;
    }
 
+   @Override
    protected BrokerService createBroker(int brokerid, boolean addToNetwork) throws Exception {
       BrokerService broker = super.createBroker(brokerid, addToNetwork);
 

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4485LowLimitTest.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4485LowLimitTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4485LowLimitTest.java
index 20c3b07..ba64b8b 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4485LowLimitTest.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4485LowLimitTest.java
@@ -458,6 +458,7 @@ public class AMQ4485LowLimitTest extends JmsMultipleBrokersTestSupport {
       }
    }
 
+   @Override
    protected void tearDown() throws Exception {
       super.tearDown();
    }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4485NetworkOfXBrokersWithNDestsFanoutTransactionTest.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4485NetworkOfXBrokersWithNDestsFanoutTransactionTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4485NetworkOfXBrokersWithNDestsFanoutTransactionTest.java
index 40459bc..add1526 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4485NetworkOfXBrokersWithNDestsFanoutTransactionTest.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4485NetworkOfXBrokersWithNDestsFanoutTransactionTest.java
@@ -342,6 +342,7 @@ public class AMQ4485NetworkOfXBrokersWithNDestsFanoutTransactionTest extends Jms
       }
    }
 
+   @Override
    protected void tearDown() throws Exception {
       super.tearDown();
    }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4485Test.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4485Test.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4485Test.java
index 98f5020..c9176da 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4485Test.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4485Test.java
@@ -80,6 +80,7 @@ public class AMQ4485Test extends TestCase {
                if (true) {
                   TransactionBroker transactionBroker = (TransactionBroker) broker.getBroker().getAdaptor(TransactionBroker.class);
                   transactionBroker.getTransaction(producerExchange.getConnectionContext(), messageSend.getTransactionId(), false).addSynchronization(new Synchronization() {
+                                                                                                                                                         @Override
                                                                                                                                                          public void afterCommit() throws Exception {
                                                                                                                                                             LOG.error("AfterCommit, NUM:" + num + ", " + messageSend.getMessageId() + ", tx: " + messageSend.getTransactionId());
                                                                                                                                                             if (num == 5) {
@@ -174,6 +175,7 @@ public class AMQ4485Test extends TestCase {
       return session;
    }
 
+   @Override
    protected void setUp() throws Exception {
       super.setUp();
       broker = new BrokerService();
@@ -185,6 +187,7 @@ public class AMQ4485Test extends TestCase {
 
    }
 
+   @Override
    protected void tearDown() throws Exception {
       super.tearDown();
       if (broker != null) {

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4607Test.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4607Test.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4607Test.java
index 53a048e..841f463 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4607Test.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4607Test.java
@@ -230,6 +230,7 @@ public class AMQ4607Test extends JmsMultipleBrokersTestSupport implements Uncaug
       }, timeout));
    }
 
+   @Override
    public void setUp() throws Exception {
       super.setUp();
 
@@ -253,6 +254,7 @@ public class AMQ4607Test extends JmsMultipleBrokersTestSupport implements Uncaug
       brokerService.setDestinationPolicy(policyMap);
    }
 
+   @Override
    public void uncaughtException(Thread t, Throwable e) {
       synchronized (unhandeledExceptions) {
          unhandeledExceptions.put(t, e);

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4636Test.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4636Test.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4636Test.java
index 11241c6..9cb9c66 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4636Test.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4636Test.java
@@ -237,6 +237,7 @@ public class AMQ4636Test {
 
    public class TestJDBCPersistenceAdapter extends JDBCPersistenceAdapter {
 
+      @Override
       public TransactionContext getTransactionContext() throws IOException {
          return new TestTransactionContext(this);
       }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4930Test.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4930Test.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4930Test.java
index ad8cb28..4805873 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4930Test.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4930Test.java
@@ -123,6 +123,7 @@ public class AMQ4930Test extends TestCase {
       }
    }
 
+   @Override
    protected void setUp() throws Exception {
       super.setUp();
       broker = new BrokerService();
@@ -134,6 +135,7 @@ public class AMQ4930Test extends TestCase {
 
    }
 
+   @Override
    protected void tearDown() throws Exception {
       super.tearDown();
       if (broker != null) {

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4950Test.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4950Test.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4950Test.java
index 91d9b8d..1f4edc0 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4950Test.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4950Test.java
@@ -142,14 +142,17 @@ public class AMQ4950Test extends BrokerRestartTestSupport {
       final byte[] bs = baos.toByteArray();
 
       return new Xid() {
+         @Override
          public int getFormatId() {
             return 86;
          }
 
+         @Override
          public byte[] getGlobalTransactionId() {
             return bs;
          }
 
+         @Override
          public byte[] getBranchQualifier() {
             return bs;
          }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ5266SingleDestTest.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ5266SingleDestTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ5266SingleDestTest.java
index 3adc8f1..405e56b 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ5266SingleDestTest.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ5266SingleDestTest.java
@@ -318,6 +318,7 @@ public class AMQ5266SingleDestTest {
             mp = session.createProducer(q);
          }
 
+         @Override
          public void run() {
 
             try {
@@ -527,6 +528,7 @@ public class AMQ5266SingleDestTest {
             idList = idsByQueue.get(queueName);
          }
 
+         @Override
          public void run() {
 
             try {

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ5266StarvedConsumerTest.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ5266StarvedConsumerTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ5266StarvedConsumerTest.java
index 0c1d6a4..86dcf5a 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ5266StarvedConsumerTest.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ5266StarvedConsumerTest.java
@@ -323,6 +323,7 @@ public class AMQ5266StarvedConsumerTest {
             mp = session.createProducer(null);
          }
 
+         @Override
          public void run() {
 
             try {
@@ -538,6 +539,7 @@ public class AMQ5266StarvedConsumerTest {
             idList = idsByQueue.get(queueName);
          }
 
+         @Override
          public void run() {
 
             try {

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ5266Test.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ5266Test.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ5266Test.java
index 980a04e..582600c 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ5266Test.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ5266Test.java
@@ -302,6 +302,7 @@ public class AMQ5266Test {
             mp = session.createProducer(q);
          }
 
+         @Override
          public void run() {
 
             try {
@@ -512,6 +513,7 @@ public class AMQ5266Test {
             idList = idsByQueue.get(queueName);
          }
 
+         @Override
          public void run() {
 
             try {

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ5567Test.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ5567Test.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ5567Test.java
index df1f80a..10b6168 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ5567Test.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ5567Test.java
@@ -59,6 +59,7 @@ public class AMQ5567Test extends BrokerRestartTestSupport {
       broker.setPersistenceAdapter(persistenceAdapter);
    }
 
+   @Override
    protected PolicyEntry getDefaultPolicy() {
       PolicyEntry policy = new PolicyEntry();
       policy.setMemoryLimit(60 * 1024);

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/ConnectionPerMessageTest.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/ConnectionPerMessageTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/ConnectionPerMessageTest.java
index ca05325..2d6a48c 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/ConnectionPerMessageTest.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/ConnectionPerMessageTest.java
@@ -79,11 +79,13 @@ public class ConnectionPerMessageTest extends EmbeddedBrokerTestSupport {
       }
    }
 
+   @Override
    protected void setUp() throws Exception {
       bindAddress = "vm://localhost";
       super.setUp();
    }
 
+   @Override
    protected BrokerService createBroker() throws Exception {
       BrokerService answer = new BrokerService();
       answer.setDeleteAllMessagesOnStartup(true);
@@ -93,10 +95,12 @@ public class ConnectionPerMessageTest extends EmbeddedBrokerTestSupport {
       return answer;
    }
 
+   @Override
    protected boolean isPersistent() {
       return true;
    }
 
+   @Override
    protected void tearDown() throws Exception {
       super.tearDown();
    }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/CraigsBugTest.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/CraigsBugTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/CraigsBugTest.java
index f2d245e..35da06c 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/CraigsBugTest.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/CraigsBugTest.java
@@ -38,6 +38,7 @@ public class CraigsBugTest extends EmbeddedBrokerTestSupport {
       final Connection conn = cf.createConnection();
 
       Runnable r = new Runnable() {
+         @Override
          public void run() {
             try {
                Session session = conn.createSession(false, 1);
@@ -60,6 +61,7 @@ public class CraigsBugTest extends EmbeddedBrokerTestSupport {
       }
    }
 
+   @Override
    protected void setUp() throws Exception {
       bindAddress = "tcp://localhost:0";
       super.setUp();

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/DoubleExpireTest.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/DoubleExpireTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/DoubleExpireTest.java
index f493eb9..a79ca58 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/DoubleExpireTest.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/DoubleExpireTest.java
@@ -35,6 +35,7 @@ public class DoubleExpireTest extends EmbeddedBrokerTestSupport {
    private static final long MESSAGE_TTL_MILLIS = 1000;
    private static final long MAX_TEST_TIME_MILLIS = 60000;
 
+   @Override
    public void setUp() throws Exception {
       setAutoFail(true);
       setMaxTestTime(MAX_TEST_TIME_MILLIS);

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java
index 06c3568..695b1a4 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java
@@ -109,6 +109,7 @@ public class DurableConsumerTest extends CombinationTestSupport {
          }
       }
 
+      @Override
       public void onMessage(Message arg0) {
       }
 
@@ -122,6 +123,7 @@ public class DurableConsumerTest extends CombinationTestSupport {
          }
       }
 
+      @Override
       public void onException(JMSException exception) {
          exceptions.add(exception);
       }
@@ -131,6 +133,7 @@ public class DurableConsumerTest extends CombinationTestSupport {
 
       private final boolean shouldPublish = true;
 
+      @Override
       public void run() {
          TopicConnectionFactory topicConnectionFactory = null;
          TopicConnection topicConnection = null;
@@ -186,6 +189,7 @@ public class DurableConsumerTest extends CombinationTestSupport {
 
          final int id = i;
          Thread thread = new Thread(new Runnable() {
+            @Override
             public void run() {
                SimpleTopicSubscriber s = new SimpleTopicSubscriber(CONNECTION_URL, System.currentTimeMillis() + "-" + id, TOPIC_NAME);
                list.add(s);
@@ -231,6 +235,7 @@ public class DurableConsumerTest extends CombinationTestSupport {
       final CountDownLatch counsumerStarted = new CountDownLatch(numConsumers);
       final AtomicInteger receivedCount = new AtomicInteger();
       Runnable consumer = new Runnable() {
+         @Override
          public void run() {
             final String consumerName = Thread.currentThread().getName();
             int acked = 0;
@@ -302,6 +307,7 @@ public class DurableConsumerTest extends CombinationTestSupport {
       executor.awaitTermination(30, TimeUnit.SECONDS);
 
       Wait.waitFor(new Wait.Condition() {
+         @Override
          public boolean isSatisified() throws Exception {
             LOG.info("receivedCount: " + receivedCount.get());
             return receivedCount.get() == numMessages;

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/JMSDurableTopicNoLocalTest.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/JMSDurableTopicNoLocalTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/JMSDurableTopicNoLocalTest.java
index 750bbc8..ef24795 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/JMSDurableTopicNoLocalTest.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/JMSDurableTopicNoLocalTest.java
@@ -48,6 +48,7 @@ public class JMSDurableTopicNoLocalTest extends EmbeddedBrokerTestSupport {
 
       final CountDownLatch latch = new CountDownLatch(1);
       subscriber.setMessageListener(new MessageListener() {
+         @Override
          public void onMessage(Message message) {
             System.out.println("Receive a message " + message);
             latch.countDown();

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/JmsDurableTopicSlowReceiveTest.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/JmsDurableTopicSlowReceiveTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/JmsDurableTopicSlowReceiveTest.java
index 65d3c9b..137caa3 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/JmsDurableTopicSlowReceiveTest.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/JmsDurableTopicSlowReceiveTest.java
@@ -60,17 +60,20 @@ public class JmsDurableTopicSlowReceiveTest extends JmsTopicSendReceiveTest {
     *
     * @see junit.framework.TestCase#setUp()
     */
+   @Override
    protected void setUp() throws Exception {
       this.durable = true;
       broker = createBroker();
       super.setUp();
    }
 
+   @Override
    protected void tearDown() throws Exception {
       super.tearDown();
       broker.stop();
    }
 
+   @Override
    protected ActiveMQConnectionFactory createConnectionFactory() throws Exception {
       ActiveMQConnectionFactory result = new ActiveMQConnectionFactory("vm://localhost?async=false");
       Properties props = new Properties();
@@ -109,6 +112,7 @@ public class JmsDurableTopicSlowReceiveTest extends JmsTopicSendReceiveTest {
       connection2.close();
       new Thread(new Runnable() {
 
+         @Override
          public void run() {
             try {
                int count = 0;

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/JmsTimeoutTest.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/JmsTimeoutTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/JmsTimeoutTest.java
index abc90d5..81987be 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/JmsTimeoutTest.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/JmsTimeoutTest.java
@@ -56,6 +56,7 @@ public class JmsTimeoutTest extends EmbeddedBrokerTestSupport {
       cx.setSendTimeout(10000);
 
       Runnable r = new Runnable() {
+         @Override
          public void run() {
             try {
                LOG.info("Sender thread starting");
@@ -102,6 +103,7 @@ public class JmsTimeoutTest extends EmbeddedBrokerTestSupport {
 
       broker.getSystemUsage().setSendFailIfNoSpaceAfterTimeout(5000);
       Runnable r = new Runnable() {
+         @Override
          public void run() {
             try {
                LOG.info("Sender thread starting");
@@ -135,6 +137,7 @@ public class JmsTimeoutTest extends EmbeddedBrokerTestSupport {
       assertTrue("No exception from the broker", exceptionCount.get() > 0);
    }
 
+   @Override
    protected void setUp() throws Exception {
       exceptionCount.set(0);
       bindAddress = "tcp://localhost:0";

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/MemoryUsageBrokerTest.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/MemoryUsageBrokerTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/MemoryUsageBrokerTest.java
index 26df394..4653ea6 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/MemoryUsageBrokerTest.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/MemoryUsageBrokerTest.java
@@ -32,6 +32,7 @@ public class MemoryUsageBrokerTest extends BrokerTestSupport {
 
    private static final Logger LOG = LoggerFactory.getLogger(MemoryUsageBrokerTest.class);
 
+   @Override
    protected void setUp() throws Exception {
       this.setAutoFail(true);
       super.setUp();
@@ -47,6 +48,7 @@ public class MemoryUsageBrokerTest extends BrokerTestSupport {
       return policy;
    }
 
+   @Override
    protected BrokerService createBroker() throws Exception {
       BrokerService broker = new BrokerService();
       KahaDBStore kaha = new KahaDBStore();

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/OptimizeAcknowledgeWithExpiredMsgsTest.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/OptimizeAcknowledgeWithExpiredMsgsTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/OptimizeAcknowledgeWithExpiredMsgsTest.java
index 88426db..6b624e2 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/OptimizeAcknowledgeWithExpiredMsgsTest.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/OptimizeAcknowledgeWithExpiredMsgsTest.java
@@ -287,6 +287,7 @@ public class OptimizeAcknowledgeWithExpiredMsgsTest {
 
       private AtomicInteger counter = new AtomicInteger(0);
 
+      @Override
       public void onMessage(final Message message) {
          try {
             LOG.trace("Got Message " + message.getJMSMessageID());
@@ -300,6 +301,7 @@ public class OptimizeAcknowledgeWithExpiredMsgsTest {
          return counter.get();
       }
 
+      @Override
       public synchronized void onException(JMSException ex) {
          LOG.error("JMS Exception occurred.  Shutting down client.");
       }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/OutOfOrderTestCase.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/OutOfOrderTestCase.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/OutOfOrderTestCase.java
index 88d552a..2b84862 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/OutOfOrderTestCase.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/OutOfOrderTestCase.java
@@ -51,6 +51,7 @@ public class OutOfOrderTestCase extends TestCase {
 
    private int seq = 0;
 
+   @Override
    public void setUp() throws Exception {
       brokerService = new BrokerService();
       brokerService.setUseJmx(true);
@@ -67,6 +68,7 @@ public class OutOfOrderTestCase extends TestCase {
       session = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE);
    }
 
+   @Override
    protected void tearDown() throws Exception {
       session.close();
       connection.close();

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/QueueWorkerPrefetchTest.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/QueueWorkerPrefetchTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/QueueWorkerPrefetchTest.java
index 74b52d5..1885325 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/QueueWorkerPrefetchTest.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/QueueWorkerPrefetchTest.java
@@ -146,6 +146,7 @@ public class QueueWorkerPrefetchTest extends TestCase implements MessageListener
          workItemConsumer.setMessageListener(this);
       }
 
+      @Override
       public void onMessage(javax.jms.Message message) {
          try {
             WorkMessage work = (WorkMessage) ((ObjectMessage) message).getObject();
@@ -179,6 +180,7 @@ public class QueueWorkerPrefetchTest extends TestCase implements MessageListener
    /**
     * Master message handler. Process ack messages.
     */
+   @Override
    public void onMessage(javax.jms.Message message) {
       long acks = acksReceived.incrementAndGet();
       latch.get().countDown();
@@ -187,6 +189,7 @@ public class QueueWorkerPrefetchTest extends TestCase implements MessageListener
       }
    }
 
+   @Override
    protected void setUp() throws Exception {
       // Create the message broker.
       super.setUp();
@@ -200,6 +203,7 @@ public class QueueWorkerPrefetchTest extends TestCase implements MessageListener
       connectionUri = broker.getTransportConnectors().get(0).getPublishableConnectString();
    }
 
+   @Override
    protected void tearDown() throws Exception {
       // Shut down the message broker.
       broker.deleteAllMessages();

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/SlowConsumerTest.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/SlowConsumerTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/SlowConsumerTest.java
index c3c2bac..b4858c1 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/SlowConsumerTest.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/SlowConsumerTest.java
@@ -66,6 +66,7 @@ public class SlowConsumerTest extends TestCase {
       connection.start();
 
       Thread producingThread = new Thread("Producing thread") {
+         @Override
          public void run() {
             try {
                Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
@@ -89,6 +90,7 @@ public class SlowConsumerTest extends TestCase {
 
       Thread consumingThread = new Thread("Consuming thread") {
 
+         @Override
          public void run() {
             try {
                Session session = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE);

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/TransactionNotStartedErrorTest.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/TransactionNotStartedErrorTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/TransactionNotStartedErrorTest.java
index b21462f..2038279 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/TransactionNotStartedErrorTest.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/TransactionNotStartedErrorTest.java
@@ -91,6 +91,7 @@ public class TransactionNotStartedErrorTest extends TestCase {
       LOG.info("Starting broker..");
    }
 
+   @Override
    public void tearDown() throws Exception {
       hectorConnection.close();
       xenaConnection.close();
@@ -104,6 +105,7 @@ public class TransactionNotStartedErrorTest extends TestCase {
       hectorConnection = createConnection();
       Thread hectorThread = buildProducer(hectorConnection, hectorToHalo);
       Receiver hHectorReceiver = new Receiver() {
+         @Override
          public void receive(String s) throws Exception {
             haloToHectorCtr++;
             if (haloToHectorCtr >= counter) {
@@ -118,6 +120,7 @@ public class TransactionNotStartedErrorTest extends TestCase {
       troyConnection = createConnection();
       Thread troyThread = buildProducer(troyConnection, troyToHalo);
       Receiver hTroyReceiver = new Receiver() {
+         @Override
          public void receive(String s) throws Exception {
             haloToTroyCtr++;
             if (haloToTroyCtr >= counter) {
@@ -132,6 +135,7 @@ public class TransactionNotStartedErrorTest extends TestCase {
       xenaConnection = createConnection();
       Thread xenaThread = buildProducer(xenaConnection, xenaToHalo);
       Receiver hXenaReceiver = new Receiver() {
+         @Override
          public void receive(String s) throws Exception {
             haloToXenaCtr++;
             if (haloToXenaCtr >= counter) {
@@ -148,6 +152,7 @@ public class TransactionNotStartedErrorTest extends TestCase {
       final MessageSender troySender = buildTransactionalProducer(haloToTroy, haloConnection);
       final MessageSender xenaSender = buildTransactionalProducer(haloToXena, haloConnection);
       Receiver hectorReceiver = new Receiver() {
+         @Override
          public void receive(String s) throws Exception {
             hectorToHaloCtr++;
             troySender.send("halo to troy because of hector");
@@ -159,6 +164,7 @@ public class TransactionNotStartedErrorTest extends TestCase {
          }
       };
       Receiver xenaReceiver = new Receiver() {
+         @Override
          public void receive(String s) throws Exception {
             xenaToHaloCtr++;
             hectorSender.send("halo to hector because of xena");
@@ -170,6 +176,7 @@ public class TransactionNotStartedErrorTest extends TestCase {
          }
       };
       Receiver troyReceiver = new Receiver() {
+         @Override
          public void receive(String s) throws Exception {
             troyToHaloCtr++;
             xenaSender.send("halo to xena because of troy");
@@ -242,6 +249,7 @@ public class TransactionNotStartedErrorTest extends TestCase {
       final MessageSender producer = new MessageSender(queueName, connection, false, false);
       Thread thread = new Thread() {
 
+         @Override
          public synchronized void run() {
             for (int i = 0; i < counter; i++) {
                try {
@@ -268,6 +276,7 @@ public class TransactionNotStartedErrorTest extends TestCase {
       MessageConsumer inputMessageConsumer = session.createConsumer(session.createQueue(queueName));
       MessageListener messageListener = new MessageListener() {
 
+         @Override
          public void onMessage(Message message) {
             try {
                ObjectMessage objectMessage = (ObjectMessage) message;

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/TrapMessageInJDBCStoreTest.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/TrapMessageInJDBCStoreTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/TrapMessageInJDBCStoreTest.java
index dfda299..36a80b4 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/TrapMessageInJDBCStoreTest.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/TrapMessageInJDBCStoreTest.java
@@ -249,6 +249,7 @@ public class TrapMessageInJDBCStoreTest extends TestCase {
 
    public class TestJDBCPersistenceAdapter extends JDBCPersistenceAdapter {
 
+      @Override
       public TransactionContext getTransactionContext() throws IOException {
          return testTransactionContext;
       }
@@ -262,6 +263,7 @@ public class TrapMessageInJDBCStoreTest extends TestCase {
          super(jdbcPersistenceAdapter);
       }
 
+      @Override
       public void executeBatch() throws SQLException {
          super.executeBatch();
          count++;

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/VMTransportClosureTest.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/VMTransportClosureTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/VMTransportClosureTest.java
index 577464b..84c1765 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/VMTransportClosureTest.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/VMTransportClosureTest.java
@@ -38,6 +38,7 @@ public class VMTransportClosureTest extends EmbeddedBrokerTestSupport {
    private static final long MAX_TEST_TIME_MILLIS = 300000; // 5min
    private static final int NUM_ATTEMPTS = 100000;
 
+   @Override
    public void setUp() throws Exception {
       setAutoFail(true);
       setMaxTestTime(MAX_TEST_TIME_MILLIS);
@@ -93,6 +94,7 @@ public class VMTransportClosureTest extends EmbeddedBrokerTestSupport {
          // transport should not affect the persistent connection.
          final Transport localTransport = TransportFactory.connect(broker.getVmConnectorURI());
          localTransport.setTransportListener(new TransportListener() {
+            @Override
             public void onCommand(Object command) {
                if (command instanceof ShutdownInfo) {
                   try {
@@ -104,14 +106,17 @@ public class VMTransportClosureTest extends EmbeddedBrokerTestSupport {
                }
             }
 
+            @Override
             public void onException(IOException error) {
                // ignore
             }
 
+            @Override
             public void transportInterupted() {
                // ignore
             }
 
+            @Override
             public void transportResumed() {
                // ignore
             }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/amq1974/TryJmsClient.java
----------------------------------------------------------------------
diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/amq1974/TryJmsClient.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/amq1974/TryJmsClient.java
index cdda13a..b74887f 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/amq1974/TryJmsClient.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/amq1974/TryJmsClient.java
@@ -65,6 +65,7 @@ public class TryJmsClient {
 
    private void startUsageMonitor(final BrokerService brokerService) {
       new Thread(new Runnable() {
+         @Override
          public void run() {
             while (true) {
                try {
@@ -106,6 +107,7 @@ public class TryJmsClient {
 
    private class MessageSend implements Runnable {
 
+      @Override
       public void run() {
          try {
             String url = "vm://TestBroker";


Mime
View raw message