activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [2/2] activemq-artemis git commit: Add missing @Overrides
Date Mon, 11 Jan 2016 18:21:08 GMT
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.skytta@iki.fi>
Authored: Sat Jan 9 13:33:03 2016 +0200
Committer: Clebert Suconic <clebertsuconic@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");


Mime
View raw message