You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2016/09/21 20:45:06 UTC
[4/4] activemq-artemis git commit: Add missing @Overrides
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� <vi...@iki.fi>
Authored: Wed Sep 21 13:15:12 2016 +0300
Committer: Clebert Suconic <cl...@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) {