diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionImpl.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionImpl.java
index 9c1702e208..243dcb6657 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionImpl.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionImpl.java
@@ -555,6 +555,7 @@ final class PageSubscriptionImpl implements PageSubscription {
       processACK(position);
    }
 
+   @Override
    public void lateDeliveryRollback(PagePosition position) {
       PageCursorInfo cursorInfo = processACK(position);
       cursorInfo.decrementPendingTX();
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/postoffice/impl/DuplicateIDCacheImpl.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/postoffice/impl/DuplicateIDCacheImpl.java
index cfeeb7b7f8..fb6559ccdb 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/postoffice/impl/DuplicateIDCacheImpl.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/postoffice/impl/DuplicateIDCacheImpl.java
@@ -196,6 +196,7 @@ public class DuplicateIDCacheImpl implements DuplicateIDCache {
 
    }
 
+   @Override
    public synchronized void addToCache(final byte[] duplID, final Transaction tx, boolean instantAdd) throws Exception {
       long recordID = -1;
 
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/impl/BridgeImpl.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/impl/BridgeImpl.java
index d81dd3eec8..268c8cd2df 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/impl/BridgeImpl.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/impl/BridgeImpl.java
@@ -330,8 +330,10 @@ public class BridgeImpl implements Bridge, SessionFailureListener, SendAcknowled
       }
    }
 
+   @Override
    public void disconnect() {
       executor.execute(new Runnable() {
+         @Override
          public void run() {
             if (session != null) {
                try {
@@ -399,6 +401,7 @@ public class BridgeImpl implements Bridge, SessionFailureListener, SendAcknowled
       }
    }
 
+   @Override
    public void pause() throws Exception {
       if (ActiveMQServerLogger.LOGGER.isDebugEnabled()) {
          ActiveMQServerLogger.LOGGER.debug("Bridge " + this.name + " being paused");
@@ -1068,6 +1071,7 @@ public class BridgeImpl implements Bridge, SessionFailureListener, SendAcknowled
          bridge = bridge2;
       }
 
+      @Override
       public void run() {
          bridge.connect();
       }
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServerConsumerImpl.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServerConsumerImpl.java
index fc5e24f293..94688194a5 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServerConsumerImpl.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServerConsumerImpl.java
@@ -727,6 +727,7 @@ public class ServerConsumerImpl implements ServerConsumer, ReadyListener {
       }
    }
 
+   @Override
    public void individualAcknowledge(Transaction tx,
                                      final long messageID) throws Exception {
       if (browseOnly) {
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/journal/NIOSequentialFileFactoryTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/journal/NIOSequentialFileFactoryTest.java
index abadceb7b4..42f8dd3cf1 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/journal/NIOSequentialFileFactoryTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/journal/NIOSequentialFileFactoryTest.java
@@ -67,6 +67,7 @@ public class NIOSequentialFileFactoryTest extends SequentialFileFactoryTestBase
       }, 1);
 
       Thread threadOpen = new Thread() {
+         @Override
          public void run() {
             try {
                Thread.currentThread().interrupt();
@@ -83,6 +84,7 @@ public class NIOSequentialFileFactoryTest extends SequentialFileFactoryTestBase
       threadOpen.join();
 
       Thread threadClose = new Thread() {
+         @Override
          public void run() {
             try {
                SequentialFile file = factory.createSequentialFile("file.txt");
@@ -101,6 +103,7 @@ public class NIOSequentialFileFactoryTest extends SequentialFileFactoryTestBase
       threadClose.join();
 
       Thread threadWrite = new Thread() {
+         @Override
          public void run() {
             try {
                SequentialFile file = factory.createSequentialFile("file.txt");
@@ -120,6 +123,7 @@ public class NIOSequentialFileFactoryTest extends SequentialFileFactoryTestBase
       threadWrite.join();
 
       Thread threadFill = new Thread() {
+         @Override
          public void run() {
             try {
                SequentialFile file = factory.createSequentialFile("file.txt");
@@ -139,6 +143,7 @@ public class NIOSequentialFileFactoryTest extends SequentialFileFactoryTestBase
       threadFill.join();
 
       Thread threadWriteDirect = new Thread() {
+         @Override
          public void run() {
             try {
                SequentialFile file = factory.createSequentialFile("file.txt");
@@ -160,6 +165,7 @@ public class NIOSequentialFileFactoryTest extends SequentialFileFactoryTestBase
       threadWriteDirect.join();
 
       Thread threadRead = new Thread() {
+         @Override
          public void run() {
             try {
                SequentialFile file = factory.createSequentialFile("file.txt");