activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [04/42] activemq-artemis git commit: Add missing @Override annotations
Date Mon, 07 Dec 2015 18:39:16 GMT
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/QueueControlUsingCoreTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/QueueControlUsingCoreTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/QueueControlUsingCoreTest.java
index 2b75f12..6dce64b 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/QueueControlUsingCoreTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/QueueControlUsingCoreTest.java
@@ -48,98 +48,122 @@ public class QueueControlUsingCoreTest extends QueueControlTest {
             }
          }
 
+         @Override
          public boolean changeMessagePriority(final long messageID, final int newPriority) throws Exception {
             return (Boolean) proxy.invokeOperation("changeMessagePriority", messageID, newPriority);
          }
 
+         @Override
          public int changeMessagesPriority(final String filter, final int newPriority) throws Exception {
             return (Integer) proxy.invokeOperation("changeMessagesPriority", filter, newPriority);
          }
 
+         @Override
          public long countMessages(final String filter) throws Exception {
             return ((Number) proxy.invokeOperation("countMessages", filter)).longValue();
          }
 
+         @Override
          public boolean expireMessage(final long messageID) throws Exception {
             return (Boolean) proxy.invokeOperation("expireMessage", messageID);
          }
 
+         @Override
          public int expireMessages(final String filter) throws Exception {
             return (Integer) proxy.invokeOperation("expireMessages", filter);
          }
 
+         @Override
          public String getAddress() {
             return (String) proxy.retrieveAttributeValue("address");
          }
 
+         @Override
          public int getConsumerCount() {
             return (Integer) proxy.retrieveAttributeValue("consumerCount");
          }
 
+         @Override
          public String getDeadLetterAddress() {
             return (String) proxy.retrieveAttributeValue("deadLetterAddress");
          }
 
+         @Override
          public int getDeliveringCount() {
             return (Integer) proxy.retrieveAttributeValue("deliveringCount");
          }
 
+         @Override
          public String getExpiryAddress() {
             return (String) proxy.retrieveAttributeValue("expiryAddress");
          }
 
+         @Override
          public String getFilter() {
             return (String) proxy.retrieveAttributeValue("filter");
          }
 
+         @Override
          public long getMessageCount() {
             return ((Number) proxy.retrieveAttributeValue("messageCount")).longValue();
          }
 
+         @Override
          public long getMessagesAdded() {
             return (Integer) proxy.retrieveAttributeValue("messagesAdded");
          }
 
+         @Override
          public long getMessagesAcknowledged() {
             return (Integer) proxy.retrieveAttributeValue("messagesAcknowledged");
          }
 
+         @Override
          public void resetMessagesAdded() throws Exception {
             proxy.invokeOperation("resetMessagesAdded");
          }
 
+         @Override
          public void resetMessagesAcknowledged() throws Exception {
             proxy.invokeOperation("resetMessagesAcknowledged");
          }
 
+         @Override
          public String getName() {
             return (String) proxy.retrieveAttributeValue("name");
          }
 
+         @Override
          public long getID() {
             return (Long) proxy.retrieveAttributeValue("ID");
          }
 
+         @Override
          public long getScheduledCount() {
             return (Long) proxy.retrieveAttributeValue("scheduledCount", Long.class);
          }
 
+         @Override
          public boolean isDurable() {
             return (Boolean) proxy.retrieveAttributeValue("durable");
          }
 
+         @Override
          public boolean isTemporary() {
             return (Boolean) proxy.retrieveAttributeValue("temporary");
          }
 
+         @Override
          public String listMessageCounter() throws Exception {
             return (String) proxy.invokeOperation("listMessageCounter");
          }
 
+         @Override
          public String listMessageCounterAsHTML() throws Exception {
             return (String) proxy.invokeOperation("listMessageCounterAsHTML");
          }
 
+         @Override
          public String listMessageCounterHistory() throws Exception {
             return (String) proxy.invokeOperation("listMessageCounterHistory");
          }
@@ -147,6 +171,7 @@ public class QueueControlUsingCoreTest extends QueueControlTest {
          /**
           * Returns the first message on the queue as JSON
           */
+         @Override
          public String getFirstMessageAsJSON() throws Exception {
             return (String) proxy.invokeOperation("getFirstMessageAsJSON");
          }
@@ -154,6 +179,7 @@ public class QueueControlUsingCoreTest extends QueueControlTest {
          /**
           * Returns the timestamp of the first message in milliseconds.
           */
+         @Override
          public Long getFirstMessageTimestamp() throws Exception {
             return (Long) proxy.invokeOperation("getFirstMessageTimestamp");
          }
@@ -161,6 +187,7 @@ public class QueueControlUsingCoreTest extends QueueControlTest {
          /**
           * Returns the age of the first message in milliseconds.
           */
+         @Override
          public Long getFirstMessageAge() throws Exception {
             Object value = proxy.invokeOperation("getFirstMessageAge");
 
@@ -171,10 +198,12 @@ public class QueueControlUsingCoreTest extends QueueControlTest {
             return (Long) value;
          }
 
+         @Override
          public String listMessageCounterHistoryAsHTML() throws Exception {
             return (String) proxy.invokeOperation("listMessageCounterHistoryAsHTML");
          }
 
+         @Override
          public Map<String, Object>[] listMessages(final String filter) throws Exception {
             Object[] res = (Object[]) proxy.invokeOperation("listMessages", filter);
             Map<String, Object>[] results = new Map[res.length];
@@ -184,10 +213,12 @@ public class QueueControlUsingCoreTest extends QueueControlTest {
             return results;
          }
 
+         @Override
          public String listMessagesAsJSON(final String filter) throws Exception {
             return (String) proxy.invokeOperation("listMessagesAsJSON", filter);
          }
 
+         @Override
          public Map<String, Object>[] listScheduledMessages() throws Exception {
             Object[] res = (Object[]) proxy.invokeOperation("listScheduledMessages");
             Map<String, Object>[] results = new Map[res.length];
@@ -197,10 +228,12 @@ public class QueueControlUsingCoreTest extends QueueControlTest {
             return results;
          }
 
+         @Override
          public String listScheduledMessagesAsJSON() throws Exception {
             return (String) proxy.invokeOperation("listScheduledMessagesAsJSON");
          }
 
+         @Override
          public int moveMessages(final String filter, final String otherQueueName) throws Exception {
             return (Integer) proxy.invokeOperation("moveMessages", filter, otherQueueName);
          }
@@ -213,50 +246,61 @@ public class QueueControlUsingCoreTest extends QueueControlTest {
             return (Integer) proxy.invokeOperation("moveMessages", flushLimit, filter, otherQueueName, rejectDuplicates);
          }
 
+         @Override
          public int moveMessages(final String filter,
                                  final String otherQueueName,
                                  final boolean rejectDuplicates) throws Exception {
             return (Integer) proxy.invokeOperation("moveMessages", filter, otherQueueName, rejectDuplicates);
          }
 
+         @Override
          public boolean moveMessage(final long messageID, final String otherQueueName) throws Exception {
             return (Boolean) proxy.invokeOperation("moveMessage", messageID, otherQueueName);
          }
 
+         @Override
          public boolean moveMessage(final long messageID,
                                     final String otherQueueName,
                                     final boolean rejectDuplicates) throws Exception {
             return (Boolean) proxy.invokeOperation("moveMessage", messageID, otherQueueName, rejectDuplicates);
          }
 
+         @Override
          public boolean retryMessage(final long messageID) throws Exception {
             return (Boolean) proxy.invokeOperation("retryMessage", messageID);
          }
 
+         @Override
          public int retryMessages() throws Exception {
             return (Integer) proxy.invokeOperation("retryMessages");
          }
 
+         @Override
          public int removeMessages(final String filter) throws Exception {
             return (Integer) proxy.invokeOperation("removeMessages", filter);
          }
 
+         @Override
          public int removeMessages(final int limit, final String filter) throws Exception {
             return (Integer) proxy.invokeOperation("removeMessages", limit, filter);
          }
 
+         @Override
          public boolean removeMessage(final long messageID) throws Exception {
             return (Boolean) proxy.invokeOperation("removeMessage", messageID);
          }
 
+         @Override
          public void resetMessageCounter() throws Exception {
             proxy.invokeOperation("resetMessageCounter");
          }
 
+         @Override
          public boolean sendMessageToDeadLetterAddress(final long messageID) throws Exception {
             return (Boolean) proxy.invokeOperation("sendMessageToDeadLetterAddress", messageID);
          }
 
+         @Override
          public int sendMessagesToDeadLetterAddress(final String filterStr) throws Exception {
             return (Integer) proxy.invokeOperation("sendMessagesToDeadLetterAddress", filterStr);
          }
@@ -269,22 +313,27 @@ public class QueueControlUsingCoreTest extends QueueControlTest {
             proxy.invokeOperation("setExpiryAddress", expiryAddress);
          }
 
+         @Override
          public void pause() throws Exception {
             proxy.invokeOperation("pause");
          }
 
+         @Override
          public void resume() throws Exception {
             proxy.invokeOperation("resume");
          }
 
+         @Override
          public boolean isPaused() throws Exception {
             return (Boolean) proxy.invokeOperation("isPaused");
          }
 
+         @Override
          public String listConsumersAsJSON() throws Exception {
             return (String) proxy.invokeOperation("listConsumersAsJSON");
          }
 
+         @Override
          public Map<String, Map<String, Object>[]> listDeliveringMessages() throws Exception {
             // This map code could be done better,
             // however that's just to convert stuff for the test class, so I

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/mqtt/imported/MQTTTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/mqtt/imported/MQTTTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/mqtt/imported/MQTTTest.java
index 9a63da1..6627014 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/mqtt/imported/MQTTTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/mqtt/imported/MQTTTest.java
@@ -55,6 +55,7 @@ public class MQTTTest extends MQTTTestSupport {
 
    private static final int NUM_MESSAGES = 250;
 
+   @Override
    @Before
    public void setUp() throws Exception {
       Field sessions = MQTTSession.class.getDeclaredField("SESSIONS");

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/mqtt/imported/MQTTTestSupport.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/mqtt/imported/MQTTTestSupport.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/mqtt/imported/MQTTTestSupport.java
index 9fa0ffe..28cd8d3 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/mqtt/imported/MQTTTestSupport.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/mqtt/imported/MQTTTestSupport.java
@@ -84,10 +84,12 @@ public class MQTTTestSupport extends ActiveMQTestBase {
       this.useSSL = useSSL;
    }
 
+   @Override
    public String getName() {
       return name.getMethodName();
    }
 
+   @Override
    @Before
    public void setUp() throws Exception {
       String basedir = basedir().getPath();
@@ -102,6 +104,7 @@ public class MQTTTestSupport extends ActiveMQTestBase {
       startBroker();
    }
 
+   @Override
    @After
    public void tearDown() throws Exception {
       System.clearProperty("javax.net.ssl.trustStore");

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/BasicSecurityTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/BasicSecurityTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/BasicSecurityTest.java
index 266ad34..a1a5e38 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/BasicSecurityTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/BasicSecurityTest.java
@@ -31,6 +31,7 @@ import org.junit.Test;
 
 public class BasicSecurityTest extends BasicOpenWireTest {
 
+   @Override
    @Before
    public void setUp() throws Exception {
       this.enableSecurity = true;

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JMSDurableTopicRedeliverTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JMSDurableTopicRedeliverTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JMSDurableTopicRedeliverTest.java
index ca96492..cbb3e31 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JMSDurableTopicRedeliverTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JMSDurableTopicRedeliverTest.java
@@ -80,6 +80,7 @@ public class JMSDurableTopicRedeliverTest extends JmsTopicRedeliverTest {
       assertNull(consumer.receive(1000));
    }
 
+   @Override
    protected String getName() {
       return "JMSDurableTopicRedeliverTest";
    }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsAutoAckListenerTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsAutoAckListenerTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsAutoAckListenerTest.java
index a61e462..644bc5e 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsAutoAckListenerTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsAutoAckListenerTest.java
@@ -58,6 +58,7 @@ public class JmsAutoAckListenerTest extends BasicOpenWireTest implements Message
       session.close();
    }
 
+   @Override
    public void onMessage(Message message) {
       System.out.println("Received message: " + message);
       assertNotNull(message);

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsConnectionStartStopTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsConnectionStartStopTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsConnectionStartStopTest.java
index 31cbb93..3606200 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsConnectionStartStopTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsConnectionStartStopTest.java
@@ -45,6 +45,7 @@ public class JmsConnectionStartStopTest extends BasicOpenWireTest {
    private Connection startedConnection;
    private Connection stoppedConnection;
 
+   @Override
    @Before
    public void setUp() throws Exception {
       super.setUp();
@@ -56,6 +57,7 @@ public class JmsConnectionStartStopTest extends BasicOpenWireTest {
    /**
     * @see junit.framework.TestCase#tearDown()
     */
+   @Override
    @After
    public void tearDown() throws Exception {
       stoppedConnection.close();

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsConsumerResetActiveListenerTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsConsumerResetActiveListenerTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsConsumerResetActiveListenerTest.java
index 80405b9..b50abb6 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsConsumerResetActiveListenerTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsConsumerResetActiveListenerTest.java
@@ -56,6 +56,7 @@ public class JmsConsumerResetActiveListenerTest extends BasicOpenWireTest {
       final Vector<Object> results = new Vector<Object>();
       consumer.setMessageListener(new MessageListener() {
 
+         @Override
          public void onMessage(Message message) {
             if (first.compareAndSet(true, false)) {
                try {
@@ -107,6 +108,7 @@ public class JmsConsumerResetActiveListenerTest extends BasicOpenWireTest {
       final Vector<Object> results = new Vector<Object>();
       consumer.setMessageListener(new MessageListener() {
 
+         @Override
          public void onMessage(Message message) {
             if (first.compareAndSet(true, false)) {
                try {

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsCreateConsumerInOnMessageTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsCreateConsumerInOnMessageTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsCreateConsumerInOnMessageTest.java
index dc86fa3..0aaded9 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsCreateConsumerInOnMessageTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsCreateConsumerInOnMessageTest.java
@@ -73,6 +73,7 @@ public class JmsCreateConsumerInOnMessageTest extends BasicOpenWireTest implemen
     *
     * @param message
     */
+   @Override
    public void onMessage(Message message) {
       System.out.println("____________onmessage " + message);
       try {

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableQueueWildcardSendReceiveTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableQueueWildcardSendReceiveTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableQueueWildcardSendReceiveTest.java
index a7be999..a17af75 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableQueueWildcardSendReceiveTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableQueueWildcardSendReceiveTest.java
@@ -23,6 +23,7 @@ import javax.jms.DeliveryMode;
  */
 public class JmsDurableQueueWildcardSendReceiveTest extends JmsTopicSendReceiveTest {
 
+   @Override
    public void setUp() throws Exception {
       topic = false;
       deliveryMode = DeliveryMode.PERSISTENT;

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableTopicSendReceiveTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableTopicSendReceiveTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableTopicSendReceiveTest.java
index 0762edd..f94defd 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableTopicSendReceiveTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableTopicSendReceiveTest.java
@@ -90,6 +90,7 @@ public class JmsDurableTopicSendReceiveTest extends JmsTopicSendReceiveTest {
       connection2.close();
    }
 
+   @Override
    protected String getName() {
       return "testSendWhileClosed";
    }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableTopicTransactionTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableTopicTransactionTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableTopicTransactionTest.java
index 53215ac..c155a6d 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableTopicTransactionTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableTopicTransactionTest.java
@@ -26,6 +26,7 @@ public class JmsDurableTopicTransactionTest extends JmsTopicTransactionTest {
    /**
     * @see JmsTransactionTestSupport#getJmsResourceProvider()
     */
+   @Override
    protected JmsResourceProvider getJmsResourceProvider() {
       JmsResourceProvider provider = new JmsResourceProvider();
       provider.setTopic(true);

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableTopicWildcardSendReceiveTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableTopicWildcardSendReceiveTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableTopicWildcardSendReceiveTest.java
index d422930..819ff20 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableTopicWildcardSendReceiveTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableTopicWildcardSendReceiveTest.java
@@ -23,6 +23,7 @@ import javax.jms.DeliveryMode;
  */
 public class JmsDurableTopicWildcardSendReceiveTest extends JmsTopicSendReceiveTest {
 
+   @Override
    public void setUp() throws Exception {
       topic = true;
       durable = true;

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsSendReceiveTestSupport.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsSendReceiveTestSupport.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsSendReceiveTestSupport.java
index 45d7c8e..e5cf659 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsSendReceiveTestSupport.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsSendReceiveTestSupport.java
@@ -181,6 +181,7 @@ public abstract class JmsSendReceiveTestSupport extends BasicOpenWireTest implem
     *
     * @see javax.jms.MessageListener#onMessage(javax.jms.Message)
     */
+   @Override
    public synchronized void onMessage(Message message) {
       consumeMessage(message, messages);
    }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsTopicRequestReplyTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsTopicRequestReplyTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsTopicRequestReplyTest.java
index 8005a34..e31621d 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsTopicRequestReplyTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsTopicRequestReplyTest.java
@@ -111,6 +111,7 @@ public class JmsTopicRequestReplyTest extends BasicOpenWireTest implements Messa
    /**
     * Use the asynchronous subscription mechanism
     */
+   @Override
    public void onMessage(Message message) {
       try {
          TextMessage requestMessage = (TextMessage) message;
@@ -185,6 +186,7 @@ public class JmsTopicRequestReplyTest extends BasicOpenWireTest implements Messa
       }
       else {
          Thread thread = new Thread(new Runnable() {
+            @Override
             public void run() {
                syncConsumeLoop(requestConsumer);
             }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsTopicWildcardSendReceiveTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsTopicWildcardSendReceiveTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsTopicWildcardSendReceiveTest.java
index 9208171..a651c0d 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsTopicWildcardSendReceiveTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsTopicWildcardSendReceiveTest.java
@@ -48,10 +48,12 @@ public class JmsTopicWildcardSendReceiveTest extends JmsTopicSendReceiveTest {
       super.setUp();
    }
 
+   @Override
    protected String getConsumerSubject() {
       return "FOO.>";
    }
 
+   @Override
    protected String getProducerSubject() {
       return "FOO.BAR.HUMBUG";
    }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/MessageListenerRedeliveryTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/MessageListenerRedeliveryTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/MessageListenerRedeliveryTest.java
index 37a544f..d07ec1a 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/MessageListenerRedeliveryTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/MessageListenerRedeliveryTest.java
@@ -391,6 +391,7 @@ public class MessageListenerRedeliveryTest extends BasicOpenWireTest {
       return DeliveryMode.PERSISTENT;
    }
 
+   @Override
    protected String getName() {
       return "testQueueSessionListenerExceptionDlq";
    }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/ProducerFlowControlSendFailTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/ProducerFlowControlSendFailTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/ProducerFlowControlSendFailTest.java
index 0eeb3e8..4d3a6f8 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/ProducerFlowControlSendFailTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/ProducerFlowControlSendFailTest.java
@@ -174,6 +174,7 @@ public class ProducerFlowControlSendFailTest extends ProducerFlowControlTest {
 
    protected ConnectionFactory getConnectionFactory() throws Exception {
       factory.setExceptionListener(new ExceptionListener() {
+         @Override
          public void onException(JMSException arg0) {
             if (arg0 instanceof ResourceAllocationException) {
                gotResourceException.set(true);

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/ProducerFlowControlTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/ProducerFlowControlTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/ProducerFlowControlTest.java
index cc4d3f0..49feb26 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/ProducerFlowControlTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/ProducerFlowControlTest.java
@@ -259,6 +259,7 @@ public class ProducerFlowControlTest extends BasicOpenWireTest {
       // Once the send starts to block it will not reset the done flag
       // anymore.
       asyncThread = new Thread("Fill thread.") {
+         @Override
          public void run() {
             Session session = null;
             try {
@@ -299,6 +300,7 @@ public class ProducerFlowControlTest extends BasicOpenWireTest {
    private CountDownLatch asyncSendTo(final ActiveMQQueue queue, final String message) throws JMSException {
       final CountDownLatch done = new CountDownLatch(1);
       new Thread("Send thread.") {
+         @Override
          public void run() {
             Session session = null;
             try {

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/ReconnectWithSameClientIDTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/ReconnectWithSameClientIDTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/ReconnectWithSameClientIDTest.java
index 940903a..671fd8d 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/ReconnectWithSameClientIDTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/ReconnectWithSameClientIDTest.java
@@ -69,6 +69,7 @@ public class ReconnectWithSameClientIDTest extends BasicOpenWireTest {
       }
    }
 
+   @Override
    @After
    public void tearDown() throws Exception {
       if (sameIdConnection != null) {

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/paging/PagingWithFailoverAndCountersTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/paging/PagingWithFailoverAndCountersTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/paging/PagingWithFailoverAndCountersTest.java
index 2c62e73..88730f3 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/paging/PagingWithFailoverAndCountersTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/paging/PagingWithFailoverAndCountersTest.java
@@ -170,6 +170,7 @@ public class PagingWithFailoverAndCountersTest extends ActiveMQTestBase {
          this.txSize = txSize;
       }
 
+      @Override
       public void run() {
          try {
 
@@ -235,6 +236,7 @@ public class PagingWithFailoverAndCountersTest extends ActiveMQTestBase {
          super("Monitor-thread");
       }
 
+      @Override
       public void run() {
 
          ActiveMQServer server = inProcessBackup.getServer();

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQMessageHandlerTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQMessageHandlerTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQMessageHandlerTest.java
index a5636cf..d2d67e2 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQMessageHandlerTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQMessageHandlerTest.java
@@ -187,6 +187,7 @@ public class ActiveMQMessageHandlerTest extends ActiveMQRATestBase {
    /**
     * @return
     */
+   @Override
    protected ActiveMQResourceAdapter newResourceAdapter() {
       ActiveMQResourceAdapter qResourceAdapter = new ActiveMQResourceAdapter();
       qResourceAdapter.setConnectorClassName(INVM_CONNECTOR_FACTORY);

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQRAClusteredTestBase.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQRAClusteredTestBase.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQRAClusteredTestBase.java
index c49d38a..d702fa0 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQRAClusteredTestBase.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQRAClusteredTestBase.java
@@ -53,6 +53,7 @@ public class ActiveMQRAClusteredTestBase extends ActiveMQRATestBase {
 
    }
 
+   @Override
    protected Configuration createDefaultConfig(boolean netty) throws Exception {
       return createSecondaryDefaultConfig(false);
    }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQRATestBase.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQRATestBase.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQRATestBase.java
index 75dc976..8043689 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQRATestBase.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQRATestBase.java
@@ -101,6 +101,7 @@ public abstract class ActiveMQRATestBase extends JMSTestBase {
          return endpoint;
       }
 
+      @Override
       public boolean isDeliveryTransacted(Method method) throws NoSuchMethodException {
          return isDeliveryTransacted;
       }
@@ -122,20 +123,24 @@ public abstract class ActiveMQRATestBase extends JMSTestBase {
          this.latch = latch;
       }
 
+      @Override
       public void beforeDelivery(Method method) throws NoSuchMethodException, ResourceException {
 
       }
 
+      @Override
       public void afterDelivery() throws ResourceException {
          if (latch != null) {
             latch.countDown();
          }
       }
 
+      @Override
       public void release() {
          released = true;
       }
 
+      @Override
       public void onMessage(Message message) {
          lastMessage = (ActiveMQMessage) message;
       }
@@ -154,6 +159,7 @@ public abstract class ActiveMQRATestBase extends JMSTestBase {
 
       WorkManager workManager = new DummyWorkManager();
 
+      @Override
       public Timer createTimer() throws UnavailableException {
          return null;
       }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ResourceAdapterTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ResourceAdapterTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ResourceAdapterTest.java
index 221b3da..6bce079 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ResourceAdapterTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ResourceAdapterTest.java
@@ -660,14 +660,17 @@ public class ResourceAdapterTest extends ActiveMQRATestBase {
 
    class DummyEndpoint implements MessageEndpoint {
 
+      @Override
       public void beforeDelivery(Method method) throws NoSuchMethodException, ResourceException {
          // To change body of implemented methods use File | Settings | File Templates.
       }
 
+      @Override
       public void afterDelivery() throws ResourceException {
          // To change body of implemented methods use File | Settings | File Templates.
       }
 
+      @Override
       public void release() {
          // To change body of implemented methods use File | Settings | File Templates.
       }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/remoting/PingTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/remoting/PingTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/remoting/PingTest.java
index 35f83bd..ed4506f 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/remoting/PingTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/remoting/PingTest.java
@@ -87,6 +87,7 @@ public class PingTest extends ActiveMQTestBase {
          return me;
       }
 
+      @Override
       public void beforeReconnect(final ActiveMQException exception) {
       }
    }
@@ -214,6 +215,7 @@ public class PingTest extends ActiveMQTestBase {
       final CountDownLatch requiredPings = new CountDownLatch(1);
       final CountDownLatch unwantedPings = new CountDownLatch(2);
       server.getRemotingService().addIncomingInterceptor(new Interceptor() {
+         @Override
          public boolean intercept(final Packet packet, final RemotingConnection connection) throws ActiveMQException {
             if (packet.getType() == PacketImpl.PING) {
                Assert.assertEquals(ActiveMQClient.DEFAULT_CONNECTION_TTL_INVM, ((Ping) packet).getConnectionTTL());
@@ -325,6 +327,7 @@ public class PingTest extends ActiveMQTestBase {
       final CountDownLatch pingOnServerLatch = new CountDownLatch(2);
       server.getRemotingService().addIncomingInterceptor(new Interceptor() {
 
+         @Override
          public boolean intercept(final Packet packet, final RemotingConnection connection) throws ActiveMQException {
             if (packet.getType() == PacketImpl.PING) {
                pingOnServerLatch.countDown();
@@ -355,12 +358,14 @@ public class PingTest extends ActiveMQTestBase {
             connectionFailed(me, failedOver);
          }
 
+         @Override
          public void beforeReconnect(final ActiveMQException exception) {
          }
       };
 
       final CountDownLatch serverLatch = new CountDownLatch(1);
       CloseListener serverListener = new CloseListener() {
+         @Override
          public void connectionClosed() {
             serverLatch.countDown();
          }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/remoting/ReconnectTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/remoting/ReconnectTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/remoting/ReconnectTest.java
index 3278a64..268b10b 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/remoting/ReconnectTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/remoting/ReconnectTest.java
@@ -82,6 +82,7 @@ public class ReconnectTest extends ActiveMQTestBase {
                connectionFailed(me, failedOver);
             }
 
+            @Override
             public void beforeReconnect(final ActiveMQException exception) {
             }
 
@@ -269,6 +270,7 @@ public class ReconnectTest extends ActiveMQTestBase {
 
          session.addFailureListener(new SessionFailureListener() {
 
+            @Override
             public void connectionFailed(final ActiveMQException me, boolean failedOver) {
                count.incrementAndGet();
                latch.countDown();
@@ -279,6 +281,7 @@ public class ReconnectTest extends ActiveMQTestBase {
                connectionFailed(me, failedOver);
             }
 
+            @Override
             public void beforeReconnect(final ActiveMQException exception) {
             }
 
@@ -287,6 +290,7 @@ public class ReconnectTest extends ActiveMQTestBase {
          server.stop();
 
          Thread tcommitt = new Thread() {
+            @Override
             public void run() {
                latchCommit.countDown();
                try {

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/replication/ReplicationTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/replication/ReplicationTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/replication/ReplicationTest.java
index 5b1a4b3..e9e3c02 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/replication/ReplicationTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/replication/ReplicationTest.java
@@ -345,12 +345,14 @@ public final class ReplicationTest extends ActiveMQTestBase {
       final CountDownLatch latch = new CountDownLatch(1);
 
       ctx.executeOnCompletion(new IOCallback() {
+         @Override
          public void onError(final int errorCode, final String errorMessage) {
             lastError.set(errorCode);
             msgsResult.add(errorMessage);
             latch.countDown();
          }
 
+         @Override
          public void done() {
          }
       });
@@ -367,12 +369,14 @@ public final class ReplicationTest extends ActiveMQTestBase {
 
       // Adding the Task after the exception should still throw an exception
       ctx.executeOnCompletion(new IOCallback() {
+         @Override
          public void onError(final int errorCode, final String errorMessage) {
             lastError.set(errorCode);
             msgsResult.add(errorMessage);
             latch2.countDown();
          }
 
+         @Override
          public void done() {
          }
       });
@@ -388,9 +392,11 @@ public final class ReplicationTest extends ActiveMQTestBase {
       final CountDownLatch latch3 = new CountDownLatch(1);
 
       ctx.executeOnCompletion(new IOCallback() {
+         @Override
          public void onError(final int errorCode, final String errorMessage) {
          }
 
+         @Override
          public void done() {
             latch3.countDown();
          }
@@ -444,9 +450,11 @@ public final class ReplicationTest extends ActiveMQTestBase {
       final CountDownLatch latch = new CountDownLatch(1);
       storage.afterCompleteOperations(new IOCallback() {
 
+         @Override
          public void onError(final int errorCode, final String errorMessage) {
          }
 
+         @Override
          public void done() {
             latch.countDown();
          }
@@ -470,9 +478,11 @@ public final class ReplicationTest extends ActiveMQTestBase {
       final CountDownLatch latch = new CountDownLatch(1);
       storage.afterCompleteOperations(new IOCallback() {
 
+         @Override
          public void onError(final int errorCode, final String errorMessage) {
          }
 
+         @Override
          public void done() {
             latch.countDown();
          }
@@ -509,9 +519,11 @@ public final class ReplicationTest extends ActiveMQTestBase {
 
          ctx.executeOnCompletion(new IOCallback() {
 
+            @Override
             public void onError(final int errorCode, final String errorMessage) {
             }
 
+            @Override
             public void done() {
                executions.add(nAdd);
                latch.countDown();
@@ -530,13 +542,16 @@ public final class ReplicationTest extends ActiveMQTestBase {
 
    class FakeData implements EncodingSupport {
 
+      @Override
       public void decode(final ActiveMQBuffer buffer) {
       }
 
+      @Override
       public void encode(final ActiveMQBuffer buffer) {
          buffer.writeBytes(new byte[5]);
       }
 
+      @Override
       public int getEncodeSize() {
          return 5;
       }
@@ -599,6 +614,7 @@ public final class ReplicationTest extends ActiveMQTestBase {
 
       static AtomicBoolean value = new AtomicBoolean(true);
 
+      @Override
       public boolean intercept(final Packet packet, final RemotingConnection connection) throws ActiveMQException {
          return TestInterceptor.value.get();
       }
@@ -607,6 +623,7 @@ public final class ReplicationTest extends ActiveMQTestBase {
 
    static final class FakeJournal implements Journal {
 
+      @Override
       public void appendAddRecord(final long id,
                                   final byte recordType,
                                   final byte[] record,
@@ -614,6 +631,7 @@ public final class ReplicationTest extends ActiveMQTestBase {
 
       }
 
+      @Override
       public void appendAddRecord(final long id,
                                   final byte recordType,
                                   final EncodingSupport record,
@@ -621,6 +639,7 @@ public final class ReplicationTest extends ActiveMQTestBase {
 
       }
 
+      @Override
       public void appendAddRecordTransactional(final long txID,
                                                final long id,
                                                final byte recordType,
@@ -628,6 +647,7 @@ public final class ReplicationTest extends ActiveMQTestBase {
 
       }
 
+      @Override
       public void appendAddRecordTransactional(final long txID,
                                                final long id,
                                                final byte recordType,
@@ -635,46 +655,55 @@ public final class ReplicationTest extends ActiveMQTestBase {
 
       }
 
+      @Override
       public void appendCommitRecord(final long txID, final boolean sync) throws Exception {
 
       }
 
+      @Override
       public void appendDeleteRecord(final long id, final boolean sync) throws Exception {
 
       }
 
+      @Override
       public void appendDeleteRecordTransactional(final long txID,
                                                   final long id,
                                                   final byte[] record) throws Exception {
 
       }
 
+      @Override
       public void appendDeleteRecordTransactional(final long txID,
                                                   final long id,
                                                   final EncodingSupport record) throws Exception {
 
       }
 
+      @Override
       public void appendDeleteRecordTransactional(final long txID, final long id) throws Exception {
 
       }
 
+      @Override
       public void appendPrepareRecord(final long txID,
                                       final EncodingSupport transactionData,
                                       final boolean sync) throws Exception {
 
       }
 
+      @Override
       public void appendPrepareRecord(final long txID,
                                       final byte[] transactionData,
                                       final boolean sync) throws Exception {
 
       }
 
+      @Override
       public void appendRollbackRecord(final long txID, final boolean sync) throws Exception {
 
       }
 
+      @Override
       public void appendUpdateRecord(final long id,
                                      final byte recordType,
                                      final byte[] record,
@@ -682,6 +711,7 @@ public final class ReplicationTest extends ActiveMQTestBase {
 
       }
 
+      @Override
       public void appendUpdateRecord(final long id,
                                      final byte recordType,
                                      final EncodingSupport record,
@@ -689,6 +719,7 @@ public final class ReplicationTest extends ActiveMQTestBase {
 
       }
 
+      @Override
       public void appendUpdateRecordTransactional(final long txID,
                                                   final long id,
                                                   final byte recordType,
@@ -696,6 +727,7 @@ public final class ReplicationTest extends ActiveMQTestBase {
 
       }
 
+      @Override
       public void appendUpdateRecordTransactional(final long txID,
                                                   final long id,
                                                   final byte recordType,
@@ -703,16 +735,19 @@ public final class ReplicationTest extends ActiveMQTestBase {
 
       }
 
+      @Override
       public int getAlignment() throws Exception {
 
          return 0;
       }
 
+      @Override
       public JournalLoadInformation load(final LoaderCallback reloadManager) throws Exception {
 
          return new JournalLoadInformation();
       }
 
+      @Override
       public JournalLoadInformation load(final List<RecordInfo> committedRecords,
                                          final List<PreparedTransactionInfo> preparedTransactions,
                                          final TransactionFailureCallback transactionFailure) throws Exception {
@@ -720,31 +755,38 @@ public final class ReplicationTest extends ActiveMQTestBase {
          return new JournalLoadInformation();
       }
 
+      @Override
       public void perfBlast(final int pages) {
 
       }
 
+      @Override
       public boolean isStarted() {
 
          return false;
       }
 
+      @Override
       public void start() throws Exception {
 
       }
 
+      @Override
       public void stop() throws Exception {
 
       }
 
+      @Override
       public JournalLoadInformation loadInternalOnly() throws Exception {
          return new JournalLoadInformation();
       }
 
+      @Override
       public int getNumberOfRecords() {
          return 0;
       }
 
+      @Override
       public void appendAddRecord(final long id,
                                   final byte recordType,
                                   final EncodingSupport record,
@@ -752,27 +794,32 @@ public final class ReplicationTest extends ActiveMQTestBase {
                                   final IOCompletion completionCallback) throws Exception {
       }
 
+      @Override
       public void appendCommitRecord(final long txID,
                                      final boolean sync,
                                      final IOCompletion callback) throws Exception {
       }
 
+      @Override
       public void appendDeleteRecord(final long id,
                                      final boolean sync,
                                      final IOCompletion completionCallback) throws Exception {
       }
 
+      @Override
       public void appendPrepareRecord(final long txID,
                                       final EncodingSupport transactionData,
                                       final boolean sync,
                                       final IOCompletion callback) throws Exception {
       }
 
+      @Override
       public void appendRollbackRecord(final long txID,
                                        final boolean sync,
                                        final IOCompletion callback) throws Exception {
       }
 
+      @Override
       public void appendUpdateRecord(final long id,
                                      final byte recordType,
                                      final EncodingSupport record,
@@ -783,9 +830,11 @@ public final class ReplicationTest extends ActiveMQTestBase {
       public void sync(final IOCompletion callback) {
       }
 
+      @Override
       public void runDirectJournalBlast() throws Exception {
       }
 
+      @Override
       public int getUserVersion() {
          return 0;
       }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/security/SecurityTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/security/SecurityTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/security/SecurityTest.java
index 3047038..468ffa5 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/security/SecurityTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/security/SecurityTest.java
@@ -1648,10 +1648,12 @@ public class SecurityTest extends ActiveMQTestBase {
    public void testCustomSecurityManager() throws Exception {
       final Configuration configuration = createDefaultInVMConfig().setSecurityEnabled(true);
       final ActiveMQSecurityManager customSecurityManager = new ActiveMQSecurityManager() {
+            @Override
             public boolean validateUser(final String username, final String password) {
                return (username.equals("foo") || username.equals("bar") || username.equals("all")) &&
                   password.equals("frobnicate");
             }
+            @Override
             public boolean validateUserAndRole(
                final String username,
                final String password,
@@ -1732,14 +1734,17 @@ public class SecurityTest extends ActiveMQTestBase {
    public void testCustomSecurityManager2() throws Exception {
       final Configuration configuration = createDefaultInVMConfig().setSecurityEnabled(true);
       final ActiveMQSecurityManager customSecurityManager = new ActiveMQSecurityManager2() {
+            @Override
             public boolean validateUser(final String username, final String password) {
                fail("Unexpected call to overridden method");
                return false;
             }
+            @Override
             public boolean validateUser(final String username, final String password, final X509Certificate[] certificates) {
                return (username.equals("foo") || username.equals("bar") || username.equals("all")) &&
                   password.equals("frobnicate");
             }
+            @Override
             public boolean validateUserAndRole(
                final String username,
                final String password,
@@ -1750,6 +1755,7 @@ public class SecurityTest extends ActiveMQTestBase {
                return false;
             }
 
+            @Override
             public boolean validateUserAndRole(
                final String username,
                final String password,

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/AddressFullLoggingTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/AddressFullLoggingTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/AddressFullLoggingTest.java
index d9469ba..36f866a 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/AddressFullLoggingTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/AddressFullLoggingTest.java
@@ -77,6 +77,7 @@ public class AddressFullLoggingTest extends ActiveMQTestBase {
 
       ExecutorService executor = Executors.newFixedThreadPool(1);
       Callable<Object> sendMessageTask = new Callable<Object>() {
+         @Override
          public Object call() throws ActiveMQException {
             producer.send(message);
             return null;

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/ExpiryRunnerTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/ExpiryRunnerTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/ExpiryRunnerTest.java
index f015ca6..ee4ac08 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/ExpiryRunnerTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/ExpiryRunnerTest.java
@@ -263,6 +263,7 @@ public class ExpiryRunnerTest extends ActiveMQTestBase {
          this.latch = latch;
       }
 
+      @Override
       public void run() {
          while (true) {
             try {

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/GracefulShutdownTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/GracefulShutdownTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/GracefulShutdownTest.java
index b7894a4..f42e585 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/GracefulShutdownTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/GracefulShutdownTest.java
@@ -45,6 +45,7 @@ public class GracefulShutdownTest extends ActiveMQTestBase {
       ClientSession session = sf.createSession(true, true);
 
       Thread t = new Thread(new Runnable() {
+         @Override
          public void run() {
             try {
                server.stop();
@@ -113,6 +114,7 @@ public class GracefulShutdownTest extends ActiveMQTestBase {
       ClientSessionFactory sf = createSessionFactory(locator);
 
       Thread t = new Thread(new Runnable() {
+         @Override
          public void run() {
             try {
                server.stop();

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/SuppliedThreadPoolTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/SuppliedThreadPoolTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/SuppliedThreadPoolTest.java
index 3b00219..2e9accf 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/SuppliedThreadPoolTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/SuppliedThreadPoolTest.java
@@ -49,6 +49,7 @@ public class SuppliedThreadPoolTest extends ActiveMQTestBase {
       server.waitForActivation(100, TimeUnit.MILLISECONDS);
    }
 
+   @Override
    @After
    public void tearDown() throws Exception {
       if (server.isActive()) {

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/spring/ExampleListener.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/spring/ExampleListener.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/spring/ExampleListener.java
index da7b647..8093d28 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/spring/ExampleListener.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/spring/ExampleListener.java
@@ -29,6 +29,7 @@ public class ExampleListener implements MessageListener {
 
    public static ReusableLatch latch = new ReusableLatch();
 
+   @Override
    public void onMessage(Message message) {
       try {
          lastMessage = ((TextMessage) message).getText();

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/spring/SpringIntegrationTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/spring/SpringIntegrationTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/spring/SpringIntegrationTest.java
index 0b0d1c8..f2e5cfd 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/spring/SpringIntegrationTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/spring/SpringIntegrationTest.java
@@ -33,6 +33,7 @@ public class SpringIntegrationTest extends ActiveMQTestBase {
 
    IntegrationTestLogger log = IntegrationTestLogger.LOGGER;
 
+   @Override
    @Before
    public void setUp() throws Exception {
       super.setUp();

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ssl/CoreClientOverTwoWaySSLTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ssl/CoreClientOverTwoWaySSLTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ssl/CoreClientOverTwoWaySSLTest.java
index 00cc0a7..d66b968 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ssl/CoreClientOverTwoWaySSLTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ssl/CoreClientOverTwoWaySSLTest.java
@@ -96,6 +96,7 @@ public class CoreClientOverTwoWaySSLTest extends ActiveMQTestBase {
 
    private class MyInterceptor implements Interceptor {
 
+      @Override
       public boolean intercept(final Packet packet, final RemotingConnection connection) throws ActiveMQException {
          if (packet.getType() == PacketImpl.SESS_SEND) {
             try {

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/StompTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/StompTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/StompTest.java
index b6b908a..534f342 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/StompTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/StompTest.java
@@ -56,6 +56,7 @@ public class StompTest extends StompTestBase {
       final CountDownLatch latch = new CountDownLatch(count);
       consumer.setMessageListener(new MessageListener() {
 
+         @Override
          public void onMessage(Message arg0) {
             latch.countDown();
          }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/AbstractClientStompFrame.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/AbstractClientStompFrame.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/AbstractClientStompFrame.java
index 8bc7f95..1aabb1a 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/AbstractClientStompFrame.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/AbstractClientStompFrame.java
@@ -65,6 +65,7 @@ public abstract class AbstractClientStompFrame implements ClientStompFrame {
       return validCommands.contains(command);
    }
 
+   @Override
    public String toString() {
       StringBuffer sb = new StringBuffer("Frame: <" + command + ">" + "\n");
       Iterator<Header> iter = headers.iterator();

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/AbstractStompClientConnection.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/AbstractStompClientConnection.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/AbstractStompClientConnection.java
index bac977b..4d3c07c 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/AbstractStompClientConnection.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/AbstractStompClientConnection.java
@@ -88,6 +88,7 @@ public abstract class AbstractStompClientConnection implements StompClientConnec
       new ReaderThread().start();
    }
 
+   @Override
    public ClientStompFrame sendFrame(ClientStompFrame frame) throws IOException, InterruptedException {
       ClientStompFrame response = null;
       ByteBuffer buffer = frame.toByteBuffer();
@@ -113,6 +114,7 @@ public abstract class AbstractStompClientConnection implements StompClientConnec
       return response;
    }
 
+   @Override
    public ClientStompFrame sendWickedFrame(ClientStompFrame frame) throws IOException, InterruptedException {
       ClientStompFrame response = null;
       ByteBuffer buffer = frame.toByteBufferWithExtra("\n");
@@ -138,10 +140,12 @@ public abstract class AbstractStompClientConnection implements StompClientConnec
       return response;
    }
 
+   @Override
    public ClientStompFrame receiveFrame() throws InterruptedException {
       return frameQueue.poll(10, TimeUnit.SECONDS);
    }
 
+   @Override
    public ClientStompFrame receiveFrame(long timeout) throws InterruptedException {
       return frameQueue.poll(timeout, TimeUnit.MILLISECONDS);
    }
@@ -236,10 +240,12 @@ public abstract class AbstractStompClientConnection implements StompClientConnec
       }
    }
 
+   @Override
    public ClientStompFrame connect() throws Exception {
       return connect(null, null);
    }
 
+   @Override
    public void destroy() {
       try {
          close();
@@ -251,18 +257,22 @@ public abstract class AbstractStompClientConnection implements StompClientConnec
       }
    }
 
+   @Override
    public ClientStompFrame connect(String username, String password) throws Exception {
       throw new RuntimeException("connect method not implemented!");
    }
 
+   @Override
    public boolean isConnected() {
       return connected;
    }
 
+   @Override
    public String getVersion() {
       return version;
    }
 
+   @Override
    public int getFrameQueueSize() {
       return this.frameQueue.size();
    }
@@ -310,6 +320,7 @@ public abstract class AbstractStompClientConnection implements StompClientConnec
          this.notify();
       }
 
+      @Override
       public void run() {
          synchronized (this) {
             while (!stop) {

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/ClientStompFrameV11.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/ClientStompFrameV11.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/ClientStompFrameV11.java
index c168922..22d7146 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/ClientStompFrameV11.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/ClientStompFrameV11.java
@@ -37,6 +37,7 @@ public class ClientStompFrameV11 extends AbstractClientStompFrame {
       super(command, validate);
    }
 
+   @Override
    public void setForceOneway() {
       forceOneway = true;
    }
@@ -52,10 +53,12 @@ public class ClientStompFrameV11 extends AbstractClientStompFrame {
       return false;
    }
 
+   @Override
    public void setPing(boolean b) {
       isPing = b;
    }
 
+   @Override
    public boolean isPing() {
       return isPing;
    }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/ClientStompFrameV12.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/ClientStompFrameV12.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/ClientStompFrameV12.java
index 22ce99e..5ca530e 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/ClientStompFrameV12.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/ClientStompFrameV12.java
@@ -44,6 +44,7 @@ public class ClientStompFrameV12 extends AbstractClientStompFrame {
       }
    }
 
+   @Override
    public void setForceOneway() {
       forceOneway = true;
    }
@@ -59,10 +60,12 @@ public class ClientStompFrameV12 extends AbstractClientStompFrame {
       return false;
    }
 
+   @Override
    public void setPing(boolean b) {
       isPing = b;
    }
 
+   @Override
    public boolean isPing() {
       return isPing;
    }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompClientConnectionV10.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompClientConnectionV10.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompClientConnectionV10.java
index 2c9dfe7..5f46b0a 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompClientConnectionV10.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompClientConnectionV10.java
@@ -27,6 +27,7 @@ public class StompClientConnectionV10 extends AbstractStompClientConnection {
       super("1.0", host, port);
    }
 
+   @Override
    public ClientStompFrame connect(String username, String passcode) throws IOException, InterruptedException {
       ClientStompFrame frame = factory.newFrame(CONNECT_COMMAND);
       frame.addHeader(LOGIN_HEADER, username);
@@ -44,6 +45,7 @@ public class StompClientConnectionV10 extends AbstractStompClientConnection {
       return response;
    }
 
+   @Override
    public void connect(String username, String passcode, String clientID) throws IOException, InterruptedException {
       ClientStompFrame frame = factory.newFrame(CONNECT_COMMAND);
       frame.addHeader(LOGIN_HEADER, username);

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompClientConnectionV11.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompClientConnectionV11.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompClientConnectionV11.java
index 481f7a1..1e2296c 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompClientConnectionV11.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompClientConnectionV11.java
@@ -24,6 +24,7 @@ public class StompClientConnectionV11 extends AbstractStompClientConnection {
       super("1.1", host, port);
    }
 
+   @Override
    public ClientStompFrame connect(String username, String passcode) throws IOException, InterruptedException {
       ClientStompFrame frame = factory.newFrame(CONNECT_COMMAND);
       frame.addHeader(ACCEPT_HEADER, "1.1");
@@ -49,6 +50,7 @@ public class StompClientConnectionV11 extends AbstractStompClientConnection {
       return response;
    }
 
+   @Override
    public void connect(String username, String passcode, String clientID) throws IOException, InterruptedException {
       ClientStompFrame frame = factory.newFrame(CONNECT_COMMAND);
       frame.addHeader(ACCEPT_HEADER, "1.1");

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompClientConnectionV12.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompClientConnectionV12.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompClientConnectionV12.java
index f28743d..797f731 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompClientConnectionV12.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompClientConnectionV12.java
@@ -29,6 +29,7 @@ public class StompClientConnectionV12 extends AbstractStompClientConnection {
       return factory.newFrame(command);
    }
 
+   @Override
    public ClientStompFrame connect(String username, String passcode) throws IOException, InterruptedException {
       ClientStompFrame frame = factory.newFrame(CONNECT_COMMAND);
       frame.addHeader(ACCEPT_HEADER, "1.2");

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompFrameFactoryV10.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompFrameFactoryV10.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompFrameFactoryV10.java
index 93674ac..5ed8566 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompFrameFactoryV10.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompFrameFactoryV10.java
@@ -37,6 +37,7 @@ import java.util.StringTokenizer;
  */
 public class StompFrameFactoryV10 implements StompFrameFactory {
 
+   @Override
    public ClientStompFrame createFrame(String data) {
       //split the string at "\n\n"
       String[] dataFields = data.split("\n\n");

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/v11/StompV11Test.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/v11/StompV11Test.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/v11/StompV11Test.java
index 6c40271..22b86a5 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/v11/StompV11Test.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/v11/StompV11Test.java
@@ -1259,6 +1259,7 @@ public class StompV11Test extends StompV11TestBase {
       final CountDownLatch latch = new CountDownLatch(1);
 
       Thread thr = new Thread() {
+         @Override
          public void run() {
             ClientStompFrame sendFrame = connV11.createFrame("SEND");
             sendFrame.addHeader("destination", getQueuePrefix() + getQueueName());
@@ -1450,6 +1451,7 @@ public class StompV11Test extends StompV11TestBase {
       int count = 1000;
       final CountDownLatch latch = new CountDownLatch(count);
       consumer.setMessageListener(new MessageListener() {
+         @Override
          public void onMessage(Message arg0) {
             latch.countDown();
          }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/v12/StompV12Test.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/v12/StompV12Test.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/v12/StompV12Test.java
index 59f4eb6..e6cbf64 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/v12/StompV12Test.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/v12/StompV12Test.java
@@ -1468,6 +1468,7 @@ public class StompV12Test extends StompV11TestBase {
       final CountDownLatch latch = new CountDownLatch(1);
 
       Thread thr = new Thread() {
+         @Override
          public void run() {
             ClientStompFrame sendFrame = connV12.createFrame("SEND");
             sendFrame.addHeader("destination", getQueuePrefix() + getQueueName());
@@ -1659,6 +1660,7 @@ public class StompV12Test extends StompV11TestBase {
       int count = 1000;
       final CountDownLatch latch = new CountDownLatch(count);
       consumer.setMessageListener(new MessageListener() {
+         @Override
          public void onMessage(Message arg0) {
             TextMessage m = (TextMessage) arg0;
             latch.countDown();

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/transports/netty/NettyConnectorWithHTTPUpgradeTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/transports/netty/NettyConnectorWithHTTPUpgradeTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/transports/netty/NettyConnectorWithHTTPUpgradeTest.java
index e455ac2..edcb588 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/transports/netty/NettyConnectorWithHTTPUpgradeTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/transports/netty/NettyConnectorWithHTTPUpgradeTest.java
@@ -137,6 +137,7 @@ public class NettyConnectorWithHTTPUpgradeTest extends ActiveMQTestBase {
       startWebServer(HTTP_PORT);
    }
 
+   @Override
    @After
    public void tearDown() throws Exception {
       stopWebServer();

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/xa/BasicXaTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/xa/BasicXaTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/xa/BasicXaTest.java
index 7d82a25..ce253a7 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/xa/BasicXaTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/xa/BasicXaTest.java
@@ -852,6 +852,7 @@ public class BasicXaTest extends ActiveMQTestBase {
          this.session = session;
       }
 
+      @Override
       public void onMessage(final ClientMessage message) {
          Xid xid = new XidImpl(UUIDGenerator.getInstance().generateStringUUID().getBytes(), 1, UUIDGenerator.getInstance().generateStringUUID().getBytes());
          try {

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/xa/XaTimeoutTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/xa/XaTimeoutTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/xa/XaTimeoutTest.java
index f244238..ea9d24a 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/xa/XaTimeoutTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/xa/XaTimeoutTest.java
@@ -376,6 +376,7 @@ public class XaTimeoutTest extends ActiveMQTestBase {
       clientSession.setTransactionTimeout(2);
 
       MessageHandler handler = new MessageHandler() {
+         @Override
          public void onMessage(ClientMessage message) {
             try {
                latchReceives.countDown();

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/util/NonSerializableFactory.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/util/NonSerializableFactory.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/util/NonSerializableFactory.java
index aea3b70..0ace718 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/util/NonSerializableFactory.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/util/NonSerializableFactory.java
@@ -85,6 +85,7 @@ public final class NonSerializableFactory implements ObjectFactory {
       return NonSerializableFactory.getWrapperMap().get(name);
    }
 
+   @Override
    public Object getObjectInstance(final Object obj,
                                    final Name name,
                                    final Context nameCtx,

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/jms-tests/src/test/java/org/apache/activemq/artemis/jms/tests/AcknowledgementTest.java
----------------------------------------------------------------------
diff --git a/tests/jms-tests/src/test/java/org/apache/activemq/artemis/jms/tests/AcknowledgementTest.java b/tests/jms-tests/src/test/java/org/apache/activemq/artemis/jms/tests/AcknowledgementTest.java
index 45f443a..b4edc54 100644
--- a/tests/jms-tests/src/test/java/org/apache/activemq/artemis/jms/tests/AcknowledgementTest.java
+++ b/tests/jms-tests/src/test/java/org/apache/activemq/artemis/jms/tests/AcknowledgementTest.java
@@ -936,6 +936,7 @@ public class AcknowledgementTest extends JMSTestCase {
          ProxyAssertSupport.assertTrue("failed to receive all messages", latch.await(2000, MILLISECONDS));
       }
 
+      @Override
       public abstract void onMessage(Message m);
 
    }


Mime
View raw message