Return-Path: X-Original-To: apmail-activemq-commits-archive@www.apache.org Delivered-To: apmail-activemq-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 8341C1896F for ; Mon, 7 Dec 2015 18:39:23 +0000 (UTC) Received: (qmail 99713 invoked by uid 500); 7 Dec 2015 18:39:17 -0000 Delivered-To: apmail-activemq-commits-archive@activemq.apache.org Received: (qmail 99646 invoked by uid 500); 7 Dec 2015 18:39:17 -0000 Mailing-List: contact commits-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@activemq.apache.org Delivered-To: mailing list commits@activemq.apache.org Received: (qmail 97809 invoked by uid 99); 7 Dec 2015 18:39:14 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 07 Dec 2015 18:39:14 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 0CADFE08DB; Mon, 7 Dec 2015 18:39:14 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: clebertsuconic@apache.org To: commits@activemq.apache.org Date: Mon, 07 Dec 2015 18:39:34 -0000 Message-Id: <6ac6040727a14793b22cf8d2ad5d3e38@git.apache.org> In-Reply-To: <5f1541ce95584d48bf47f02f5e930ed0@git.apache.org> References: <5f1541ce95584d48bf47f02f5e930ed0@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [22/42] activemq-artemis git commit: Add missing @Override annotations http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/amq1974/TryJmsManager.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/amq1974/TryJmsManager.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/amq1974/TryJmsManager.java index fe2ceaa..91ca459 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/amq1974/TryJmsManager.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/amq1974/TryJmsManager.java @@ -65,6 +65,7 @@ public class TryJmsManager { private void startUsageMonitor(final BrokerService brokerService) { new Thread(new Runnable() { + @Override public void run() { while (true) { try { @@ -108,6 +109,7 @@ public class TryJmsManager { MessageConsumer consumer = session.createConsumer(dest); consumer.setMessageListener(new MessageListener() { + @Override public void onMessage(Message message) { try { System.out.println("got message " + message.getJMSMessageID()); http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/command/ActiveMQBytesMessageTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/command/ActiveMQBytesMessageTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/command/ActiveMQBytesMessageTest.java index 9d51fea..7551258 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/command/ActiveMQBytesMessageTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/command/ActiveMQBytesMessageTest.java @@ -39,6 +39,7 @@ public class ActiveMQBytesMessageTest extends TestCase { /* * @see TestCase#setUp() */ + @Override protected void setUp() throws Exception { super.setUp(); } @@ -46,6 +47,7 @@ public class ActiveMQBytesMessageTest extends TestCase { /* * @see TestCase#tearDown() */ + @Override protected void tearDown() throws Exception { super.tearDown(); } http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/command/ActiveMQDestinationTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/command/ActiveMQDestinationTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/command/ActiveMQDestinationTest.java index 9fa4e39..46ede44 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/command/ActiveMQDestinationTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/command/ActiveMQDestinationTest.java @@ -75,13 +75,16 @@ public class ActiveMQDestinationTest extends DataStructureTestSupport { this.topicName = topicName; } + @Override public void delete() throws JMSException { } + @Override public String getTopicName() throws JMSException { return topicName; } + @Override public String getQueueName() throws JMSException { return qName; } http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/command/ActiveMQMapMessageTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/command/ActiveMQMapMessageTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/command/ActiveMQMapMessageTest.java index 117c852..4bc17a9 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/command/ActiveMQMapMessageTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/command/ActiveMQMapMessageTest.java @@ -58,6 +58,7 @@ public class ActiveMQMapMessageTest extends TestCase { /* * @see TestCase#setUp() */ + @Override protected void setUp() throws Exception { super.setUp(); } @@ -65,6 +66,7 @@ public class ActiveMQMapMessageTest extends TestCase { /* * @see TestCase#tearDown() */ + @Override protected void tearDown() throws Exception { super.tearDown(); } http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/command/ActiveMQObjectMessageTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/command/ActiveMQObjectMessageTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/command/ActiveMQObjectMessageTest.java index 4a2f6bc..94f0d93 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/command/ActiveMQObjectMessageTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/command/ActiveMQObjectMessageTest.java @@ -45,6 +45,7 @@ public class ActiveMQObjectMessageTest extends TestCase { /* * @see TestCase#setUp() */ + @Override protected void setUp() throws Exception { super.setUp(); } @@ -52,6 +53,7 @@ public class ActiveMQObjectMessageTest extends TestCase { /* * @see TestCase#tearDown() */ + @Override protected void tearDown() throws Exception { super.tearDown(); } http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/command/ActiveMQStreamMessageTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/command/ActiveMQStreamMessageTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/command/ActiveMQStreamMessageTest.java index 757fb7f..34ceb14 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/command/ActiveMQStreamMessageTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/command/ActiveMQStreamMessageTest.java @@ -46,6 +46,7 @@ public class ActiveMQStreamMessageTest extends TestCase { /* * @see TestCase#setUp() */ + @Override protected void setUp() throws Exception { super.setUp(); } @@ -53,6 +54,7 @@ public class ActiveMQStreamMessageTest extends TestCase { /* * @see TestCase#tearDown() */ + @Override protected void tearDown() throws Exception { super.tearDown(); } http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/command/DataStructureTestSupport.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/command/DataStructureTestSupport.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/command/DataStructureTestSupport.java index 074ebe4..6cdee06 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/command/DataStructureTestSupport.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/command/DataStructureTestSupport.java @@ -149,6 +149,7 @@ public abstract class DataStructureTestSupport extends CombinationTestSupport { } } + @Override protected void setUp() throws Exception { wireFormat = createWireFormat(); super.setUp(); http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/command/MessageCompressionTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/command/MessageCompressionTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/command/MessageCompressionTest.java index fc4182b..4a3ba42 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/command/MessageCompressionTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/command/MessageCompressionTest.java @@ -43,6 +43,7 @@ public class MessageCompressionTest extends TestCase { private ActiveMQQueue queue; private String connectionUri; + @Override protected void setUp() throws Exception { broker = new BrokerService(); connectionUri = broker.addConnector(BROKER_URL).getPublishableConnectString(); @@ -50,6 +51,7 @@ public class MessageCompressionTest extends TestCase { queue = new ActiveMQQueue("TEST." + System.currentTimeMillis()); } + @Override protected void tearDown() throws Exception { if (broker != null) { broker.stop(); http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/config/BrokerXmlConfigTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/config/BrokerXmlConfigTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/config/BrokerXmlConfigTest.java index 0e52c78..b93babc 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/config/BrokerXmlConfigTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/config/BrokerXmlConfigTest.java @@ -24,6 +24,7 @@ import org.apache.activemq.test.JmsTopicSendReceiveWithTwoConnectionsTest; */ public class BrokerXmlConfigTest extends JmsTopicSendReceiveWithTwoConnectionsTest { + @Override protected ActiveMQConnectionFactory createConnectionFactory() throws Exception { // START SNIPPET: bean http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/console/command/AMQ3410Test.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/console/command/AMQ3410Test.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/console/command/AMQ3410Test.java index 6be65ce..6ba38ef 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/console/command/AMQ3410Test.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/console/command/AMQ3410Test.java @@ -42,6 +42,7 @@ public class AMQ3410Test extends TestCase { protected AbstractApplicationContext context; + @Override protected void setUp() throws Exception { super.setUp(); @@ -53,6 +54,7 @@ public class AMQ3410Test extends TestCase { return new ClassPathXmlApplicationContext("org/apache/activemq/console/command/activemq.xml"); } + @Override protected void tearDown() throws Exception { BrokerService broker = (BrokerService) context.getBean("localbroker"); broker.stop(); http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/console/command/AMQ3411Test.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/console/command/AMQ3411Test.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/console/command/AMQ3411Test.java index 9db2af0..dc307cb 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/console/command/AMQ3411Test.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/console/command/AMQ3411Test.java @@ -41,6 +41,7 @@ public class AMQ3411Test extends TestCase { protected AbstractApplicationContext context; protected static final String origPassword = "ABCDEFG"; + @Override protected void setUp() throws Exception { super.setUp(); @@ -52,6 +53,7 @@ public class AMQ3411Test extends TestCase { return new ClassPathXmlApplicationContext("org/apache/activemq/console/command/activemq.xml"); } + @Override protected void tearDown() throws Exception { BrokerService broker = (BrokerService) context.getBean("localbroker"); broker.stop(); http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/filter/DummyPolicyEntry.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/filter/DummyPolicyEntry.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/filter/DummyPolicyEntry.java index b15ff38..547d2c9 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/filter/DummyPolicyEntry.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/filter/DummyPolicyEntry.java @@ -32,6 +32,7 @@ public class DummyPolicyEntry extends DestinationMapEntry { this.description = description; } + @Override public Comparable getValue() { return description; } http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/jndi/XAConnectionFactoryTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/jndi/XAConnectionFactoryTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/jndi/XAConnectionFactoryTest.java index df3c564..801c475 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/jndi/XAConnectionFactoryTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/jndi/XAConnectionFactoryTest.java @@ -25,6 +25,7 @@ public class XAConnectionFactoryTest extends ActiveMQInitialContextFactoryTest { assertTrue("connection factory implements XA", context.lookup(getConnectionFactoryLookupName()) instanceof XAConnectionFactory); } + @Override protected void configureEnvironment() { environment.put("xa", "true"); super.configureEnvironment(); http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/joramtests/ActiveMQAdmin.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/joramtests/ActiveMQAdmin.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/joramtests/ActiveMQAdmin.java index c8472c5..d5109d9 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/joramtests/ActiveMQAdmin.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/joramtests/ActiveMQAdmin.java @@ -57,12 +57,14 @@ public class ActiveMQAdmin implements Admin { return BrokerFactory.createBroker(new URI("broker://()/localhost?persistent=false")); } + @Override public String getName() { return getClass().getName(); } BrokerService broker; + @Override public void startServer() throws Exception { if (System.getProperty("basedir") == null) { File file = new File("."); @@ -72,20 +74,25 @@ public class ActiveMQAdmin implements Admin { broker.start(); } + @Override public void stopServer() throws Exception { broker.stop(); } + @Override public void start() throws Exception { } + @Override public void stop() throws Exception { } + @Override public Context createContext() throws NamingException { return context; } + @Override public void createQueue(String name) { try { context.bind(name, new ActiveMQQueue(name)); @@ -95,6 +102,7 @@ public class ActiveMQAdmin implements Admin { } } + @Override public void createTopic(String name) { try { context.bind(name, new ActiveMQTopic(name)); @@ -104,6 +112,7 @@ public class ActiveMQAdmin implements Admin { } } + @Override public void deleteQueue(String name) { // BrokerTestSupport.delete_queue((Broker)base.broker, name); try { @@ -114,6 +123,7 @@ public class ActiveMQAdmin implements Admin { } } + @Override public void deleteTopic(String name) { try { context.unbind(name); @@ -123,6 +133,7 @@ public class ActiveMQAdmin implements Admin { } } + @Override public void createConnectionFactory(String name) { try { final ConnectionFactory factory = new ActiveMQConnectionFactory("vm://localhost"); @@ -134,6 +145,7 @@ public class ActiveMQAdmin implements Admin { } } + @Override public void deleteConnectionFactory(String name) { try { context.unbind(name); @@ -143,18 +155,22 @@ public class ActiveMQAdmin implements Admin { } } + @Override public void createQueueConnectionFactory(String name) { createConnectionFactory(name); } + @Override public void createTopicConnectionFactory(String name) { createConnectionFactory(name); } + @Override public void deleteQueueConnectionFactory(String name) { deleteConnectionFactory(name); } + @Override public void deleteTopicConnectionFactory(String name) { deleteConnectionFactory(name); } http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/load/LoadClient.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/load/LoadClient.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/load/LoadClient.java index e272f8f..4a0146c 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/load/LoadClient.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/load/LoadClient.java @@ -85,6 +85,7 @@ public class LoadClient implements Runnable { } } + @Override public void run() { try { while (running) { http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/load/LoadTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/load/LoadTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/load/LoadTest.java index 9657522..2d9443d 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/load/LoadTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/load/LoadTest.java @@ -58,6 +58,7 @@ public class LoadTest extends TestCase { * * @see junit.framework.TestCase#setUp() */ + @Override protected void setUp() throws Exception { if (broker == null) { broker = createBroker(bindAddress); @@ -105,6 +106,7 @@ public class LoadTest extends TestCase { super.setUp(); } + @Override protected void tearDown() throws Exception { super.tearDown(); managementConnection.close(); http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/management/BoundedRangeStatisticTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/management/BoundedRangeStatisticTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/management/BoundedRangeStatisticTest.java index e02976f..ded835b 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/management/BoundedRangeStatisticTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/management/BoundedRangeStatisticTest.java @@ -26,6 +26,7 @@ public class BoundedRangeStatisticTest extends RangeStatisticTest { * * @throws Exception */ + @Override public void testStatistic() throws Exception { BoundedRangeStatisticImpl stat = new BoundedRangeStatisticImpl("myRange", "millis", "myDescription", 10, 3000); assertStatistic(stat, "myRange", "millis", "myDescription"); http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/memory/buffer/DummyMessage.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/memory/buffer/DummyMessage.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/memory/buffer/DummyMessage.java index 2cf1f68..368b971 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/memory/buffer/DummyMessage.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/memory/buffer/DummyMessage.java @@ -29,10 +29,12 @@ public class DummyMessage extends ActiveMQMessage { this.size = size; } + @Override public int getSize() { return size; } + @Override public String toString() { return "DummyMessage[id=" + getMessageId() + " size=" + size + "]"; } http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/memory/buffer/MemoryBufferTestSupport.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/memory/buffer/MemoryBufferTestSupport.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/memory/buffer/MemoryBufferTestSupport.java index 120a934..9ddfc65 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/memory/buffer/MemoryBufferTestSupport.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/memory/buffer/MemoryBufferTestSupport.java @@ -40,6 +40,7 @@ public abstract class MemoryBufferTestSupport extends TestCase { protected abstract MessageBuffer createMessageBuffer(); + @Override protected void setUp() throws Exception { buffer = createMessageBuffer(); qA = buffer.createMessageQueue(); http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/memory/buffer/OrderBasedMemoryBufferTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/memory/buffer/OrderBasedMemoryBufferTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/memory/buffer/OrderBasedMemoryBufferTest.java index 3530976..b89b0a5 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/memory/buffer/OrderBasedMemoryBufferTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/memory/buffer/OrderBasedMemoryBufferTest.java @@ -66,6 +66,7 @@ public class OrderBasedMemoryBufferTest extends MemoryBufferTestSupport { assertEquals("qC", 20, qC.getSize()); } + @Override protected MessageBuffer createMessageBuffer() { return new OrderBasedMessageBuffer(40); } http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/memory/buffer/SizeBasedMessageBufferTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/memory/buffer/SizeBasedMessageBufferTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/memory/buffer/SizeBasedMessageBufferTest.java index eea4f1f..ed7575e 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/memory/buffer/SizeBasedMessageBufferTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/memory/buffer/SizeBasedMessageBufferTest.java @@ -49,6 +49,7 @@ public class SizeBasedMessageBufferTest extends MemoryBufferTestSupport { assertEquals("qC", 20, qC.getSize()); } + @Override protected MessageBuffer createMessageBuffer() { return new SizeBasedMessageBuffer(40); } http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/DemandForwardingBridgeFilterTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/DemandForwardingBridgeFilterTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/DemandForwardingBridgeFilterTest.java index 76ebe70..dacc9f0 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/DemandForwardingBridgeFilterTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/DemandForwardingBridgeFilterTest.java @@ -142,6 +142,7 @@ public class DemandForwardingBridgeFilterTest extends NetworkTestSupport { return m; } + @Override protected void setUp() throws Exception { super.setUp(); @@ -160,6 +161,7 @@ public class DemandForwardingBridgeFilterTest extends NetworkTestSupport { consumerConnection.send(consumerSessionInfo); } + @Override protected void tearDown() throws Exception { bridge.stop(); super.tearDown(); http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/ForwardingBridgeTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/ForwardingBridgeTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/ForwardingBridgeTest.java index 411ac1b..30df2b4 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/ForwardingBridgeTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/ForwardingBridgeTest.java @@ -128,6 +128,7 @@ public class ForwardingBridgeTest extends NetworkTestSupport { assertNotNull(m); } + @Override protected void setUp() throws Exception { super.setUp(); bridge = new ForwardingBridge(createTransport(), createRemoteTransport()); @@ -136,6 +137,7 @@ public class ForwardingBridgeTest extends NetworkTestSupport { bridge.start(); } + @Override protected void tearDown() throws Exception { bridge.stop(); super.tearDown(); http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/MulticastNetworkTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/MulticastNetworkTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/MulticastNetworkTest.java index 81901fa..0bf10d4 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/MulticastNetworkTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/MulticastNetworkTest.java @@ -21,10 +21,12 @@ package org.apache.activemq.network; */ public class MulticastNetworkTest extends SimpleNetworkTest { + @Override protected String getRemoteBrokerURI() { return "org/apache/activemq/network/multicast/remoteBroker.xml"; } + @Override protected String getLocalBrokerURI() { return "org/apache/activemq/network/multicast/localBroker.xml"; } http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/NetworkLoadTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/NetworkLoadTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/NetworkLoadTest.java index 389bdfd..0a8ed30 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/NetworkLoadTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/NetworkLoadTest.java @@ -91,6 +91,7 @@ public class NetworkLoadTest extends TestCase { MessageConsumer consumer = fromSession.createConsumer(new ActiveMQQueue("Q" + from)); consumer.setMessageListener(new MessageListener() { + @Override public void onMessage(Message msg) { try { producer.send(msg); @@ -122,6 +123,7 @@ public class NetworkLoadTest extends TestCase { private BrokerService[] brokers; private ForwardingClient[] forwardingClients; + @Override protected void setUp() throws Exception { groupId = "network-load-test-" + System.currentTimeMillis(); brokers = new BrokerService[BROKER_COUNT]; @@ -143,6 +145,7 @@ public class NetworkLoadTest extends TestCase { } } + @Override protected void tearDown() throws Exception { for (int i = 0; i < forwardingClients.length; i++) { LOG.info("Stoping fowarding client " + i); @@ -234,6 +237,7 @@ public class NetworkLoadTest extends TestCase { // Setup the consumer.. consumer.setMessageListener(new MessageListener() { + @Override public void onMessage(Message msg) { ActiveMQTextMessage m = (ActiveMQTextMessage) msg; ActiveMQTextMessage last = lastMessageReceived.get(); http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/NetworkReconnectTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/NetworkReconnectTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/NetworkReconnectTest.java index 1984a1f..34d779e 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/NetworkReconnectTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/NetworkReconnectTest.java @@ -183,6 +183,7 @@ public class NetworkReconnectTest extends TestCase { } + @Override protected void setUp() throws Exception { LOG.info("==============================================================================="); @@ -195,6 +196,7 @@ public class NetworkReconnectTest extends TestCase { } + @Override protected void tearDown() throws Exception { disposeConsumerConnections(); try { @@ -300,6 +302,7 @@ public class NetworkReconnectTest extends TestCase { ConsumerEventSource source = new ConsumerEventSource(connection, destination); source.setConsumerListener(new ConsumerListener() { + @Override public void onConsumerEvent(ConsumerEvent event) { rc.set(event.getConsumerCount()); } http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/NetworkRestartTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/NetworkRestartTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/NetworkRestartTest.java index f34451f..d100c54 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/NetworkRestartTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/NetworkRestartTest.java @@ -106,12 +106,14 @@ public class NetworkRestartTest extends TestSupport { assertEquals("after", ((TextMessage) after).getText()); } + @Override protected void setUp() throws Exception { setAutoFail(true); super.setUp(); doSetUp(); } + @Override protected void tearDown() throws Exception { localBroker.deleteAllMessages(); remoteBroker.deleteAllMessages(); http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/jms/QueueBridgeTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/jms/QueueBridgeTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/jms/QueueBridgeTest.java index 274fe0c..9355714 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/jms/QueueBridgeTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/jms/QueueBridgeTest.java @@ -50,6 +50,7 @@ public class QueueBridgeTest extends TestCase implements MessageListener { protected MessageConsumer requestServerConsumer; protected MessageProducer requestServerProducer; + @Override protected void setUp() throws Exception { super.setUp(); context = createApplicationContext(); @@ -80,6 +81,7 @@ public class QueueBridgeTest extends TestCase implements MessageListener { return new ClassPathXmlApplicationContext("org/apache/activemq/network/jms/queue-config.xml"); } + @Override protected void tearDown() throws Exception { localConnection.close(); super.tearDown(); @@ -94,6 +96,7 @@ public class QueueBridgeTest extends TestCase implements MessageListener { } } + @Override public void onMessage(Message msg) { try { TextMessage textMsg = (TextMessage) msg; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/jms/QueueBridgeXBeanTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/jms/QueueBridgeXBeanTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/jms/QueueBridgeXBeanTest.java index 1691af1..120792c 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/jms/QueueBridgeXBeanTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/jms/QueueBridgeXBeanTest.java @@ -25,6 +25,7 @@ import org.springframework.context.support.AbstractApplicationContext; */ public class QueueBridgeXBeanTest extends QueueBridgeTest { + @Override protected AbstractApplicationContext createApplicationContext() { return new ClassPathXmlApplicationContext("org/apache/activemq/network/jms/queue-xbean.xml"); } http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/jms/TopicBridgeSpringTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/jms/TopicBridgeSpringTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/jms/TopicBridgeSpringTest.java index e40db2d..bd33362 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/jms/TopicBridgeSpringTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/jms/TopicBridgeSpringTest.java @@ -50,6 +50,7 @@ public class TopicBridgeSpringTest extends TestCase implements MessageListener { protected MessageConsumer requestServerConsumer; protected MessageProducer requestServerProducer; + @Override protected void setUp() throws Exception { super.setUp(); @@ -74,6 +75,7 @@ public class TopicBridgeSpringTest extends TestCase implements MessageListener { return new ClassPathXmlApplicationContext("org/apache/activemq/network/jms/topic-spring.xml"); } + @Override protected void tearDown() throws Exception { localConnection.close(); super.tearDown(); @@ -89,6 +91,7 @@ public class TopicBridgeSpringTest extends TestCase implements MessageListener { } } + @Override public void onMessage(Message msg) { try { TextMessage textMsg = (TextMessage) msg; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/jms/TopicBridgeXBeanTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/jms/TopicBridgeXBeanTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/jms/TopicBridgeXBeanTest.java index c4b0bd3..747d59c 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/jms/TopicBridgeXBeanTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/network/jms/TopicBridgeXBeanTest.java @@ -25,6 +25,7 @@ import org.springframework.context.support.AbstractApplicationContext; */ public class TopicBridgeXBeanTest extends TopicBridgeSpringTest { + @Override protected AbstractApplicationContext createApplicationContext() { return new ClassPathXmlApplicationContext("org/apache/activemq/network/jms/topic-config.xml"); } http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/BrokerInfoData.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/BrokerInfoData.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/BrokerInfoData.java index e289115..6b4e090 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/BrokerInfoData.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/BrokerInfoData.java @@ -21,6 +21,7 @@ import org.apache.activemq.command.BrokerInfo; public class BrokerInfoData extends DataFileGenerator { + @Override protected Object createObject() { BrokerInfo rc = new BrokerInfo(); rc.setResponseRequired(false); http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/WireFormatInfoData.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/WireFormatInfoData.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/WireFormatInfoData.java index c396abb..c968939 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/WireFormatInfoData.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/WireFormatInfoData.java @@ -22,6 +22,7 @@ import org.apache.activemq.command.WireFormatInfo; public class WireFormatInfoData extends DataFileGenerator { + @Override protected Object createObject() throws IOException { WireFormatInfo rc = new WireFormatInfo(); rc.setResponseRequired(false); http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQBytesMessageTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQBytesMessageTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQBytesMessageTest.java index 81ccac0..1a4fcf7 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQBytesMessageTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQBytesMessageTest.java @@ -30,12 +30,14 @@ public class ActiveMQBytesMessageTest extends ActiveMQMessageTest { public static final ActiveMQBytesMessageTest SINGLETON = new ActiveMQBytesMessageTest(); + @Override public Object createObject() throws Exception { ActiveMQBytesMessage info = new ActiveMQBytesMessage(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); ActiveMQBytesMessage info = (ActiveMQBytesMessage) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQDestinationTestSupport.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQDestinationTestSupport.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQDestinationTestSupport.java index 90cec8b..4c5a0db 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQDestinationTestSupport.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQDestinationTestSupport.java @@ -29,6 +29,7 @@ import org.apache.activemq.openwire.DataFileGeneratorTestSupport; */ public abstract class ActiveMQDestinationTestSupport extends DataFileGeneratorTestSupport { + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); ActiveMQDestination info = (ActiveMQDestination) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQMapMessageTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQMapMessageTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQMapMessageTest.java index 48662a5..f9ec5d1 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQMapMessageTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQMapMessageTest.java @@ -30,12 +30,14 @@ public class ActiveMQMapMessageTest extends ActiveMQMessageTest { public static final ActiveMQMapMessageTest SINGLETON = new ActiveMQMapMessageTest(); + @Override public Object createObject() throws Exception { ActiveMQMapMessage info = new ActiveMQMapMessage(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); ActiveMQMapMessage info = (ActiveMQMapMessage) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQMessageTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQMessageTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQMessageTest.java index df78d73..bac2c53 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQMessageTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQMessageTest.java @@ -30,12 +30,14 @@ public class ActiveMQMessageTest extends MessageTestSupport { public static final ActiveMQMessageTest SINGLETON = new ActiveMQMessageTest(); + @Override public Object createObject() throws Exception { ActiveMQMessage info = new ActiveMQMessage(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); ActiveMQMessage info = (ActiveMQMessage) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQObjectMessageTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQObjectMessageTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQObjectMessageTest.java index 7dd20c0..d67cb6e 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQObjectMessageTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQObjectMessageTest.java @@ -30,12 +30,14 @@ public class ActiveMQObjectMessageTest extends ActiveMQMessageTest { public static final ActiveMQObjectMessageTest SINGLETON = new ActiveMQObjectMessageTest(); + @Override public Object createObject() throws Exception { ActiveMQObjectMessage info = new ActiveMQObjectMessage(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); ActiveMQObjectMessage info = (ActiveMQObjectMessage) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQQueueTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQQueueTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQQueueTest.java index 09427c7..8b57bcf 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQQueueTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQQueueTest.java @@ -28,12 +28,14 @@ public class ActiveMQQueueTest extends ActiveMQDestinationTestSupport { public static final ActiveMQQueueTest SINGLETON = new ActiveMQQueueTest(); + @Override public Object createObject() throws Exception { ActiveMQQueue info = new ActiveMQQueue(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); ActiveMQQueue info = (ActiveMQQueue) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQStreamMessageTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQStreamMessageTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQStreamMessageTest.java index d69f80a..3af498d 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQStreamMessageTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQStreamMessageTest.java @@ -28,12 +28,14 @@ public class ActiveMQStreamMessageTest extends ActiveMQMessageTest { public static final ActiveMQStreamMessageTest SINGLETON = new ActiveMQStreamMessageTest(); + @Override public Object createObject() throws Exception { ActiveMQStreamMessage info = new ActiveMQStreamMessage(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); ActiveMQStreamMessage info = (ActiveMQStreamMessage) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQTempDestinationTestSupport.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQTempDestinationTestSupport.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQTempDestinationTestSupport.java index c486dba..816715a 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQTempDestinationTestSupport.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQTempDestinationTestSupport.java @@ -26,6 +26,7 @@ import org.apache.activemq.command.ActiveMQTempDestination; */ public abstract class ActiveMQTempDestinationTestSupport extends ActiveMQDestinationTestSupport { + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); ActiveMQTempDestination info = (ActiveMQTempDestination) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQTempQueueTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQTempQueueTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQTempQueueTest.java index 60c5342..20f6f26 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQTempQueueTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQTempQueueTest.java @@ -28,12 +28,14 @@ public class ActiveMQTempQueueTest extends ActiveMQTempDestinationTestSupport { public static final ActiveMQTempQueueTest SINGLETON = new ActiveMQTempQueueTest(); + @Override public Object createObject() throws Exception { ActiveMQTempQueue info = new ActiveMQTempQueue(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); ActiveMQTempQueue info = (ActiveMQTempQueue) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQTempTopicTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQTempTopicTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQTempTopicTest.java index 8e6d048..d06c2f8 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQTempTopicTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQTempTopicTest.java @@ -28,12 +28,14 @@ public class ActiveMQTempTopicTest extends ActiveMQTempDestinationTestSupport { public static final ActiveMQTempTopicTest SINGLETON = new ActiveMQTempTopicTest(); + @Override public Object createObject() throws Exception { ActiveMQTempTopic info = new ActiveMQTempTopic(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); ActiveMQTempTopic info = (ActiveMQTempTopic) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQTextMessageTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQTextMessageTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQTextMessageTest.java index 56fef8e..402c9e1 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQTextMessageTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQTextMessageTest.java @@ -28,12 +28,14 @@ public class ActiveMQTextMessageTest extends ActiveMQMessageTest { public static final ActiveMQTextMessageTest SINGLETON = new ActiveMQTextMessageTest(); + @Override public Object createObject() throws Exception { ActiveMQTextMessage info = new ActiveMQTextMessage(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); ActiveMQTextMessage info = (ActiveMQTextMessage) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQTopicTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQTopicTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQTopicTest.java index e85b5bc..fe8f74a 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQTopicTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ActiveMQTopicTest.java @@ -28,12 +28,14 @@ public class ActiveMQTopicTest extends ActiveMQDestinationTestSupport { public static final ActiveMQTopicTest SINGLETON = new ActiveMQTopicTest(); + @Override public Object createObject() throws Exception { ActiveMQTopic info = new ActiveMQTopic(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); ActiveMQTopic info = (ActiveMQTopic) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/BaseCommandTestSupport.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/BaseCommandTestSupport.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/BaseCommandTestSupport.java index befa49a..86357bd 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/BaseCommandTestSupport.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/BaseCommandTestSupport.java @@ -27,6 +27,7 @@ import org.apache.activemq.openwire.DataFileGeneratorTestSupport; */ public abstract class BaseCommandTestSupport extends DataFileGeneratorTestSupport { + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); BaseCommand info = (BaseCommand) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/BrokerIdTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/BrokerIdTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/BrokerIdTest.java index 798646f..2db742c 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/BrokerIdTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/BrokerIdTest.java @@ -31,12 +31,14 @@ public class BrokerIdTest extends DataFileGeneratorTestSupport { public static final BrokerIdTest SINGLETON = new BrokerIdTest(); + @Override public Object createObject() throws Exception { BrokerId info = new BrokerId(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); BrokerId info = (BrokerId) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/BrokerInfoTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/BrokerInfoTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/BrokerInfoTest.java index 010edc9..cd1bc98 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/BrokerInfoTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/BrokerInfoTest.java @@ -28,12 +28,14 @@ public class BrokerInfoTest extends BaseCommandTestSupport { public static final BrokerInfoTest SINGLETON = new BrokerInfoTest(); + @Override public Object createObject() throws Exception { BrokerInfo info = new BrokerInfo(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); BrokerInfo info = (BrokerInfo) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ConnectionControlTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ConnectionControlTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ConnectionControlTest.java index 207359f..de4f29e 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ConnectionControlTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ConnectionControlTest.java @@ -30,12 +30,14 @@ public class ConnectionControlTest extends BaseCommandTestSupport { public static final ConnectionControlTest SINGLETON = new ConnectionControlTest(); + @Override public Object createObject() throws Exception { ConnectionControl info = new ConnectionControl(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); ConnectionControl info = (ConnectionControl) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ConnectionErrorTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ConnectionErrorTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ConnectionErrorTest.java index aaa399e..5acd495 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ConnectionErrorTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ConnectionErrorTest.java @@ -30,12 +30,14 @@ public class ConnectionErrorTest extends BaseCommandTestSupport { public static final ConnectionErrorTest SINGLETON = new ConnectionErrorTest(); + @Override public Object createObject() throws Exception { ConnectionError info = new ConnectionError(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); ConnectionError info = (ConnectionError) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ConnectionIdTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ConnectionIdTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ConnectionIdTest.java index 105910f..0ea97ea 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ConnectionIdTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ConnectionIdTest.java @@ -31,12 +31,14 @@ public class ConnectionIdTest extends DataFileGeneratorTestSupport { public static final ConnectionIdTest SINGLETON = new ConnectionIdTest(); + @Override public Object createObject() throws Exception { ConnectionId info = new ConnectionId(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); ConnectionId info = (ConnectionId) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ConnectionInfoTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ConnectionInfoTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ConnectionInfoTest.java index 784052c..3c1e8fa 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ConnectionInfoTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ConnectionInfoTest.java @@ -29,12 +29,14 @@ public class ConnectionInfoTest extends BaseCommandTestSupport { public static final ConnectionInfoTest SINGLETON = new ConnectionInfoTest(); + @Override public Object createObject() throws Exception { ConnectionInfo info = new ConnectionInfo(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); ConnectionInfo info = (ConnectionInfo) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ConsumerControlTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ConsumerControlTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ConsumerControlTest.java index e86c538..32727c6 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ConsumerControlTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ConsumerControlTest.java @@ -30,12 +30,14 @@ public class ConsumerControlTest extends BaseCommandTestSupport { public static final ConsumerControlTest SINGLETON = new ConsumerControlTest(); + @Override public Object createObject() throws Exception { ConsumerControl info = new ConsumerControl(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); ConsumerControl info = (ConsumerControl) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ConsumerIdTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ConsumerIdTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ConsumerIdTest.java index fd04985..1d37eb9 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ConsumerIdTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ConsumerIdTest.java @@ -31,12 +31,14 @@ public class ConsumerIdTest extends DataFileGeneratorTestSupport { public static final ConsumerIdTest SINGLETON = new ConsumerIdTest(); + @Override public Object createObject() throws Exception { ConsumerId info = new ConsumerId(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); ConsumerId info = (ConsumerId) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ConsumerInfoTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ConsumerInfoTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ConsumerInfoTest.java index d516b8d..10d4fab 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ConsumerInfoTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ConsumerInfoTest.java @@ -29,12 +29,14 @@ public class ConsumerInfoTest extends BaseCommandTestSupport { public static final ConsumerInfoTest SINGLETON = new ConsumerInfoTest(); + @Override public Object createObject() throws Exception { ConsumerInfo info = new ConsumerInfo(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); ConsumerInfo info = (ConsumerInfo) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ControlCommandTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ControlCommandTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ControlCommandTest.java index 165929b..b939354 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ControlCommandTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ControlCommandTest.java @@ -30,12 +30,14 @@ public class ControlCommandTest extends BaseCommandTestSupport { public static final ControlCommandTest SINGLETON = new ControlCommandTest(); + @Override public Object createObject() throws Exception { ControlCommand info = new ControlCommand(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); ControlCommand info = (ControlCommand) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/DataArrayResponseTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/DataArrayResponseTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/DataArrayResponseTest.java index b4de668..92842b6 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/DataArrayResponseTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/DataArrayResponseTest.java @@ -29,12 +29,14 @@ public class DataArrayResponseTest extends ResponseTest { public static final DataArrayResponseTest SINGLETON = new DataArrayResponseTest(); + @Override public Object createObject() throws Exception { DataArrayResponse info = new DataArrayResponse(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); DataArrayResponse info = (DataArrayResponse) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/DataResponseTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/DataResponseTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/DataResponseTest.java index 6123677..d360fa4 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/DataResponseTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/DataResponseTest.java @@ -30,12 +30,14 @@ public class DataResponseTest extends ResponseTest { public static final DataResponseTest SINGLETON = new DataResponseTest(); + @Override public Object createObject() throws Exception { DataResponse info = new DataResponse(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); DataResponse info = (DataResponse) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/DestinationInfoTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/DestinationInfoTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/DestinationInfoTest.java index 31d4385..2c8b858 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/DestinationInfoTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/DestinationInfoTest.java @@ -29,12 +29,14 @@ public class DestinationInfoTest extends BaseCommandTestSupport { public static final DestinationInfoTest SINGLETON = new DestinationInfoTest(); + @Override public Object createObject() throws Exception { DestinationInfo info = new DestinationInfo(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); DestinationInfo info = (DestinationInfo) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/DiscoveryEventTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/DiscoveryEventTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/DiscoveryEventTest.java index 09fa5c2..40a14c8 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/DiscoveryEventTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/DiscoveryEventTest.java @@ -31,12 +31,14 @@ public class DiscoveryEventTest extends DataFileGeneratorTestSupport { public static final DiscoveryEventTest SINGLETON = new DiscoveryEventTest(); + @Override public Object createObject() throws Exception { DiscoveryEvent info = new DiscoveryEvent(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); DiscoveryEvent info = (DiscoveryEvent) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ExceptionResponseTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ExceptionResponseTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ExceptionResponseTest.java index ae219f9..126ced0 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ExceptionResponseTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/ExceptionResponseTest.java @@ -30,12 +30,14 @@ public class ExceptionResponseTest extends ResponseTest { public static final ExceptionResponseTest SINGLETON = new ExceptionResponseTest(); + @Override public Object createObject() throws Exception { ExceptionResponse info = new ExceptionResponse(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); ExceptionResponse info = (ExceptionResponse) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/FlushCommandTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/FlushCommandTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/FlushCommandTest.java index 1fee22b..ced5ebf 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/FlushCommandTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/FlushCommandTest.java @@ -30,12 +30,14 @@ public class FlushCommandTest extends BaseCommandTestSupport { public static final FlushCommandTest SINGLETON = new FlushCommandTest(); + @Override public Object createObject() throws Exception { FlushCommand info = new FlushCommand(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); FlushCommand info = (FlushCommand) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/IntegerResponseTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/IntegerResponseTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/IntegerResponseTest.java index b082093..1d7231d 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/IntegerResponseTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/IntegerResponseTest.java @@ -30,12 +30,14 @@ public class IntegerResponseTest extends ResponseTest { public static final IntegerResponseTest SINGLETON = new IntegerResponseTest(); + @Override public Object createObject() throws Exception { IntegerResponse info = new IntegerResponse(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); IntegerResponse info = (IntegerResponse) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/JournalQueueAckTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/JournalQueueAckTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/JournalQueueAckTest.java index 54eff67..b9cc450 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/JournalQueueAckTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/JournalQueueAckTest.java @@ -31,12 +31,14 @@ public class JournalQueueAckTest extends DataFileGeneratorTestSupport { public static final JournalQueueAckTest SINGLETON = new JournalQueueAckTest(); + @Override public Object createObject() throws Exception { JournalQueueAck info = new JournalQueueAck(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); JournalQueueAck info = (JournalQueueAck) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/JournalTopicAckTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/JournalTopicAckTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/JournalTopicAckTest.java index 863ef03..66f6d79 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/JournalTopicAckTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/JournalTopicAckTest.java @@ -31,12 +31,14 @@ public class JournalTopicAckTest extends DataFileGeneratorTestSupport { public static final JournalTopicAckTest SINGLETON = new JournalTopicAckTest(); + @Override public Object createObject() throws Exception { JournalTopicAck info = new JournalTopicAck(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); JournalTopicAck info = (JournalTopicAck) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/JournalTraceTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/JournalTraceTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/JournalTraceTest.java index cbcc549..2d3c9a3 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/JournalTraceTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/JournalTraceTest.java @@ -31,12 +31,14 @@ public class JournalTraceTest extends DataFileGeneratorTestSupport { public static final JournalTraceTest SINGLETON = new JournalTraceTest(); + @Override public Object createObject() throws Exception { JournalTrace info = new JournalTrace(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); JournalTrace info = (JournalTrace) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/JournalTransactionTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/JournalTransactionTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/JournalTransactionTest.java index c76ba64..ad79551 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/JournalTransactionTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/JournalTransactionTest.java @@ -31,12 +31,14 @@ public class JournalTransactionTest extends DataFileGeneratorTestSupport { public static final JournalTransactionTest SINGLETON = new JournalTransactionTest(); + @Override public Object createObject() throws Exception { JournalTransaction info = new JournalTransaction(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); JournalTransaction info = (JournalTransaction) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/KeepAliveInfoTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/KeepAliveInfoTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/KeepAliveInfoTest.java index 316dd34..55b98c0 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/KeepAliveInfoTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/KeepAliveInfoTest.java @@ -30,12 +30,14 @@ public class KeepAliveInfoTest extends BaseCommandTestSupport { public static final KeepAliveInfoTest SINGLETON = new KeepAliveInfoTest(); + @Override public Object createObject() throws Exception { KeepAliveInfo info = new KeepAliveInfo(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); KeepAliveInfo info = (KeepAliveInfo) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/LastPartialCommandTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/LastPartialCommandTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/LastPartialCommandTest.java index 39c447c..3f7403a 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/LastPartialCommandTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/LastPartialCommandTest.java @@ -30,12 +30,14 @@ public class LastPartialCommandTest extends PartialCommandTest { public static final LastPartialCommandTest SINGLETON = new LastPartialCommandTest(); + @Override public Object createObject() throws Exception { LastPartialCommand info = new LastPartialCommand(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); LastPartialCommand info = (LastPartialCommand) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/LocalTransactionIdTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/LocalTransactionIdTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/LocalTransactionIdTest.java index c7d33e2..4104130 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/LocalTransactionIdTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/LocalTransactionIdTest.java @@ -30,12 +30,14 @@ public class LocalTransactionIdTest extends TransactionIdTestSupport { public static final LocalTransactionIdTest SINGLETON = new LocalTransactionIdTest(); + @Override public Object createObject() throws Exception { LocalTransactionId info = new LocalTransactionId(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); LocalTransactionId info = (LocalTransactionId) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/MessageAckTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/MessageAckTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/MessageAckTest.java index 375f2ce..1bf1bd9 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/MessageAckTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/MessageAckTest.java @@ -30,12 +30,14 @@ public class MessageAckTest extends BaseCommandTestSupport { public static final MessageAckTest SINGLETON = new MessageAckTest(); + @Override public Object createObject() throws Exception { MessageAck info = new MessageAck(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); MessageAck info = (MessageAck) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/MessageDispatchNotificationTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/MessageDispatchNotificationTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/MessageDispatchNotificationTest.java index a7103df..a211d95 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/MessageDispatchNotificationTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/MessageDispatchNotificationTest.java @@ -30,12 +30,14 @@ public class MessageDispatchNotificationTest extends BaseCommandTestSupport { public static final MessageDispatchNotificationTest SINGLETON = new MessageDispatchNotificationTest(); + @Override public Object createObject() throws Exception { MessageDispatchNotification info = new MessageDispatchNotification(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); MessageDispatchNotification info = (MessageDispatchNotification) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/MessageDispatchTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/MessageDispatchTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/MessageDispatchTest.java index 31a2514..2b0654a 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/MessageDispatchTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/MessageDispatchTest.java @@ -30,12 +30,14 @@ public class MessageDispatchTest extends BaseCommandTestSupport { public static final MessageDispatchTest SINGLETON = new MessageDispatchTest(); + @Override public Object createObject() throws Exception { MessageDispatch info = new MessageDispatch(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); MessageDispatch info = (MessageDispatch) object; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/MessageIdTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/MessageIdTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/MessageIdTest.java index b65de93..6db063b 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/MessageIdTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/openwire/v1/MessageIdTest.java @@ -31,12 +31,14 @@ public class MessageIdTest extends DataFileGeneratorTestSupport { public static final MessageIdTest SINGLETON = new MessageIdTest(); + @Override public Object createObject() throws Exception { MessageId info = new MessageId(); populateObject(info); return info; } + @Override protected void populateObject(Object object) throws Exception { super.populateObject(object); MessageId info = (MessageId) object;