You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2015/12/07 19:39:34 UTC
[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<String> {
this.description = description;
}
+ @Override
public Comparable<String> 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;