Add missing @Override annotations

This commit is contained in:
Ville Skyttä 2016-07-19 10:58:00 +03:00 committed by Martyn Taylor
parent d1d2ebeb60
commit 39edf958a1
14 changed files with 16 additions and 0 deletions

View File

@ -290,6 +290,7 @@ public class JDBCSequentialFileFactoryDriver extends AbstractJDBCDriver {
/**
* Drop all tables and data
*/
@Override
public synchronized void destroy() throws SQLException {
try {
connection.setAutoCommit(false);

View File

@ -92,6 +92,7 @@ public class JDBCJournalImpl extends AbstractJDBCDriver implements Journal {
started = true;
}
@Override
protected void createSchema() throws SQLException {
createTable(sqlProvider.getCreateJournalTableSQL());
}
@ -118,6 +119,7 @@ public class JDBCJournalImpl extends AbstractJDBCDriver implements Journal {
}
}
@Override
public synchronized void destroy() throws Exception {
super.destroy();
stop();

View File

@ -200,6 +200,7 @@ final class MappedByteBufferCache implements AutoCloseable {
return closed;
}
@Override
public void close() {
if (!closed) {
//TO_FIX: unmap in this way is not portable BUT required on Windows that can't resize a memory mapped file!

View File

@ -100,6 +100,7 @@ public class PagingStoreFactoryNIO implements PagingStoreFactory {
return new PageCursorProviderImpl(store, storageManager, executor, addressSettings.getPageCacheMaxSize());
}
@Override
public synchronized PagingStore newStore(final SimpleString address, final AddressSettings settings) {
return new PagingStoreImpl(address, scheduledExecutor, syncTimeout, pagingManager, storageManager, null, this, address, settings, executorFactory.getExecutor(), syncNonTransactional);

View File

@ -292,6 +292,7 @@ public abstract class AbstractJournalStorageManager implements StorageManager {
getContext().executeOnCompletion(run);
}
@Override
public void afterStoreOperations(IOCallback run) {
getContext().executeOnCompletion(run, true);
}

View File

@ -370,6 +370,7 @@ public class NettyAcceptor extends AbstractAcceptor {
channel.pipeline().addLast(protocolHandler.getProtocolDecoder());
}
@Override
public void reload() {
serverChannelGroup.disconnect();
serverChannelGroup.clear();

View File

@ -2339,6 +2339,7 @@ public class ActiveMQServerImpl implements ActiveMQServer {
this.runnable = runnable;
}
@Override
public void run() {
lockActivation();
try {

View File

@ -183,6 +183,7 @@ public class RaceOnSyncLargeMessageOverReplication2Test extends ActiveMQTestBase
final MapMessage message = createLargeMessage();
t = new Thread() {
@Override
public void run() {
try {
producer.send(message);

View File

@ -40,6 +40,7 @@ public class SendingAndReceivingTest extends ActiveMQTestBase {
private ActiveMQServer server;
@Before
@Override
public void setUp() throws Exception {
super.setUp();
server = createServer(true, true);
@ -47,6 +48,7 @@ public class SendingAndReceivingTest extends ActiveMQTestBase {
}
@After
@Override
public void tearDown() throws Exception {
try {
server.stop();

View File

@ -184,6 +184,7 @@ public class ReplicationWithDivertTest extends ActiveMQTestBase {
final MapMessage message = createLargeMessage();
t = new Thread() {
@Override
public void run() {
try {
for (int i = 0; i < numberOfMessage; i++) {

View File

@ -125,6 +125,7 @@ public class JDBCJournalTest extends ActiveMQTestBase {
}
@After
@Override
public void tearDown() throws Exception {
journal.destroy();
}

View File

@ -79,6 +79,7 @@ public abstract class LargeMessageTestBase extends ActiveMQTestBase {
this.storeType = storeType;
}
@Override
public void tearDown() throws Exception {
super.tearDown();
if (storeType == StoreConfiguration.StoreType.DATABASE) {

View File

@ -708,6 +708,7 @@ public class ActiveMQServerControlUsingCoreTest extends ActiveMQServerControlTes
};
}
@Override
public boolean usingCore() {
return true;
}

View File

@ -55,6 +55,7 @@ public class StompTestWithSecurity extends StompTestBase {
Assert.assertTrue(Math.abs(tnow - tmsg) < 1000);
}
@Override
public boolean isSecurityEnabled() {
return true;
}