diff --git a/artemis-commons/src/test/java/org/apache/activemq/artemis/utils/ActiveMQScheduledComponentTest.java b/artemis-commons/src/test/java/org/apache/activemq/artemis/utils/ActiveMQScheduledComponentTest.java index bf920e7408..b4b7daf767 100644 --- a/artemis-commons/src/test/java/org/apache/activemq/artemis/utils/ActiveMQScheduledComponentTest.java +++ b/artemis-commons/src/test/java/org/apache/activemq/artemis/utils/ActiveMQScheduledComponentTest.java @@ -56,6 +56,7 @@ public class ActiveMQScheduledComponentTest { final ActiveMQScheduledComponent local = new ActiveMQScheduledComponent(scheduledExecutorService, executorService, 100, TimeUnit.MILLISECONDS, false) { + @Override public void run() { if (count.get() == 0) { try { diff --git a/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/sql/GenericSQLProvider.java b/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/sql/GenericSQLProvider.java index a246dd5ea8..f7b37f7163 100644 --- a/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/sql/GenericSQLProvider.java +++ b/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/sql/GenericSQLProvider.java @@ -201,6 +201,7 @@ public class GenericSQLProvider implements SQLProvider { public static class Factory implements SQLProvider.Factory { + @Override public SQLProvider create(String tableName) { return new GenericSQLProvider(tableName); } diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java index 7e32f43284..1f28754f36 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java @@ -2400,6 +2400,7 @@ public class ActiveMQServerImpl implements ActiveMQServer { return new Date().getTime() - startDate.getTime(); } + @Override public boolean addClientConnection(String clientId, boolean unique) { final AtomicInteger i = connectedClientIds.putIfAbsent(clientId, new AtomicInteger(1)); if (i != null) { @@ -2413,6 +2414,7 @@ public class ActiveMQServerImpl implements ActiveMQServer { return true; } + @Override public void removeClientConnection(String clientId) { AtomicInteger i = connectedClientIds.get(clientId); if (i != null && i.decrementAndGet() == 0) { diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java index 99ce43f1ab..d5862c817a 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java @@ -1100,6 +1100,7 @@ public class QueueImpl implements Queue { } } + @Override public void expire(final MessageReference ref) throws Exception { SimpleString messageExpiryAddress = expiryAddressFromMessageAddress(ref); if (messageExpiryAddress == null) {