Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add missing @Overrides

This commit is contained in:
Ville Skyttä 2016-01-09 13:33:03 +02:00 committed by Clebert Suconic
parent a4648f4a93
commit 389762cb3a
5 changed files with 13 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionImpl.java
View File

@ -555,6 +555,7 @@ final class PageSubscriptionImpl implements PageSubscription {
processACK(position); processACK(position);
} }
@Override
public void lateDeliveryRollback(PagePosition position) { public void lateDeliveryRollback(PagePosition position) {
PageCursorInfo cursorInfo = processACK(position); PageCursorInfo cursorInfo = processACK(position);
cursorInfo.decrementPendingTX(); cursorInfo.decrementPendingTX();

1
artemis-server/src/main/java/org/apache/activemq/artemis/core/postoffice/impl/DuplicateIDCacheImpl.java
View File

@ -196,6 +196,7 @@ public class DuplicateIDCacheImpl implements DuplicateIDCache {
} }
@Override
public synchronized void addToCache(final byte[] duplID, final Transaction tx, boolean instantAdd) throws Exception { public synchronized void addToCache(final byte[] duplID, final Transaction tx, boolean instantAdd) throws Exception {
long recordID = -1; long recordID = -1;

4
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/impl/BridgeImpl.java
View File

@ -330,8 +330,10 @@ public class BridgeImpl implements Bridge, SessionFailureListener, SendAcknowled
} }
} }
@Override
public void disconnect() { public void disconnect() {
executor.execute(new Runnable() { executor.execute(new Runnable() {
@Override
public void run() { public void run() {
if (session != null) { if (session != null) {
try { try {
@ -399,6 +401,7 @@ public class BridgeImpl implements Bridge, SessionFailureListener, SendAcknowled
} }
} }
@Override
public void pause() throws Exception { public void pause() throws Exception {
if (ActiveMQServerLogger.LOGGER.isDebugEnabled()) { if (ActiveMQServerLogger.LOGGER.isDebugEnabled()) {
ActiveMQServerLogger.LOGGER.debug("Bridge " + this.name + " being paused"); ActiveMQServerLogger.LOGGER.debug("Bridge " + this.name + " being paused");
@ -1068,6 +1071,7 @@ public class BridgeImpl implements Bridge, SessionFailureListener, SendAcknowled
bridge = bridge2; bridge = bridge2;
} }
@Override
public void run() { public void run() {
bridge.connect(); bridge.connect();
} }

1
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServerConsumerImpl.java
View File

@ -727,6 +727,7 @@ public class ServerConsumerImpl implements ServerConsumer, ReadyListener {
} }
} }
@Override
public void individualAcknowledge(Transaction tx, public void individualAcknowledge(Transaction tx,
final long messageID) throws Exception { final long messageID) throws Exception {
if (browseOnly) { if (browseOnly) {

6
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/journal/NIOSequentialFileFactoryTest.java
View File

@ -67,6 +67,7 @@ public class NIOSequentialFileFactoryTest extends SequentialFileFactoryTestBase
}, 1); }, 1);
Thread threadOpen = new Thread() { Thread threadOpen = new Thread() {
@Override
public void run() { public void run() {
try { try {
Thread.currentThread().interrupt(); Thread.currentThread().interrupt();
@ -83,6 +84,7 @@ public class NIOSequentialFileFactoryTest extends SequentialFileFactoryTestBase
threadOpen.join(); threadOpen.join();
Thread threadClose = new Thread() { Thread threadClose = new Thread() {
@Override
public void run() { public void run() {
try { try {
SequentialFile file = factory.createSequentialFile("file.txt"); SequentialFile file = factory.createSequentialFile("file.txt");
@ -101,6 +103,7 @@ public class NIOSequentialFileFactoryTest extends SequentialFileFactoryTestBase
threadClose.join(); threadClose.join();
Thread threadWrite = new Thread() { Thread threadWrite = new Thread() {
@Override
public void run() { public void run() {
try { try {
SequentialFile file = factory.createSequentialFile("file.txt"); SequentialFile file = factory.createSequentialFile("file.txt");
@ -120,6 +123,7 @@ public class NIOSequentialFileFactoryTest extends SequentialFileFactoryTestBase
threadWrite.join(); threadWrite.join();
Thread threadFill = new Thread() { Thread threadFill = new Thread() {
@Override
public void run() { public void run() {
try { try {
SequentialFile file = factory.createSequentialFile("file.txt"); SequentialFile file = factory.createSequentialFile("file.txt");
@ -139,6 +143,7 @@ public class NIOSequentialFileFactoryTest extends SequentialFileFactoryTestBase
threadFill.join(); threadFill.join();
Thread threadWriteDirect = new Thread() { Thread threadWriteDirect = new Thread() {
@Override
public void run() { public void run() {
try { try {
SequentialFile file = factory.createSequentialFile("file.txt"); SequentialFile file = factory.createSequentialFile("file.txt");
@ -160,6 +165,7 @@ public class NIOSequentialFileFactoryTest extends SequentialFileFactoryTestBase
threadWriteDirect.join(); threadWriteDirect.join();
Thread threadRead = new Thread() { Thread threadRead = new Thread() {
@Override
public void run() { public void run() {
try { try {
SequentialFile file = factory.createSequentialFile("file.txt"); SequentialFile file = factory.createSequentialFile("file.txt");