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/389762cb Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/389762cb Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/389762cb Branch: refs/heads/master Commit: 389762cb3a33db7c3f7c442ad5b968363c2da9dd Parents: a4648f4 Author: Ville Skyttä <ville.sky...@iki.fi> Authored: Sat Jan 9 13:33:03 2016 +0200 Committer: Clebert Suconic <clebertsuco...@apache.org> Committed: Mon Jan 11 13:20:57 2016 -0500 ---------------------------------------------------------------------- .../artemis/core/paging/cursor/impl/PageSubscriptionImpl.java | 1 + .../artemis/core/postoffice/impl/DuplicateIDCacheImpl.java | 1 + .../activemq/artemis/core/server/cluster/impl/BridgeImpl.java | 4 ++++ .../activemq/artemis/core/server/impl/ServerConsumerImpl.java | 1 + .../integration/journal/NIOSequentialFileFactoryTest.java | 6 ++++++ 5 files changed, 13 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/389762cb/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionImpl.java ---------------------------------------------------------------------- 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 9c1702e..243dcb6 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(); http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/389762cb/artemis-server/src/main/java/org/apache/activemq/artemis/core/postoffice/impl/DuplicateIDCacheImpl.java ---------------------------------------------------------------------- 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 cfeeb7b..fb6559c 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; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/389762cb/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/impl/BridgeImpl.java ---------------------------------------------------------------------- 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 d81dd3e..268c8cd 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(); } http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/389762cb/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServerConsumerImpl.java ---------------------------------------------------------------------- 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 fc5e24f..9468819 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) { http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/389762cb/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/journal/NIOSequentialFileFactoryTest.java ---------------------------------------------------------------------- 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 abadceb..42f8dd3 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");
