Add missing @Overrides

Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/02a7ac29
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/02a7ac29
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/02a7ac29

Branch: refs/heads/master
Commit: 02a7ac29497ad9d4134085b8a647cab8fc8fa4ff
Parents: 905b7ea
Author: Ville Skyttä <ville.sky...@iki.fi>
Authored: Wed Sep 21 13:15:12 2016 +0300
Committer: Clebert Suconic <clebertsuco...@apache.org>
Committed: Wed Sep 21 16:31:14 2016 -0400

----------------------------------------------------------------------
 .../activemq/artemis/utils/ActiveMQScheduledComponentTest.java     | 1 +
 .../apache/activemq/artemis/jdbc/store/sql/GenericSQLProvider.java | 1 +
 .../activemq/artemis/core/server/impl/ActiveMQServerImpl.java      | 2 ++
 .../org/apache/activemq/artemis/core/server/impl/QueueImpl.java    | 1 +
 4 files changed, 5 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/02a7ac29/artemis-commons/src/test/java/org/apache/activemq/artemis/utils/ActiveMQScheduledComponentTest.java
----------------------------------------------------------------------
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 bf920e7..b4b7daf 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 {

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/02a7ac29/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/sql/GenericSQLProvider.java
----------------------------------------------------------------------
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 a246dd5..f7b37f7 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);
       }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/02a7ac29/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java
----------------------------------------------------------------------
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 7e32f43..1f28754 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) {

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/02a7ac29/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java
----------------------------------------------------------------------
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 99ce43f..d5862c8 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) {

Reply via email to