activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [01/42] activemq-artemis git commit: Add missing @Override annotations
Date Mon, 07 Dec 2015 18:39:13 GMT
Repository: activemq-artemis
Updated Branches:
  refs/heads/master fd38dddd0 -> deb84857a


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/server/impl/QueueImplTest.java
----------------------------------------------------------------------
diff --git a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/server/impl/QueueImplTest.java
b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/server/impl/QueueImplTest.java
index 1e57f23..8b4e265 100644
--- a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/server/impl/QueueImplTest.java
+++ b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/server/impl/QueueImplTest.java
@@ -155,10 +155,12 @@ public class QueueImplTest extends ActiveMQTestBase {
       Assert.assertNull(queue.getFilter());
 
       Filter filter = new Filter() {
+         @Override
          public boolean match(final ServerMessage message) {
             return false;
          }
 
+         @Override
          public SimpleString getFilterString() {
             return null;
          }
@@ -1226,6 +1228,7 @@ public class QueueImplTest extends ActiveMQTestBase {
          this.first = first;
       }
 
+      @Override
       public void run() {
          if (first) {
             queue.addHead(messageReference);

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/server/impl/fakes/FakeConsumer.java
----------------------------------------------------------------------
diff --git a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/server/impl/fakes/FakeConsumer.java
b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/server/impl/fakes/FakeConsumer.java
index dc109b1..7355674 100644
--- a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/server/impl/fakes/FakeConsumer.java
+++ b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/server/impl/fakes/FakeConsumer.java
@@ -45,10 +45,12 @@ public class FakeConsumer implements Consumer {
       this.filter = filter;
    }
 
+   @Override
    public Filter getFilter() {
       return filter;
    }
 
+   @Override
    public String debug() {
       return toString();
    }
@@ -89,6 +91,7 @@ public class FakeConsumer implements Consumer {
       references.clear();
    }
 
+   @Override
    public synchronized HandleStatus handle(final MessageReference reference) {
       if (statusToReturn == HandleStatus.BUSY) {
          return HandleStatus.BUSY;
@@ -142,6 +145,7 @@ public class FakeConsumer implements Consumer {
       //To change body of implemented methods use File | Settings | File Templates.
    }
 
+   @Override
    public List<MessageReference> getDeliveringMessages() {
       return Collections.emptyList();
    }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/server/impl/fakes/FakeFilter.java
----------------------------------------------------------------------
diff --git a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/server/impl/fakes/FakeFilter.java
b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/server/impl/fakes/FakeFilter.java
index 51f0780..9d7f0e1 100644
--- a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/server/impl/fakes/FakeFilter.java
+++ b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/server/impl/fakes/FakeFilter.java
@@ -35,6 +35,7 @@ public class FakeFilter implements Filter {
    public FakeFilter() {
    }
 
+   @Override
    public boolean match(final ServerMessage message) {
       if (headerName != null) {
          Object value = message.getObjectProperty(new SimpleString(headerName));
@@ -53,6 +54,7 @@ public class FakeFilter implements Filter {
       return true;
    }
 
+   @Override
    public SimpleString getFilterString() {
       return null;
    }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/server/impl/fakes/FakePostOffice.java
----------------------------------------------------------------------
diff --git a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/server/impl/fakes/FakePostOffice.java
b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/server/impl/fakes/FakePostOffice.java
index dc51f0e..27d9c33 100644
--- a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/server/impl/fakes/FakePostOffice.java
+++ b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/server/impl/fakes/FakePostOffice.java
@@ -80,6 +80,7 @@ public class FakePostOffice implements PostOffice {
       return null;
    }
 
+   @Override
    public Bindings lookupBindingsForAddress(final SimpleString address) throws Exception
{
 
       return null;
@@ -122,12 +123,14 @@ public class FakePostOffice implements PostOffice {
 
    }
 
+   @Override
    public Pair<RoutingContext, ServerMessage> redistribute(final ServerMessage message,
                                                            final Queue originatingQueue,
                                                            final Transaction tx) throws Exception
{
       return null;
    }
 
+   @Override
    public MessageReference reroute(final ServerMessage message,
                                    final Queue queue,
                                    final Transaction tx) throws Exception {
@@ -135,6 +138,7 @@ public class FakePostOffice implements PostOffice {
       return new MessageReferenceImpl();
    }
 
+   @Override
    public void route(ServerMessage message,
                      QueueCreator creator,
                      RoutingContext context,
@@ -142,6 +146,7 @@ public class FakePostOffice implements PostOffice {
 
    }
 
+   @Override
    public void route(ServerMessage message, QueueCreator creator, Transaction tx, boolean
direct) throws Exception {
 
    }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/server/impl/fakes/FakeQueueFactory.java
----------------------------------------------------------------------
diff --git a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/server/impl/fakes/FakeQueueFactory.java
b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/server/impl/fakes/FakeQueueFactory.java
index 288b6f9..0219153 100644
--- a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/server/impl/fakes/FakeQueueFactory.java
+++ b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/server/impl/fakes/FakeQueueFactory.java
@@ -36,6 +36,7 @@ public class FakeQueueFactory implements QueueFactory {
 
    private PostOffice postOffice;
 
+   @Override
    public Queue createQueue(final long persistenceID,
                             final SimpleString address,
                             final SimpleString name,
@@ -48,6 +49,7 @@ public class FakeQueueFactory implements QueueFactory {
       return new QueueImpl(persistenceID, address, name, filter, subscription, user, durable,
temporary, autoCreated, scheduledExecutor, postOffice, null, null, executor);
    }
 
+   @Override
    public void setPostOffice(final PostOffice postOffice) {
       this.postOffice = postOffice;
 

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/jms/client/ActiveMQStreamMessageTest.java
----------------------------------------------------------------------
diff --git a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/jms/client/ActiveMQStreamMessageTest.java
b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/jms/client/ActiveMQStreamMessageTest.java
index b319dfb..614084e 100644
--- a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/jms/client/ActiveMQStreamMessageTest.java
+++ b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/jms/client/ActiveMQStreamMessageTest.java
@@ -71,6 +71,7 @@ public class ActiveMQStreamMessageTest extends ActiveMQTestBase {
    @Test
    public void testReadBooleanFromInvalidType() throws Exception {
       doReadTypeFromInvalidType(RandomUtil.randomFloat(), new TypeReader() {
+         @Override
          public Object readType(final ActiveMQStreamMessage message) throws Exception {
             return message.readBoolean();
          }
@@ -80,6 +81,7 @@ public class ActiveMQStreamMessageTest extends ActiveMQTestBase {
    @Test
    public void testReadBooleanFromEmptyMessage() throws Exception {
       doReadTypeFromEmptyMessage(new TypeReader() {
+         @Override
          public Object readType(final ActiveMQStreamMessage message) throws Exception {
             return message.readBoolean();
          }
@@ -89,6 +91,7 @@ public class ActiveMQStreamMessageTest extends ActiveMQTestBase {
    @Test
    public void testReadCharFromInvalidType() throws Exception {
       doReadTypeFromInvalidType(RandomUtil.randomFloat(), new TypeReader() {
+         @Override
          public Object readType(final ActiveMQStreamMessage message) throws Exception {
             return message.readChar();
          }
@@ -98,6 +101,7 @@ public class ActiveMQStreamMessageTest extends ActiveMQTestBase {
    @Test
    public void testReadCharFromEmptyMessage() throws Exception {
       doReadTypeFromEmptyMessage(new TypeReader() {
+         @Override
          public Object readType(final ActiveMQStreamMessage message) throws Exception {
             return message.readChar();
          }
@@ -129,6 +133,7 @@ public class ActiveMQStreamMessageTest extends ActiveMQTestBase {
    @Test
    public void testReadByteFromInvalidType() throws Exception {
       doReadTypeFromInvalidType(RandomUtil.randomFloat(), new TypeReader() {
+         @Override
          public Object readType(final ActiveMQStreamMessage message) throws Exception {
             return message.readByte();
          }
@@ -138,6 +143,7 @@ public class ActiveMQStreamMessageTest extends ActiveMQTestBase {
    @Test
    public void testReadByteFromEmptyMessage() throws Exception {
       doReadTypeFromEmptyMessage(new TypeReader() {
+         @Override
          public Object readType(final ActiveMQStreamMessage message) throws Exception {
             return message.readByte();
          }
@@ -175,6 +181,7 @@ public class ActiveMQStreamMessageTest extends ActiveMQTestBase {
    @Test
    public void testReadBytesFromInvalidType() throws Exception {
       doReadTypeFromInvalidType(RandomUtil.randomBoolean(), new TypeReader() {
+         @Override
          public Object readType(final ActiveMQStreamMessage message) throws Exception {
             return message.readByte();
          }
@@ -184,6 +191,7 @@ public class ActiveMQStreamMessageTest extends ActiveMQTestBase {
    @Test
    public void testReadBytesFromEmptyMessage() throws Exception {
       doReadTypeFromEmptyMessage(new TypeReader() {
+         @Override
          public Object readType(final ActiveMQStreamMessage message) throws Exception {
             byte[] bytes = new byte[1];
             return message.readBytes(bytes);
@@ -227,6 +235,7 @@ public class ActiveMQStreamMessageTest extends ActiveMQTestBase {
    @Test
    public void testReadShortFromInvalidType() throws Exception {
       doReadTypeFromInvalidType(RandomUtil.randomFloat(), new TypeReader() {
+         @Override
          public Object readType(final ActiveMQStreamMessage message) throws Exception {
             return message.readShort();
          }
@@ -236,6 +245,7 @@ public class ActiveMQStreamMessageTest extends ActiveMQTestBase {
    @Test
    public void testReadShortFromEmptyMessage() throws Exception {
       doReadTypeFromEmptyMessage(new TypeReader() {
+         @Override
          public Object readType(final ActiveMQStreamMessage message) throws Exception {
             return message.readShort();
          }
@@ -289,6 +299,7 @@ public class ActiveMQStreamMessageTest extends ActiveMQTestBase {
    @Test
    public void testReadIntFromInvalidType() throws Exception {
       doReadTypeFromInvalidType(RandomUtil.randomFloat(), new TypeReader() {
+         @Override
          public Object readType(final ActiveMQStreamMessage message) throws Exception {
             return message.readInt();
          }
@@ -298,6 +309,7 @@ public class ActiveMQStreamMessageTest extends ActiveMQTestBase {
    @Test
    public void testReadIntFromEmptyMessage() throws Exception {
       doReadTypeFromEmptyMessage(new TypeReader() {
+         @Override
          public Object readType(final ActiveMQStreamMessage message) throws Exception {
             return message.readInt();
          }
@@ -388,6 +400,7 @@ public class ActiveMQStreamMessageTest extends ActiveMQTestBase {
    @Test
    public void testReadLongFromInvalidType() throws Exception {
       doReadTypeFromInvalidType(RandomUtil.randomFloat(), new TypeReader() {
+         @Override
          public Object readType(final ActiveMQStreamMessage message) throws Exception {
             return message.readLong();
          }
@@ -397,6 +410,7 @@ public class ActiveMQStreamMessageTest extends ActiveMQTestBase {
    @Test
    public void testReadLongFromEmptyMessage() throws Exception {
       doReadTypeFromEmptyMessage(new TypeReader() {
+         @Override
          public Object readType(final ActiveMQStreamMessage message) throws Exception {
             return message.readLong();
          }
@@ -428,6 +442,7 @@ public class ActiveMQStreamMessageTest extends ActiveMQTestBase {
    @Test
    public void testReadFloatFromInvalidType() throws Exception {
       doReadTypeFromInvalidType(RandomUtil.randomBoolean(), new TypeReader() {
+         @Override
          public Object readType(final ActiveMQStreamMessage message) throws Exception {
             return message.readFloat();
          }
@@ -437,6 +452,7 @@ public class ActiveMQStreamMessageTest extends ActiveMQTestBase {
    @Test
    public void testReadFloatFromEmptyMessage() throws Exception {
       doReadTypeFromEmptyMessage(new TypeReader() {
+         @Override
          public Object readType(final ActiveMQStreamMessage message) throws Exception {
             return message.readFloat();
          }
@@ -479,6 +495,7 @@ public class ActiveMQStreamMessageTest extends ActiveMQTestBase {
    @Test
    public void testReadDoubleFromInvalidType() throws Exception {
       doReadTypeFromInvalidType(RandomUtil.randomBoolean(), new TypeReader() {
+         @Override
          public Object readType(final ActiveMQStreamMessage message) throws Exception {
             return message.readDouble();
          }
@@ -488,6 +505,7 @@ public class ActiveMQStreamMessageTest extends ActiveMQTestBase {
    @Test
    public void testReadDoubleFromEmptyMessage() throws Exception {
       doReadTypeFromEmptyMessage(new TypeReader() {
+         @Override
          public Object readType(final ActiveMQStreamMessage message) throws Exception {
             return message.readDouble();
          }
@@ -625,6 +643,7 @@ public class ActiveMQStreamMessageTest extends ActiveMQTestBase {
    @Test
    public void testReadStringFromEmptyMessage() throws Exception {
       doReadTypeFromEmptyMessage(new TypeReader() {
+         @Override
          public Object readType(final ActiveMQStreamMessage message) throws Exception {
             return message.readString();
          }
@@ -634,6 +653,7 @@ public class ActiveMQStreamMessageTest extends ActiveMQTestBase {
    @Test
    public void testWriteObjectWithBoolean() throws Exception {
       doWriteObjectWithType(RandomUtil.randomBoolean(), new TypeReader() {
+         @Override
          public Object readType(final ActiveMQStreamMessage message) throws Exception {
             return message.readBoolean();
          }
@@ -643,6 +663,7 @@ public class ActiveMQStreamMessageTest extends ActiveMQTestBase {
    @Test
    public void testWriteObjectWithChar() throws Exception {
       doWriteObjectWithType(RandomUtil.randomChar(), new TypeReader() {
+         @Override
          public Object readType(final ActiveMQStreamMessage message) throws Exception {
             return message.readChar();
          }
@@ -652,6 +673,7 @@ public class ActiveMQStreamMessageTest extends ActiveMQTestBase {
    @Test
    public void testWriteObjectWithByte() throws Exception {
       doWriteObjectWithType(RandomUtil.randomByte(), new TypeReader() {
+         @Override
          public Object readType(final ActiveMQStreamMessage message) throws Exception {
             return message.readByte();
          }
@@ -662,6 +684,7 @@ public class ActiveMQStreamMessageTest extends ActiveMQTestBase {
    public void testWriteObjectWithBytes() throws Exception {
       final byte[] value = RandomUtil.randomBytes();
       doWriteObjectWithType(value, new TypeReader() {
+         @Override
          public Object readType(final ActiveMQStreamMessage message) throws Exception {
             byte[] bytes = new byte[value.length];
             message.readBytes(bytes);
@@ -673,6 +696,7 @@ public class ActiveMQStreamMessageTest extends ActiveMQTestBase {
    @Test
    public void testWriteObjectWithShort() throws Exception {
       doWriteObjectWithType(RandomUtil.randomShort(), new TypeReader() {
+         @Override
          public Object readType(final ActiveMQStreamMessage message) throws Exception {
             return message.readShort();
          }
@@ -682,6 +706,7 @@ public class ActiveMQStreamMessageTest extends ActiveMQTestBase {
    @Test
    public void testWriteObjectWithInt() throws Exception {
       doWriteObjectWithType(RandomUtil.randomInt(), new TypeReader() {
+         @Override
          public Object readType(final ActiveMQStreamMessage message) throws Exception {
             return message.readInt();
          }
@@ -691,6 +716,7 @@ public class ActiveMQStreamMessageTest extends ActiveMQTestBase {
    @Test
    public void testWriteObjectWithLong() throws Exception {
       doWriteObjectWithType(RandomUtil.randomLong(), new TypeReader() {
+         @Override
          public Object readType(final ActiveMQStreamMessage message) throws Exception {
             return message.readLong();
          }
@@ -700,6 +726,7 @@ public class ActiveMQStreamMessageTest extends ActiveMQTestBase {
    @Test
    public void testWriteObjectWithFloat() throws Exception {
       doWriteObjectWithType(RandomUtil.randomFloat(), new TypeReader() {
+         @Override
          public Object readType(final ActiveMQStreamMessage message) throws Exception {
             return message.readFloat();
          }
@@ -709,6 +736,7 @@ public class ActiveMQStreamMessageTest extends ActiveMQTestBase {
    @Test
    public void testWriteObjectWithDouble() throws Exception {
       doWriteObjectWithType(RandomUtil.randomDouble(), new TypeReader() {
+         @Override
          public Object readType(final ActiveMQStreamMessage message) throws Exception {
             return message.readDouble();
          }
@@ -718,6 +746,7 @@ public class ActiveMQStreamMessageTest extends ActiveMQTestBase {
    @Test
    public void testWriteObjectWithString() throws Exception {
       doWriteObjectWithType(RandomUtil.randomString(), new TypeReader() {
+         @Override
          public Object readType(final ActiveMQStreamMessage message) throws Exception {
             return message.readString();
          }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/ra/BootstrapContext.java
----------------------------------------------------------------------
diff --git a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/ra/BootstrapContext.java
b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/ra/BootstrapContext.java
index 30f385d..b69ec51 100644
--- a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/ra/BootstrapContext.java
+++ b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/ra/BootstrapContext.java
@@ -27,25 +27,31 @@ import java.util.Timer;
 
 public class BootstrapContext implements javax.resource.spi.BootstrapContext {
 
+   @Override
    public Timer createTimer() throws UnavailableException {
       return null;
    }
 
+   @Override
    public WorkManager getWorkManager() {
       return new WorkManager() {
+         @Override
          public void doWork(final Work work) throws WorkException {
          }
 
+         @Override
          public void doWork(final Work work,
                             final long l,
                             final ExecutionContext executionContext,
                             final WorkListener workListener) throws WorkException {
          }
 
+         @Override
          public long startWork(final Work work) throws WorkException {
             return 0;
          }
 
+         @Override
          public long startWork(final Work work,
                                final long l,
                                final ExecutionContext executionContext,
@@ -53,10 +59,12 @@ public class BootstrapContext implements javax.resource.spi.BootstrapContext
{
             return 0;
          }
 
+         @Override
          public void scheduleWork(final Work work) throws WorkException {
             work.run();
          }
 
+         @Override
          public void scheduleWork(final Work work,
                                   final long l,
                                   final ExecutionContext executionContext,
@@ -65,6 +73,7 @@ public class BootstrapContext implements javax.resource.spi.BootstrapContext
{
       };
    }
 
+   @Override
    public XATerminator getXATerminator() {
       return null;
    }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/FakePagingManager.java
----------------------------------------------------------------------
diff --git a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/FakePagingManager.java
b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/FakePagingManager.java
index e51252f..9faf307 100644
--- a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/FakePagingManager.java
+++ b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/FakePagingManager.java
@@ -35,6 +35,7 @@ public final class FakePagingManager implements PagingManager {
       return 0;
    }
 
+   @Override
    public void addTransaction(final PageTransactionInfo pageTransaction) {
    }
 
@@ -46,6 +47,7 @@ public final class FakePagingManager implements PagingManager {
       return 0;
    }
 
+   @Override
    public SimpleString[] getStoreNames() {
       return null;
    }
@@ -54,13 +56,16 @@ public final class FakePagingManager implements PagingManager {
       return 0;
    }
 
+   @Override
    public PagingStore getPageStore(final SimpleString address) throws Exception {
       return null;
    }
 
+   @Override
    public void deletePageStore(SimpleString storeName) throws Exception {
    }
 
+   @Override
    public PageTransactionInfo getTransaction(final long transactionID) {
       return null;
    }
@@ -87,9 +92,11 @@ public final class FakePagingManager implements PagingManager {
       return false;
    }
 
+   @Override
    public void reloadStores() throws Exception {
    }
 
+   @Override
    public void removeTransaction(final long transactionID) {
 
    }
@@ -106,13 +113,16 @@ public final class FakePagingManager implements PagingManager {
    public void sync(final Collection<SimpleString> destinationsToSync) throws Exception
{
    }
 
+   @Override
    public boolean isStarted() {
       return false;
    }
 
+   @Override
    public void start() throws Exception {
    }
 
+   @Override
    public void stop() throws Exception {
    }
 
@@ -128,6 +138,7 @@ public final class FakePagingManager implements PagingManager {
     * (non-Javadoc)
     * @see org.apache.activemq.artemis.core.paging.PagingManager#getTransactions()
     */
+   @Override
    public Map<Long, PageTransactionInfo> getTransactions() {
       return null;
    }
@@ -136,6 +147,7 @@ public final class FakePagingManager implements PagingManager {
     * (non-Javadoc)
     * @see org.apache.activemq.artemis.core.paging.PagingManager#processReload()
     */
+   @Override
    public void processReload() {
    }
 
@@ -151,6 +163,7 @@ public final class FakePagingManager implements PagingManager {
     * (non-Javadoc)
     * @see org.apache.activemq.artemis.core.settings.HierarchicalRepositoryChangeListener#onChange()
     */
+   @Override
    public void onChange() {
    }
 

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/InVMContext.java
----------------------------------------------------------------------
diff --git a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/InVMContext.java
b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/InVMContext.java
index 526f0fc..6d398f1 100644
--- a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/InVMContext.java
+++ b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/InVMContext.java
@@ -67,10 +67,12 @@ public class InVMContext implements Context, Serializable {
 
    // Context implementation ----------------------------------------
 
+   @Override
    public Object lookup(final Name name) throws NamingException {
       throw new UnsupportedOperationException();
    }
 
+   @Override
    public Object lookup(String name) throws NamingException {
       name = trimSlashes(name);
       int i = name.indexOf("/");
@@ -95,26 +97,32 @@ public class InVMContext implements Context, Serializable {
       }
    }
 
+   @Override
    public void bind(final Name name, final Object obj) throws NamingException {
       throw new UnsupportedOperationException();
    }
 
+   @Override
    public void bind(final String name, final Object obj) throws NamingException {
       internalBind(name, obj, false);
    }
 
+   @Override
    public void rebind(final Name name, final Object obj) throws NamingException {
       throw new UnsupportedOperationException();
    }
 
+   @Override
    public void rebind(final String name, final Object obj) throws NamingException {
       internalBind(name, obj, true);
    }
 
+   @Override
    public void unbind(final Name name) throws NamingException {
       unbind(name.toString());
    }
 
+   @Override
    public void unbind(String name) throws NamingException {
       name = trimSlashes(name);
       int i = name.indexOf("/");
@@ -132,26 +140,32 @@ public class InVMContext implements Context, Serializable {
       }
    }
 
+   @Override
    public void rename(final Name oldName, final Name newName) throws NamingException {
       throw new UnsupportedOperationException();
    }
 
+   @Override
    public void rename(final String oldName, final String newName) throws NamingException
{
       throw new UnsupportedOperationException();
    }
 
+   @Override
    public NamingEnumeration<NameClassPair> list(final Name name) throws NamingException
{
       throw new UnsupportedOperationException();
    }
 
+   @Override
    public NamingEnumeration<NameClassPair> list(final String name) throws NamingException
{
       throw new UnsupportedOperationException();
    }
 
+   @Override
    public NamingEnumeration<Binding> listBindings(final Name name) throws NamingException
{
       throw new UnsupportedOperationException();
    }
 
+   @Override
    public NamingEnumeration<Binding> listBindings(String contextName) throws NamingException
{
       contextName = trimSlashes(contextName);
       if (!"".equals(contextName) && !".".equals(contextName)) {
@@ -172,18 +186,22 @@ public class InVMContext implements Context, Serializable {
       return new NamingEnumerationImpl<Binding>(l.iterator());
    }
 
+   @Override
    public void destroySubcontext(final Name name) throws NamingException {
       destroySubcontext(name.toString());
    }
 
+   @Override
    public void destroySubcontext(final String name) throws NamingException {
       map.remove(trimSlashes(name));
    }
 
+   @Override
    public Context createSubcontext(final Name name) throws NamingException {
       throw new UnsupportedOperationException();
    }
 
+   @Override
    public Context createSubcontext(String name) throws NamingException {
       name = trimSlashes(name);
       if (map.get(name) != null) {
@@ -194,47 +212,58 @@ public class InVMContext implements Context, Serializable {
       return c;
    }
 
+   @Override
    public Object lookupLink(final Name name) throws NamingException {
       throw new UnsupportedOperationException();
    }
 
+   @Override
    public Object lookupLink(final String name) throws NamingException {
       throw new UnsupportedOperationException();
    }
 
+   @Override
    public NameParser getNameParser(final Name name) throws NamingException {
       return getNameParser(name.toString());
    }
 
+   @Override
    public NameParser getNameParser(final String name) throws NamingException {
       return parser;
    }
 
+   @Override
    public Name composeName(final Name name, final Name prefix) throws NamingException {
       throw new UnsupportedOperationException();
    }
 
+   @Override
    public String composeName(final String name, final String prefix) throws NamingException
{
       throw new UnsupportedOperationException();
    }
 
+   @Override
    public Object addToEnvironment(final String propName, final Object propVal) throws NamingException
{
       throw new UnsupportedOperationException();
    }
 
+   @Override
    public Object removeFromEnvironment(final String propName) throws NamingException {
       throw new UnsupportedOperationException();
    }
 
+   @Override
    public Hashtable<String, String> getEnvironment() throws NamingException {
       Hashtable<String, String> env = new Hashtable<String, String>();
       env.put("java.naming.factory.initial", "org.apache.activemq.artemis.jms.tests.tools.container.InVMInitialContextFactory");
       return env;
    }
 
+   @Override
    public void close() throws NamingException {
    }
 
+   @Override
    public String getNameInNamespace() throws NamingException {
       return nameInNamespace;
    }
@@ -292,22 +321,27 @@ public class InVMContext implements Context, Serializable {
          iterator = bindingIterator;
       }
 
+      @Override
       public void close() throws NamingException {
          throw new UnsupportedOperationException();
       }
 
+      @Override
       public boolean hasMore() throws NamingException {
          return iterator.hasNext();
       }
 
+      @Override
       public T next() throws NamingException {
          return iterator.next();
       }
 
+      @Override
       public boolean hasMoreElements() {
          return iterator.hasNext();
       }
 
+      @Override
       public T nextElement() {
          return iterator.next();
       }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/InVMNameParser.java
----------------------------------------------------------------------
diff --git a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/InVMNameParser.java
b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/InVMNameParser.java
index ebaaa62..059a646 100644
--- a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/InVMNameParser.java
+++ b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/InVMNameParser.java
@@ -50,6 +50,7 @@ public class InVMNameParser implements NameParser, Serializable {
       return InVMNameParser.syntax;
    }
 
+   @Override
    public Name parse(final String name) throws NamingException {
       return new CompoundName(name, InVMNameParser.syntax);
    }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/InVMNamingContext.java
----------------------------------------------------------------------
diff --git a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/InVMNamingContext.java
b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/InVMNamingContext.java
index 8b7df6d..b323902 100644
--- a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/InVMNamingContext.java
+++ b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/InVMNamingContext.java
@@ -67,10 +67,12 @@ public class InVMNamingContext implements Context, Serializable {
 
    // Context implementation ----------------------------------------
 
+   @Override
    public Object lookup(final Name name) throws NamingException {
       throw new UnsupportedOperationException();
    }
 
+   @Override
    public Object lookup(String name) throws NamingException {
       name = trimSlashes(name);
       int i = name.indexOf("/");
@@ -95,26 +97,32 @@ public class InVMNamingContext implements Context, Serializable {
       }
    }
 
+   @Override
    public void bind(final Name name, final Object obj) throws NamingException {
       throw new UnsupportedOperationException();
    }
 
+   @Override
    public void bind(final String name, final Object obj) throws NamingException {
       internalBind(name, obj, false);
    }
 
+   @Override
    public void rebind(final Name name, final Object obj) throws NamingException {
       throw new UnsupportedOperationException();
    }
 
+   @Override
    public void rebind(final String name, final Object obj) throws NamingException {
       internalBind(name, obj, true);
    }
 
+   @Override
    public void unbind(final Name name) throws NamingException {
       unbind(name.toString());
    }
 
+   @Override
    public void unbind(String name) throws NamingException {
       name = trimSlashes(name);
       int i = name.indexOf("/");
@@ -132,26 +140,32 @@ public class InVMNamingContext implements Context, Serializable {
       }
    }
 
+   @Override
    public void rename(final Name oldName, final Name newName) throws NamingException {
       throw new UnsupportedOperationException();
    }
 
+   @Override
    public void rename(final String oldName, final String newName) throws NamingException
{
       throw new UnsupportedOperationException();
    }
 
+   @Override
    public NamingEnumeration<NameClassPair> list(final Name name) throws NamingException
{
       throw new UnsupportedOperationException();
    }
 
+   @Override
    public NamingEnumeration<NameClassPair> list(final String name) throws NamingException
{
       throw new UnsupportedOperationException();
    }
 
+   @Override
    public NamingEnumeration<Binding> listBindings(final Name name) throws NamingException
{
       throw new UnsupportedOperationException();
    }
 
+   @Override
    public NamingEnumeration<Binding> listBindings(String contextName) throws NamingException
{
       contextName = trimSlashes(contextName);
       if (!"".equals(contextName) && !".".equals(contextName)) {
@@ -172,18 +186,22 @@ public class InVMNamingContext implements Context, Serializable {
       return new NamingEnumerationImpl<Binding>(l.iterator());
    }
 
+   @Override
    public void destroySubcontext(final Name name) throws NamingException {
       destroySubcontext(name.toString());
    }
 
+   @Override
    public void destroySubcontext(final String name) throws NamingException {
       map.remove(trimSlashes(name));
    }
 
+   @Override
    public Context createSubcontext(final Name name) throws NamingException {
       throw new UnsupportedOperationException();
    }
 
+   @Override
    public Context createSubcontext(String name) throws NamingException {
       name = trimSlashes(name);
       if (map.get(name) != null) {
@@ -194,47 +212,58 @@ public class InVMNamingContext implements Context, Serializable {
       return c;
    }
 
+   @Override
    public Object lookupLink(final Name name) throws NamingException {
       throw new UnsupportedOperationException();
    }
 
+   @Override
    public Object lookupLink(final String name) throws NamingException {
       throw new UnsupportedOperationException();
    }
 
+   @Override
    public NameParser getNameParser(final Name name) throws NamingException {
       return getNameParser(name.toString());
    }
 
+   @Override
    public NameParser getNameParser(final String name) throws NamingException {
       return parser;
    }
 
+   @Override
    public Name composeName(final Name name, final Name prefix) throws NamingException {
       throw new UnsupportedOperationException();
    }
 
+   @Override
    public String composeName(final String name, final String prefix) throws NamingException
{
       throw new UnsupportedOperationException();
    }
 
+   @Override
    public Object addToEnvironment(final String propName, final Object propVal) throws NamingException
{
       throw new UnsupportedOperationException();
    }
 
+   @Override
    public Object removeFromEnvironment(final String propName) throws NamingException {
       throw new UnsupportedOperationException();
    }
 
+   @Override
    public Hashtable<String, String> getEnvironment() throws NamingException {
       Hashtable<String, String> env = new Hashtable<String, String>();
       env.put("java.naming.factory.initial", "org.apache.activemq.artemis.jms.tests.tools.container.InVMInitialContextFactory");
       return env;
    }
 
+   @Override
    public void close() throws NamingException {
    }
 
+   @Override
    public String getNameInNamespace() throws NamingException {
       return nameInNamespace;
    }
@@ -292,22 +321,27 @@ public class InVMNamingContext implements Context, Serializable {
          iterator = bindingIterator;
       }
 
+      @Override
       public void close() throws NamingException {
          throw new UnsupportedOperationException();
       }
 
+      @Override
       public boolean hasMore() throws NamingException {
          return iterator.hasNext();
       }
 
+      @Override
       public T next() throws NamingException {
          return iterator.next();
       }
 
+      @Override
       public boolean hasMoreElements() {
          return iterator.hasNext();
       }
 
+      @Override
       public T nextElement() {
          return iterator.next();
       }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/MemorySizeTest.java
----------------------------------------------------------------------
diff --git a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/MemorySizeTest.java
b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/MemorySizeTest.java
index b6e08ef..052afaf 100644
--- a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/MemorySizeTest.java
+++ b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/MemorySizeTest.java
@@ -30,12 +30,14 @@ public class MemorySizeTest extends Assert {
    @Test
    public void testObjectSizes() throws Exception {
       UnitTestLogger.LOGGER.info("Server message size is " + MemorySize.calculateSize(new
MemorySize.ObjectFactory() {
+         @Override
          public Object createObject() {
             return new ServerMessageImpl(1, 1000);
          }
       }));
 
       UnitTestLogger.LOGGER.info("Message reference size is " + MemorySize.calculateSize(new
MemorySize.ObjectFactory() {
+         @Override
          public Object createObject() {
             return new MessageReferenceImpl();
          }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/NonSerializableFactory.java
----------------------------------------------------------------------
diff --git a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/NonSerializableFactory.java
b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/NonSerializableFactory.java
index a7d21d2..3b621ae 100644
--- a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/NonSerializableFactory.java
+++ b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/NonSerializableFactory.java
@@ -84,6 +84,7 @@ public class NonSerializableFactory implements ObjectFactory {
       return NonSerializableFactory.getWrapperMap().get(name);
    }
 
+   @Override
    public Object getObjectInstance(final Object obj,
                                    final Name name,
                                    final Context nameCtx,

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/ObjectInputStreamWithClassLoaderTest.java
----------------------------------------------------------------------
diff --git a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/ObjectInputStreamWithClassLoaderTest.java
b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/ObjectInputStreamWithClassLoaderTest.java
index 7592c15..8e45f5d 100644
--- a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/ObjectInputStreamWithClassLoaderTest.java
+++ b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/ObjectInputStreamWithClassLoaderTest.java
@@ -158,6 +158,7 @@ public class ObjectInputStreamWithClassLoaderTest extends ActiveMQTestBase
{
          }
       }
 
+      @Override
       public void run() {
 
          try {

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/SoftValueMapTest.java
----------------------------------------------------------------------
diff --git a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/SoftValueMapTest.java
b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/SoftValueMapTest.java
index 9e13967..8c0d042 100644
--- a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/SoftValueMapTest.java
+++ b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/SoftValueMapTest.java
@@ -123,6 +123,7 @@ public class SoftValueMapTest extends ActiveMQTestBase {
       /* (non-Javadoc)
        * @see org.apache.activemq.artemis.utils.SoftValueHashMap.ValueCache#isLive()
        */
+      @Override
       public boolean isLive() {
          return live;
       }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/util/SpawnedVMSupport.java
----------------------------------------------------------------------
diff --git a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/util/SpawnedVMSupport.java
b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/util/SpawnedVMSupport.java
index d7afaab..b88786c 100644
--- a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/util/SpawnedVMSupport.java
+++ b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/util/SpawnedVMSupport.java
@@ -163,6 +163,7 @@ public final class SpawnedVMSupport {
       ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor();
       Future<Integer> future = executor.submit(new Callable<Integer>() {
 
+         @Override
          public Integer call() throws Exception {
             p.waitFor();
             return p.exitValue();


Mime
View raw message