Add missing @Overrides

This commit is contained in:
Ville Skyttä 2016-09-21 13:15:12 +03:00 committed by Clebert Suconic
parent 905b7eace0
commit 02a7ac2949
4 changed files with 5 additions and 0 deletions

View File

@ -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 {

View File

@ -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);
}

View File

@ -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) {

View File

@ -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) {