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 68D3A18950 for ; Mon, 7 Dec 2015 18:39:15 +0000 (UTC) Received: (qmail 98298 invoked by uid 500); 7 Dec 2015 18:39:15 -0000 Delivered-To: apmail-activemq-commits-archive@activemq.apache.org Received: (qmail 98180 invoked by uid 500); 7 Dec 2015 18:39:15 -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 97634 invoked by uid 99); 7 Dec 2015 18:39:13 -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:13 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 77F1BE08DB; Mon, 7 Dec 2015 18:39:13 +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:16 -0000 Message-Id: In-Reply-To: <5f1541ce95584d48bf47f02f5e930ed0@git.apache.org> References: <5f1541ce95584d48bf47f02f5e930ed0@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [04/42] activemq-artemis git commit: Add missing @Override annotations http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/QueueControlUsingCoreTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/QueueControlUsingCoreTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/QueueControlUsingCoreTest.java index 2b75f12..6dce64b 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/QueueControlUsingCoreTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/QueueControlUsingCoreTest.java @@ -48,98 +48,122 @@ public class QueueControlUsingCoreTest extends QueueControlTest { } } + @Override public boolean changeMessagePriority(final long messageID, final int newPriority) throws Exception { return (Boolean) proxy.invokeOperation("changeMessagePriority", messageID, newPriority); } + @Override public int changeMessagesPriority(final String filter, final int newPriority) throws Exception { return (Integer) proxy.invokeOperation("changeMessagesPriority", filter, newPriority); } + @Override public long countMessages(final String filter) throws Exception { return ((Number) proxy.invokeOperation("countMessages", filter)).longValue(); } + @Override public boolean expireMessage(final long messageID) throws Exception { return (Boolean) proxy.invokeOperation("expireMessage", messageID); } + @Override public int expireMessages(final String filter) throws Exception { return (Integer) proxy.invokeOperation("expireMessages", filter); } + @Override public String getAddress() { return (String) proxy.retrieveAttributeValue("address"); } + @Override public int getConsumerCount() { return (Integer) proxy.retrieveAttributeValue("consumerCount"); } + @Override public String getDeadLetterAddress() { return (String) proxy.retrieveAttributeValue("deadLetterAddress"); } + @Override public int getDeliveringCount() { return (Integer) proxy.retrieveAttributeValue("deliveringCount"); } + @Override public String getExpiryAddress() { return (String) proxy.retrieveAttributeValue("expiryAddress"); } + @Override public String getFilter() { return (String) proxy.retrieveAttributeValue("filter"); } + @Override public long getMessageCount() { return ((Number) proxy.retrieveAttributeValue("messageCount")).longValue(); } + @Override public long getMessagesAdded() { return (Integer) proxy.retrieveAttributeValue("messagesAdded"); } + @Override public long getMessagesAcknowledged() { return (Integer) proxy.retrieveAttributeValue("messagesAcknowledged"); } + @Override public void resetMessagesAdded() throws Exception { proxy.invokeOperation("resetMessagesAdded"); } + @Override public void resetMessagesAcknowledged() throws Exception { proxy.invokeOperation("resetMessagesAcknowledged"); } + @Override public String getName() { return (String) proxy.retrieveAttributeValue("name"); } + @Override public long getID() { return (Long) proxy.retrieveAttributeValue("ID"); } + @Override public long getScheduledCount() { return (Long) proxy.retrieveAttributeValue("scheduledCount", Long.class); } + @Override public boolean isDurable() { return (Boolean) proxy.retrieveAttributeValue("durable"); } + @Override public boolean isTemporary() { return (Boolean) proxy.retrieveAttributeValue("temporary"); } + @Override public String listMessageCounter() throws Exception { return (String) proxy.invokeOperation("listMessageCounter"); } + @Override public String listMessageCounterAsHTML() throws Exception { return (String) proxy.invokeOperation("listMessageCounterAsHTML"); } + @Override public String listMessageCounterHistory() throws Exception { return (String) proxy.invokeOperation("listMessageCounterHistory"); } @@ -147,6 +171,7 @@ public class QueueControlUsingCoreTest extends QueueControlTest { /** * Returns the first message on the queue as JSON */ + @Override public String getFirstMessageAsJSON() throws Exception { return (String) proxy.invokeOperation("getFirstMessageAsJSON"); } @@ -154,6 +179,7 @@ public class QueueControlUsingCoreTest extends QueueControlTest { /** * Returns the timestamp of the first message in milliseconds. */ + @Override public Long getFirstMessageTimestamp() throws Exception { return (Long) proxy.invokeOperation("getFirstMessageTimestamp"); } @@ -161,6 +187,7 @@ public class QueueControlUsingCoreTest extends QueueControlTest { /** * Returns the age of the first message in milliseconds. */ + @Override public Long getFirstMessageAge() throws Exception { Object value = proxy.invokeOperation("getFirstMessageAge"); @@ -171,10 +198,12 @@ public class QueueControlUsingCoreTest extends QueueControlTest { return (Long) value; } + @Override public String listMessageCounterHistoryAsHTML() throws Exception { return (String) proxy.invokeOperation("listMessageCounterHistoryAsHTML"); } + @Override public Map[] listMessages(final String filter) throws Exception { Object[] res = (Object[]) proxy.invokeOperation("listMessages", filter); Map[] results = new Map[res.length]; @@ -184,10 +213,12 @@ public class QueueControlUsingCoreTest extends QueueControlTest { return results; } + @Override public String listMessagesAsJSON(final String filter) throws Exception { return (String) proxy.invokeOperation("listMessagesAsJSON", filter); } + @Override public Map[] listScheduledMessages() throws Exception { Object[] res = (Object[]) proxy.invokeOperation("listScheduledMessages"); Map[] results = new Map[res.length]; @@ -197,10 +228,12 @@ public class QueueControlUsingCoreTest extends QueueControlTest { return results; } + @Override public String listScheduledMessagesAsJSON() throws Exception { return (String) proxy.invokeOperation("listScheduledMessagesAsJSON"); } + @Override public int moveMessages(final String filter, final String otherQueueName) throws Exception { return (Integer) proxy.invokeOperation("moveMessages", filter, otherQueueName); } @@ -213,50 +246,61 @@ public class QueueControlUsingCoreTest extends QueueControlTest { return (Integer) proxy.invokeOperation("moveMessages", flushLimit, filter, otherQueueName, rejectDuplicates); } + @Override public int moveMessages(final String filter, final String otherQueueName, final boolean rejectDuplicates) throws Exception { return (Integer) proxy.invokeOperation("moveMessages", filter, otherQueueName, rejectDuplicates); } + @Override public boolean moveMessage(final long messageID, final String otherQueueName) throws Exception { return (Boolean) proxy.invokeOperation("moveMessage", messageID, otherQueueName); } + @Override public boolean moveMessage(final long messageID, final String otherQueueName, final boolean rejectDuplicates) throws Exception { return (Boolean) proxy.invokeOperation("moveMessage", messageID, otherQueueName, rejectDuplicates); } + @Override public boolean retryMessage(final long messageID) throws Exception { return (Boolean) proxy.invokeOperation("retryMessage", messageID); } + @Override public int retryMessages() throws Exception { return (Integer) proxy.invokeOperation("retryMessages"); } + @Override public int removeMessages(final String filter) throws Exception { return (Integer) proxy.invokeOperation("removeMessages", filter); } + @Override public int removeMessages(final int limit, final String filter) throws Exception { return (Integer) proxy.invokeOperation("removeMessages", limit, filter); } + @Override public boolean removeMessage(final long messageID) throws Exception { return (Boolean) proxy.invokeOperation("removeMessage", messageID); } + @Override public void resetMessageCounter() throws Exception { proxy.invokeOperation("resetMessageCounter"); } + @Override public boolean sendMessageToDeadLetterAddress(final long messageID) throws Exception { return (Boolean) proxy.invokeOperation("sendMessageToDeadLetterAddress", messageID); } + @Override public int sendMessagesToDeadLetterAddress(final String filterStr) throws Exception { return (Integer) proxy.invokeOperation("sendMessagesToDeadLetterAddress", filterStr); } @@ -269,22 +313,27 @@ public class QueueControlUsingCoreTest extends QueueControlTest { proxy.invokeOperation("setExpiryAddress", expiryAddress); } + @Override public void pause() throws Exception { proxy.invokeOperation("pause"); } + @Override public void resume() throws Exception { proxy.invokeOperation("resume"); } + @Override public boolean isPaused() throws Exception { return (Boolean) proxy.invokeOperation("isPaused"); } + @Override public String listConsumersAsJSON() throws Exception { return (String) proxy.invokeOperation("listConsumersAsJSON"); } + @Override public Map[]> listDeliveringMessages() throws Exception { // This map code could be done better, // however that's just to convert stuff for the test class, so I http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/mqtt/imported/MQTTTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/mqtt/imported/MQTTTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/mqtt/imported/MQTTTest.java index 9a63da1..6627014 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/mqtt/imported/MQTTTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/mqtt/imported/MQTTTest.java @@ -55,6 +55,7 @@ public class MQTTTest extends MQTTTestSupport { private static final int NUM_MESSAGES = 250; + @Override @Before public void setUp() throws Exception { Field sessions = MQTTSession.class.getDeclaredField("SESSIONS"); http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/mqtt/imported/MQTTTestSupport.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/mqtt/imported/MQTTTestSupport.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/mqtt/imported/MQTTTestSupport.java index 9fa0ffe..28cd8d3 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/mqtt/imported/MQTTTestSupport.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/mqtt/imported/MQTTTestSupport.java @@ -84,10 +84,12 @@ public class MQTTTestSupport extends ActiveMQTestBase { this.useSSL = useSSL; } + @Override public String getName() { return name.getMethodName(); } + @Override @Before public void setUp() throws Exception { String basedir = basedir().getPath(); @@ -102,6 +104,7 @@ public class MQTTTestSupport extends ActiveMQTestBase { startBroker(); } + @Override @After public void tearDown() throws Exception { System.clearProperty("javax.net.ssl.trustStore"); http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/BasicSecurityTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/BasicSecurityTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/BasicSecurityTest.java index 266ad34..a1a5e38 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/BasicSecurityTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/BasicSecurityTest.java @@ -31,6 +31,7 @@ import org.junit.Test; public class BasicSecurityTest extends BasicOpenWireTest { + @Override @Before public void setUp() throws Exception { this.enableSecurity = true; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JMSDurableTopicRedeliverTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JMSDurableTopicRedeliverTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JMSDurableTopicRedeliverTest.java index ca96492..cbb3e31 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JMSDurableTopicRedeliverTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JMSDurableTopicRedeliverTest.java @@ -80,6 +80,7 @@ public class JMSDurableTopicRedeliverTest extends JmsTopicRedeliverTest { assertNull(consumer.receive(1000)); } + @Override protected String getName() { return "JMSDurableTopicRedeliverTest"; } http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsAutoAckListenerTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsAutoAckListenerTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsAutoAckListenerTest.java index a61e462..644bc5e 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsAutoAckListenerTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsAutoAckListenerTest.java @@ -58,6 +58,7 @@ public class JmsAutoAckListenerTest extends BasicOpenWireTest implements Message session.close(); } + @Override public void onMessage(Message message) { System.out.println("Received message: " + message); assertNotNull(message); http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsConnectionStartStopTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsConnectionStartStopTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsConnectionStartStopTest.java index 31cbb93..3606200 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsConnectionStartStopTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsConnectionStartStopTest.java @@ -45,6 +45,7 @@ public class JmsConnectionStartStopTest extends BasicOpenWireTest { private Connection startedConnection; private Connection stoppedConnection; + @Override @Before public void setUp() throws Exception { super.setUp(); @@ -56,6 +57,7 @@ public class JmsConnectionStartStopTest extends BasicOpenWireTest { /** * @see junit.framework.TestCase#tearDown() */ + @Override @After public void tearDown() throws Exception { stoppedConnection.close(); http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsConsumerResetActiveListenerTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsConsumerResetActiveListenerTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsConsumerResetActiveListenerTest.java index 80405b9..b50abb6 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsConsumerResetActiveListenerTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsConsumerResetActiveListenerTest.java @@ -56,6 +56,7 @@ public class JmsConsumerResetActiveListenerTest extends BasicOpenWireTest { final Vector results = new Vector(); consumer.setMessageListener(new MessageListener() { + @Override public void onMessage(Message message) { if (first.compareAndSet(true, false)) { try { @@ -107,6 +108,7 @@ public class JmsConsumerResetActiveListenerTest extends BasicOpenWireTest { final Vector results = new Vector(); consumer.setMessageListener(new MessageListener() { + @Override public void onMessage(Message message) { if (first.compareAndSet(true, false)) { try { http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsCreateConsumerInOnMessageTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsCreateConsumerInOnMessageTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsCreateConsumerInOnMessageTest.java index dc86fa3..0aaded9 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsCreateConsumerInOnMessageTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsCreateConsumerInOnMessageTest.java @@ -73,6 +73,7 @@ public class JmsCreateConsumerInOnMessageTest extends BasicOpenWireTest implemen * * @param message */ + @Override public void onMessage(Message message) { System.out.println("____________onmessage " + message); try { http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableQueueWildcardSendReceiveTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableQueueWildcardSendReceiveTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableQueueWildcardSendReceiveTest.java index a7be999..a17af75 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableQueueWildcardSendReceiveTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableQueueWildcardSendReceiveTest.java @@ -23,6 +23,7 @@ import javax.jms.DeliveryMode; */ public class JmsDurableQueueWildcardSendReceiveTest extends JmsTopicSendReceiveTest { + @Override public void setUp() throws Exception { topic = false; deliveryMode = DeliveryMode.PERSISTENT; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableTopicSendReceiveTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableTopicSendReceiveTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableTopicSendReceiveTest.java index 0762edd..f94defd 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableTopicSendReceiveTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableTopicSendReceiveTest.java @@ -90,6 +90,7 @@ public class JmsDurableTopicSendReceiveTest extends JmsTopicSendReceiveTest { connection2.close(); } + @Override protected String getName() { return "testSendWhileClosed"; } http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableTopicTransactionTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableTopicTransactionTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableTopicTransactionTest.java index 53215ac..c155a6d 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableTopicTransactionTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableTopicTransactionTest.java @@ -26,6 +26,7 @@ public class JmsDurableTopicTransactionTest extends JmsTopicTransactionTest { /** * @see JmsTransactionTestSupport#getJmsResourceProvider() */ + @Override protected JmsResourceProvider getJmsResourceProvider() { JmsResourceProvider provider = new JmsResourceProvider(); provider.setTopic(true); http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableTopicWildcardSendReceiveTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableTopicWildcardSendReceiveTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableTopicWildcardSendReceiveTest.java index d422930..819ff20 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableTopicWildcardSendReceiveTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsDurableTopicWildcardSendReceiveTest.java @@ -23,6 +23,7 @@ import javax.jms.DeliveryMode; */ public class JmsDurableTopicWildcardSendReceiveTest extends JmsTopicSendReceiveTest { + @Override public void setUp() throws Exception { topic = true; durable = true; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsSendReceiveTestSupport.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsSendReceiveTestSupport.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsSendReceiveTestSupport.java index 45d7c8e..e5cf659 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsSendReceiveTestSupport.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsSendReceiveTestSupport.java @@ -181,6 +181,7 @@ public abstract class JmsSendReceiveTestSupport extends BasicOpenWireTest implem * * @see javax.jms.MessageListener#onMessage(javax.jms.Message) */ + @Override public synchronized void onMessage(Message message) { consumeMessage(message, messages); } http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsTopicRequestReplyTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsTopicRequestReplyTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsTopicRequestReplyTest.java index 8005a34..e31621d 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsTopicRequestReplyTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsTopicRequestReplyTest.java @@ -111,6 +111,7 @@ public class JmsTopicRequestReplyTest extends BasicOpenWireTest implements Messa /** * Use the asynchronous subscription mechanism */ + @Override public void onMessage(Message message) { try { TextMessage requestMessage = (TextMessage) message; @@ -185,6 +186,7 @@ public class JmsTopicRequestReplyTest extends BasicOpenWireTest implements Messa } else { Thread thread = new Thread(new Runnable() { + @Override public void run() { syncConsumeLoop(requestConsumer); } http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsTopicWildcardSendReceiveTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsTopicWildcardSendReceiveTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsTopicWildcardSendReceiveTest.java index 9208171..a651c0d 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsTopicWildcardSendReceiveTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/JmsTopicWildcardSendReceiveTest.java @@ -48,10 +48,12 @@ public class JmsTopicWildcardSendReceiveTest extends JmsTopicSendReceiveTest { super.setUp(); } + @Override protected String getConsumerSubject() { return "FOO.>"; } + @Override protected String getProducerSubject() { return "FOO.BAR.HUMBUG"; } http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/MessageListenerRedeliveryTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/MessageListenerRedeliveryTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/MessageListenerRedeliveryTest.java index 37a544f..d07ec1a 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/MessageListenerRedeliveryTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/MessageListenerRedeliveryTest.java @@ -391,6 +391,7 @@ public class MessageListenerRedeliveryTest extends BasicOpenWireTest { return DeliveryMode.PERSISTENT; } + @Override protected String getName() { return "testQueueSessionListenerExceptionDlq"; } http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/ProducerFlowControlSendFailTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/ProducerFlowControlSendFailTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/ProducerFlowControlSendFailTest.java index 0eeb3e8..4d3a6f8 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/ProducerFlowControlSendFailTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/ProducerFlowControlSendFailTest.java @@ -174,6 +174,7 @@ public class ProducerFlowControlSendFailTest extends ProducerFlowControlTest { protected ConnectionFactory getConnectionFactory() throws Exception { factory.setExceptionListener(new ExceptionListener() { + @Override public void onException(JMSException arg0) { if (arg0 instanceof ResourceAllocationException) { gotResourceException.set(true); http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/ProducerFlowControlTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/ProducerFlowControlTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/ProducerFlowControlTest.java index cc4d3f0..49feb26 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/ProducerFlowControlTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/ProducerFlowControlTest.java @@ -259,6 +259,7 @@ public class ProducerFlowControlTest extends BasicOpenWireTest { // Once the send starts to block it will not reset the done flag // anymore. asyncThread = new Thread("Fill thread.") { + @Override public void run() { Session session = null; try { @@ -299,6 +300,7 @@ public class ProducerFlowControlTest extends BasicOpenWireTest { private CountDownLatch asyncSendTo(final ActiveMQQueue queue, final String message) throws JMSException { final CountDownLatch done = new CountDownLatch(1); new Thread("Send thread.") { + @Override public void run() { Session session = null; try { http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/ReconnectWithSameClientIDTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/ReconnectWithSameClientIDTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/ReconnectWithSameClientIDTest.java index 940903a..671fd8d 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/ReconnectWithSameClientIDTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/ReconnectWithSameClientIDTest.java @@ -69,6 +69,7 @@ public class ReconnectWithSameClientIDTest extends BasicOpenWireTest { } } + @Override @After public void tearDown() throws Exception { if (sameIdConnection != null) { http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/paging/PagingWithFailoverAndCountersTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/paging/PagingWithFailoverAndCountersTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/paging/PagingWithFailoverAndCountersTest.java index 2c62e73..88730f3 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/paging/PagingWithFailoverAndCountersTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/paging/PagingWithFailoverAndCountersTest.java @@ -170,6 +170,7 @@ public class PagingWithFailoverAndCountersTest extends ActiveMQTestBase { this.txSize = txSize; } + @Override public void run() { try { @@ -235,6 +236,7 @@ public class PagingWithFailoverAndCountersTest extends ActiveMQTestBase { super("Monitor-thread"); } + @Override public void run() { ActiveMQServer server = inProcessBackup.getServer(); http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQMessageHandlerTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQMessageHandlerTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQMessageHandlerTest.java index a5636cf..d2d67e2 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQMessageHandlerTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQMessageHandlerTest.java @@ -187,6 +187,7 @@ public class ActiveMQMessageHandlerTest extends ActiveMQRATestBase { /** * @return */ + @Override protected ActiveMQResourceAdapter newResourceAdapter() { ActiveMQResourceAdapter qResourceAdapter = new ActiveMQResourceAdapter(); qResourceAdapter.setConnectorClassName(INVM_CONNECTOR_FACTORY); http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQRAClusteredTestBase.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQRAClusteredTestBase.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQRAClusteredTestBase.java index c49d38a..d702fa0 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQRAClusteredTestBase.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQRAClusteredTestBase.java @@ -53,6 +53,7 @@ public class ActiveMQRAClusteredTestBase extends ActiveMQRATestBase { } + @Override protected Configuration createDefaultConfig(boolean netty) throws Exception { return createSecondaryDefaultConfig(false); } http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQRATestBase.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQRATestBase.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQRATestBase.java index 75dc976..8043689 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQRATestBase.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQRATestBase.java @@ -101,6 +101,7 @@ public abstract class ActiveMQRATestBase extends JMSTestBase { return endpoint; } + @Override public boolean isDeliveryTransacted(Method method) throws NoSuchMethodException { return isDeliveryTransacted; } @@ -122,20 +123,24 @@ public abstract class ActiveMQRATestBase extends JMSTestBase { this.latch = latch; } + @Override public void beforeDelivery(Method method) throws NoSuchMethodException, ResourceException { } + @Override public void afterDelivery() throws ResourceException { if (latch != null) { latch.countDown(); } } + @Override public void release() { released = true; } + @Override public void onMessage(Message message) { lastMessage = (ActiveMQMessage) message; } @@ -154,6 +159,7 @@ public abstract class ActiveMQRATestBase extends JMSTestBase { WorkManager workManager = new DummyWorkManager(); + @Override public Timer createTimer() throws UnavailableException { return null; } http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ResourceAdapterTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ResourceAdapterTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ResourceAdapterTest.java index 221b3da..6bce079 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ResourceAdapterTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ResourceAdapterTest.java @@ -660,14 +660,17 @@ public class ResourceAdapterTest extends ActiveMQRATestBase { class DummyEndpoint implements MessageEndpoint { + @Override public void beforeDelivery(Method method) throws NoSuchMethodException, ResourceException { // To change body of implemented methods use File | Settings | File Templates. } + @Override public void afterDelivery() throws ResourceException { // To change body of implemented methods use File | Settings | File Templates. } + @Override public void release() { // To change body of implemented methods use File | Settings | File Templates. } http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/remoting/PingTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/remoting/PingTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/remoting/PingTest.java index 35f83bd..ed4506f 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/remoting/PingTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/remoting/PingTest.java @@ -87,6 +87,7 @@ public class PingTest extends ActiveMQTestBase { return me; } + @Override public void beforeReconnect(final ActiveMQException exception) { } } @@ -214,6 +215,7 @@ public class PingTest extends ActiveMQTestBase { final CountDownLatch requiredPings = new CountDownLatch(1); final CountDownLatch unwantedPings = new CountDownLatch(2); server.getRemotingService().addIncomingInterceptor(new Interceptor() { + @Override public boolean intercept(final Packet packet, final RemotingConnection connection) throws ActiveMQException { if (packet.getType() == PacketImpl.PING) { Assert.assertEquals(ActiveMQClient.DEFAULT_CONNECTION_TTL_INVM, ((Ping) packet).getConnectionTTL()); @@ -325,6 +327,7 @@ public class PingTest extends ActiveMQTestBase { final CountDownLatch pingOnServerLatch = new CountDownLatch(2); server.getRemotingService().addIncomingInterceptor(new Interceptor() { + @Override public boolean intercept(final Packet packet, final RemotingConnection connection) throws ActiveMQException { if (packet.getType() == PacketImpl.PING) { pingOnServerLatch.countDown(); @@ -355,12 +358,14 @@ public class PingTest extends ActiveMQTestBase { connectionFailed(me, failedOver); } + @Override public void beforeReconnect(final ActiveMQException exception) { } }; final CountDownLatch serverLatch = new CountDownLatch(1); CloseListener serverListener = new CloseListener() { + @Override public void connectionClosed() { serverLatch.countDown(); } http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/remoting/ReconnectTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/remoting/ReconnectTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/remoting/ReconnectTest.java index 3278a64..268b10b 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/remoting/ReconnectTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/remoting/ReconnectTest.java @@ -82,6 +82,7 @@ public class ReconnectTest extends ActiveMQTestBase { connectionFailed(me, failedOver); } + @Override public void beforeReconnect(final ActiveMQException exception) { } @@ -269,6 +270,7 @@ public class ReconnectTest extends ActiveMQTestBase { session.addFailureListener(new SessionFailureListener() { + @Override public void connectionFailed(final ActiveMQException me, boolean failedOver) { count.incrementAndGet(); latch.countDown(); @@ -279,6 +281,7 @@ public class ReconnectTest extends ActiveMQTestBase { connectionFailed(me, failedOver); } + @Override public void beforeReconnect(final ActiveMQException exception) { } @@ -287,6 +290,7 @@ public class ReconnectTest extends ActiveMQTestBase { server.stop(); Thread tcommitt = new Thread() { + @Override public void run() { latchCommit.countDown(); try { http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/replication/ReplicationTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/replication/ReplicationTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/replication/ReplicationTest.java index 5b1a4b3..e9e3c02 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/replication/ReplicationTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/replication/ReplicationTest.java @@ -345,12 +345,14 @@ public final class ReplicationTest extends ActiveMQTestBase { final CountDownLatch latch = new CountDownLatch(1); ctx.executeOnCompletion(new IOCallback() { + @Override public void onError(final int errorCode, final String errorMessage) { lastError.set(errorCode); msgsResult.add(errorMessage); latch.countDown(); } + @Override public void done() { } }); @@ -367,12 +369,14 @@ public final class ReplicationTest extends ActiveMQTestBase { // Adding the Task after the exception should still throw an exception ctx.executeOnCompletion(new IOCallback() { + @Override public void onError(final int errorCode, final String errorMessage) { lastError.set(errorCode); msgsResult.add(errorMessage); latch2.countDown(); } + @Override public void done() { } }); @@ -388,9 +392,11 @@ public final class ReplicationTest extends ActiveMQTestBase { final CountDownLatch latch3 = new CountDownLatch(1); ctx.executeOnCompletion(new IOCallback() { + @Override public void onError(final int errorCode, final String errorMessage) { } + @Override public void done() { latch3.countDown(); } @@ -444,9 +450,11 @@ public final class ReplicationTest extends ActiveMQTestBase { final CountDownLatch latch = new CountDownLatch(1); storage.afterCompleteOperations(new IOCallback() { + @Override public void onError(final int errorCode, final String errorMessage) { } + @Override public void done() { latch.countDown(); } @@ -470,9 +478,11 @@ public final class ReplicationTest extends ActiveMQTestBase { final CountDownLatch latch = new CountDownLatch(1); storage.afterCompleteOperations(new IOCallback() { + @Override public void onError(final int errorCode, final String errorMessage) { } + @Override public void done() { latch.countDown(); } @@ -509,9 +519,11 @@ public final class ReplicationTest extends ActiveMQTestBase { ctx.executeOnCompletion(new IOCallback() { + @Override public void onError(final int errorCode, final String errorMessage) { } + @Override public void done() { executions.add(nAdd); latch.countDown(); @@ -530,13 +542,16 @@ public final class ReplicationTest extends ActiveMQTestBase { class FakeData implements EncodingSupport { + @Override public void decode(final ActiveMQBuffer buffer) { } + @Override public void encode(final ActiveMQBuffer buffer) { buffer.writeBytes(new byte[5]); } + @Override public int getEncodeSize() { return 5; } @@ -599,6 +614,7 @@ public final class ReplicationTest extends ActiveMQTestBase { static AtomicBoolean value = new AtomicBoolean(true); + @Override public boolean intercept(final Packet packet, final RemotingConnection connection) throws ActiveMQException { return TestInterceptor.value.get(); } @@ -607,6 +623,7 @@ public final class ReplicationTest extends ActiveMQTestBase { static final class FakeJournal implements Journal { + @Override public void appendAddRecord(final long id, final byte recordType, final byte[] record, @@ -614,6 +631,7 @@ public final class ReplicationTest extends ActiveMQTestBase { } + @Override public void appendAddRecord(final long id, final byte recordType, final EncodingSupport record, @@ -621,6 +639,7 @@ public final class ReplicationTest extends ActiveMQTestBase { } + @Override public void appendAddRecordTransactional(final long txID, final long id, final byte recordType, @@ -628,6 +647,7 @@ public final class ReplicationTest extends ActiveMQTestBase { } + @Override public void appendAddRecordTransactional(final long txID, final long id, final byte recordType, @@ -635,46 +655,55 @@ public final class ReplicationTest extends ActiveMQTestBase { } + @Override public void appendCommitRecord(final long txID, final boolean sync) throws Exception { } + @Override public void appendDeleteRecord(final long id, final boolean sync) throws Exception { } + @Override public void appendDeleteRecordTransactional(final long txID, final long id, final byte[] record) throws Exception { } + @Override public void appendDeleteRecordTransactional(final long txID, final long id, final EncodingSupport record) throws Exception { } + @Override public void appendDeleteRecordTransactional(final long txID, final long id) throws Exception { } + @Override public void appendPrepareRecord(final long txID, final EncodingSupport transactionData, final boolean sync) throws Exception { } + @Override public void appendPrepareRecord(final long txID, final byte[] transactionData, final boolean sync) throws Exception { } + @Override public void appendRollbackRecord(final long txID, final boolean sync) throws Exception { } + @Override public void appendUpdateRecord(final long id, final byte recordType, final byte[] record, @@ -682,6 +711,7 @@ public final class ReplicationTest extends ActiveMQTestBase { } + @Override public void appendUpdateRecord(final long id, final byte recordType, final EncodingSupport record, @@ -689,6 +719,7 @@ public final class ReplicationTest extends ActiveMQTestBase { } + @Override public void appendUpdateRecordTransactional(final long txID, final long id, final byte recordType, @@ -696,6 +727,7 @@ public final class ReplicationTest extends ActiveMQTestBase { } + @Override public void appendUpdateRecordTransactional(final long txID, final long id, final byte recordType, @@ -703,16 +735,19 @@ public final class ReplicationTest extends ActiveMQTestBase { } + @Override public int getAlignment() throws Exception { return 0; } + @Override public JournalLoadInformation load(final LoaderCallback reloadManager) throws Exception { return new JournalLoadInformation(); } + @Override public JournalLoadInformation load(final List committedRecords, final List preparedTransactions, final TransactionFailureCallback transactionFailure) throws Exception { @@ -720,31 +755,38 @@ public final class ReplicationTest extends ActiveMQTestBase { return new JournalLoadInformation(); } + @Override public void perfBlast(final int pages) { } + @Override public boolean isStarted() { return false; } + @Override public void start() throws Exception { } + @Override public void stop() throws Exception { } + @Override public JournalLoadInformation loadInternalOnly() throws Exception { return new JournalLoadInformation(); } + @Override public int getNumberOfRecords() { return 0; } + @Override public void appendAddRecord(final long id, final byte recordType, final EncodingSupport record, @@ -752,27 +794,32 @@ public final class ReplicationTest extends ActiveMQTestBase { final IOCompletion completionCallback) throws Exception { } + @Override public void appendCommitRecord(final long txID, final boolean sync, final IOCompletion callback) throws Exception { } + @Override public void appendDeleteRecord(final long id, final boolean sync, final IOCompletion completionCallback) throws Exception { } + @Override public void appendPrepareRecord(final long txID, final EncodingSupport transactionData, final boolean sync, final IOCompletion callback) throws Exception { } + @Override public void appendRollbackRecord(final long txID, final boolean sync, final IOCompletion callback) throws Exception { } + @Override public void appendUpdateRecord(final long id, final byte recordType, final EncodingSupport record, @@ -783,9 +830,11 @@ public final class ReplicationTest extends ActiveMQTestBase { public void sync(final IOCompletion callback) { } + @Override public void runDirectJournalBlast() throws Exception { } + @Override public int getUserVersion() { return 0; } http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/security/SecurityTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/security/SecurityTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/security/SecurityTest.java index 3047038..468ffa5 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/security/SecurityTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/security/SecurityTest.java @@ -1648,10 +1648,12 @@ public class SecurityTest extends ActiveMQTestBase { public void testCustomSecurityManager() throws Exception { final Configuration configuration = createDefaultInVMConfig().setSecurityEnabled(true); final ActiveMQSecurityManager customSecurityManager = new ActiveMQSecurityManager() { + @Override public boolean validateUser(final String username, final String password) { return (username.equals("foo") || username.equals("bar") || username.equals("all")) && password.equals("frobnicate"); } + @Override public boolean validateUserAndRole( final String username, final String password, @@ -1732,14 +1734,17 @@ public class SecurityTest extends ActiveMQTestBase { public void testCustomSecurityManager2() throws Exception { final Configuration configuration = createDefaultInVMConfig().setSecurityEnabled(true); final ActiveMQSecurityManager customSecurityManager = new ActiveMQSecurityManager2() { + @Override public boolean validateUser(final String username, final String password) { fail("Unexpected call to overridden method"); return false; } + @Override public boolean validateUser(final String username, final String password, final X509Certificate[] certificates) { return (username.equals("foo") || username.equals("bar") || username.equals("all")) && password.equals("frobnicate"); } + @Override public boolean validateUserAndRole( final String username, final String password, @@ -1750,6 +1755,7 @@ public class SecurityTest extends ActiveMQTestBase { return false; } + @Override public boolean validateUserAndRole( final String username, final String password, http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/AddressFullLoggingTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/AddressFullLoggingTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/AddressFullLoggingTest.java index d9469ba..36f866a 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/AddressFullLoggingTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/AddressFullLoggingTest.java @@ -77,6 +77,7 @@ public class AddressFullLoggingTest extends ActiveMQTestBase { ExecutorService executor = Executors.newFixedThreadPool(1); Callable sendMessageTask = new Callable() { + @Override public Object call() throws ActiveMQException { producer.send(message); return null; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/ExpiryRunnerTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/ExpiryRunnerTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/ExpiryRunnerTest.java index f015ca6..ee4ac08 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/ExpiryRunnerTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/ExpiryRunnerTest.java @@ -263,6 +263,7 @@ public class ExpiryRunnerTest extends ActiveMQTestBase { this.latch = latch; } + @Override public void run() { while (true) { try { http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/GracefulShutdownTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/GracefulShutdownTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/GracefulShutdownTest.java index b7894a4..f42e585 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/GracefulShutdownTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/GracefulShutdownTest.java @@ -45,6 +45,7 @@ public class GracefulShutdownTest extends ActiveMQTestBase { ClientSession session = sf.createSession(true, true); Thread t = new Thread(new Runnable() { + @Override public void run() { try { server.stop(); @@ -113,6 +114,7 @@ public class GracefulShutdownTest extends ActiveMQTestBase { ClientSessionFactory sf = createSessionFactory(locator); Thread t = new Thread(new Runnable() { + @Override public void run() { try { server.stop(); http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/SuppliedThreadPoolTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/SuppliedThreadPoolTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/SuppliedThreadPoolTest.java index 3b00219..2e9accf 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/SuppliedThreadPoolTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/SuppliedThreadPoolTest.java @@ -49,6 +49,7 @@ public class SuppliedThreadPoolTest extends ActiveMQTestBase { server.waitForActivation(100, TimeUnit.MILLISECONDS); } + @Override @After public void tearDown() throws Exception { if (server.isActive()) { http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/spring/ExampleListener.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/spring/ExampleListener.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/spring/ExampleListener.java index da7b647..8093d28 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/spring/ExampleListener.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/spring/ExampleListener.java @@ -29,6 +29,7 @@ public class ExampleListener implements MessageListener { public static ReusableLatch latch = new ReusableLatch(); + @Override public void onMessage(Message message) { try { lastMessage = ((TextMessage) message).getText(); http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/spring/SpringIntegrationTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/spring/SpringIntegrationTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/spring/SpringIntegrationTest.java index 0b0d1c8..f2e5cfd 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/spring/SpringIntegrationTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/spring/SpringIntegrationTest.java @@ -33,6 +33,7 @@ public class SpringIntegrationTest extends ActiveMQTestBase { IntegrationTestLogger log = IntegrationTestLogger.LOGGER; + @Override @Before public void setUp() throws Exception { super.setUp(); http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ssl/CoreClientOverTwoWaySSLTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ssl/CoreClientOverTwoWaySSLTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ssl/CoreClientOverTwoWaySSLTest.java index 00cc0a7..d66b968 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ssl/CoreClientOverTwoWaySSLTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ssl/CoreClientOverTwoWaySSLTest.java @@ -96,6 +96,7 @@ public class CoreClientOverTwoWaySSLTest extends ActiveMQTestBase { private class MyInterceptor implements Interceptor { + @Override public boolean intercept(final Packet packet, final RemotingConnection connection) throws ActiveMQException { if (packet.getType() == PacketImpl.SESS_SEND) { try { http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/StompTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/StompTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/StompTest.java index b6b908a..534f342 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/StompTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/StompTest.java @@ -56,6 +56,7 @@ public class StompTest extends StompTestBase { final CountDownLatch latch = new CountDownLatch(count); consumer.setMessageListener(new MessageListener() { + @Override public void onMessage(Message arg0) { latch.countDown(); } http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/AbstractClientStompFrame.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/AbstractClientStompFrame.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/AbstractClientStompFrame.java index 8bc7f95..1aabb1a 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/AbstractClientStompFrame.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/AbstractClientStompFrame.java @@ -65,6 +65,7 @@ public abstract class AbstractClientStompFrame implements ClientStompFrame { return validCommands.contains(command); } + @Override public String toString() { StringBuffer sb = new StringBuffer("Frame: <" + command + ">" + "\n"); Iterator
iter = headers.iterator(); http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/AbstractStompClientConnection.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/AbstractStompClientConnection.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/AbstractStompClientConnection.java index bac977b..4d3c07c 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/AbstractStompClientConnection.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/AbstractStompClientConnection.java @@ -88,6 +88,7 @@ public abstract class AbstractStompClientConnection implements StompClientConnec new ReaderThread().start(); } + @Override public ClientStompFrame sendFrame(ClientStompFrame frame) throws IOException, InterruptedException { ClientStompFrame response = null; ByteBuffer buffer = frame.toByteBuffer(); @@ -113,6 +114,7 @@ public abstract class AbstractStompClientConnection implements StompClientConnec return response; } + @Override public ClientStompFrame sendWickedFrame(ClientStompFrame frame) throws IOException, InterruptedException { ClientStompFrame response = null; ByteBuffer buffer = frame.toByteBufferWithExtra("\n"); @@ -138,10 +140,12 @@ public abstract class AbstractStompClientConnection implements StompClientConnec return response; } + @Override public ClientStompFrame receiveFrame() throws InterruptedException { return frameQueue.poll(10, TimeUnit.SECONDS); } + @Override public ClientStompFrame receiveFrame(long timeout) throws InterruptedException { return frameQueue.poll(timeout, TimeUnit.MILLISECONDS); } @@ -236,10 +240,12 @@ public abstract class AbstractStompClientConnection implements StompClientConnec } } + @Override public ClientStompFrame connect() throws Exception { return connect(null, null); } + @Override public void destroy() { try { close(); @@ -251,18 +257,22 @@ public abstract class AbstractStompClientConnection implements StompClientConnec } } + @Override public ClientStompFrame connect(String username, String password) throws Exception { throw new RuntimeException("connect method not implemented!"); } + @Override public boolean isConnected() { return connected; } + @Override public String getVersion() { return version; } + @Override public int getFrameQueueSize() { return this.frameQueue.size(); } @@ -310,6 +320,7 @@ public abstract class AbstractStompClientConnection implements StompClientConnec this.notify(); } + @Override public void run() { synchronized (this) { while (!stop) { http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/ClientStompFrameV11.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/ClientStompFrameV11.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/ClientStompFrameV11.java index c168922..22d7146 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/ClientStompFrameV11.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/ClientStompFrameV11.java @@ -37,6 +37,7 @@ public class ClientStompFrameV11 extends AbstractClientStompFrame { super(command, validate); } + @Override public void setForceOneway() { forceOneway = true; } @@ -52,10 +53,12 @@ public class ClientStompFrameV11 extends AbstractClientStompFrame { return false; } + @Override public void setPing(boolean b) { isPing = b; } + @Override public boolean isPing() { return isPing; } http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/ClientStompFrameV12.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/ClientStompFrameV12.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/ClientStompFrameV12.java index 22ce99e..5ca530e 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/ClientStompFrameV12.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/ClientStompFrameV12.java @@ -44,6 +44,7 @@ public class ClientStompFrameV12 extends AbstractClientStompFrame { } } + @Override public void setForceOneway() { forceOneway = true; } @@ -59,10 +60,12 @@ public class ClientStompFrameV12 extends AbstractClientStompFrame { return false; } + @Override public void setPing(boolean b) { isPing = b; } + @Override public boolean isPing() { return isPing; } http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompClientConnectionV10.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompClientConnectionV10.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompClientConnectionV10.java index 2c9dfe7..5f46b0a 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompClientConnectionV10.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompClientConnectionV10.java @@ -27,6 +27,7 @@ public class StompClientConnectionV10 extends AbstractStompClientConnection { super("1.0", host, port); } + @Override public ClientStompFrame connect(String username, String passcode) throws IOException, InterruptedException { ClientStompFrame frame = factory.newFrame(CONNECT_COMMAND); frame.addHeader(LOGIN_HEADER, username); @@ -44,6 +45,7 @@ public class StompClientConnectionV10 extends AbstractStompClientConnection { return response; } + @Override public void connect(String username, String passcode, String clientID) throws IOException, InterruptedException { ClientStompFrame frame = factory.newFrame(CONNECT_COMMAND); frame.addHeader(LOGIN_HEADER, username); http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompClientConnectionV11.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompClientConnectionV11.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompClientConnectionV11.java index 481f7a1..1e2296c 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompClientConnectionV11.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompClientConnectionV11.java @@ -24,6 +24,7 @@ public class StompClientConnectionV11 extends AbstractStompClientConnection { super("1.1", host, port); } + @Override public ClientStompFrame connect(String username, String passcode) throws IOException, InterruptedException { ClientStompFrame frame = factory.newFrame(CONNECT_COMMAND); frame.addHeader(ACCEPT_HEADER, "1.1"); @@ -49,6 +50,7 @@ public class StompClientConnectionV11 extends AbstractStompClientConnection { return response; } + @Override public void connect(String username, String passcode, String clientID) throws IOException, InterruptedException { ClientStompFrame frame = factory.newFrame(CONNECT_COMMAND); frame.addHeader(ACCEPT_HEADER, "1.1"); http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompClientConnectionV12.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompClientConnectionV12.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompClientConnectionV12.java index f28743d..797f731 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompClientConnectionV12.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompClientConnectionV12.java @@ -29,6 +29,7 @@ public class StompClientConnectionV12 extends AbstractStompClientConnection { return factory.newFrame(command); } + @Override public ClientStompFrame connect(String username, String passcode) throws IOException, InterruptedException { ClientStompFrame frame = factory.newFrame(CONNECT_COMMAND); frame.addHeader(ACCEPT_HEADER, "1.2"); http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompFrameFactoryV10.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompFrameFactoryV10.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompFrameFactoryV10.java index 93674ac..5ed8566 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompFrameFactoryV10.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompFrameFactoryV10.java @@ -37,6 +37,7 @@ import java.util.StringTokenizer; */ public class StompFrameFactoryV10 implements StompFrameFactory { + @Override public ClientStompFrame createFrame(String data) { //split the string at "\n\n" String[] dataFields = data.split("\n\n"); http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/v11/StompV11Test.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/v11/StompV11Test.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/v11/StompV11Test.java index 6c40271..22b86a5 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/v11/StompV11Test.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/v11/StompV11Test.java @@ -1259,6 +1259,7 @@ public class StompV11Test extends StompV11TestBase { final CountDownLatch latch = new CountDownLatch(1); Thread thr = new Thread() { + @Override public void run() { ClientStompFrame sendFrame = connV11.createFrame("SEND"); sendFrame.addHeader("destination", getQueuePrefix() + getQueueName()); @@ -1450,6 +1451,7 @@ public class StompV11Test extends StompV11TestBase { int count = 1000; final CountDownLatch latch = new CountDownLatch(count); consumer.setMessageListener(new MessageListener() { + @Override public void onMessage(Message arg0) { latch.countDown(); } http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/v12/StompV12Test.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/v12/StompV12Test.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/v12/StompV12Test.java index 59f4eb6..e6cbf64 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/v12/StompV12Test.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/v12/StompV12Test.java @@ -1468,6 +1468,7 @@ public class StompV12Test extends StompV11TestBase { final CountDownLatch latch = new CountDownLatch(1); Thread thr = new Thread() { + @Override public void run() { ClientStompFrame sendFrame = connV12.createFrame("SEND"); sendFrame.addHeader("destination", getQueuePrefix() + getQueueName()); @@ -1659,6 +1660,7 @@ public class StompV12Test extends StompV11TestBase { int count = 1000; final CountDownLatch latch = new CountDownLatch(count); consumer.setMessageListener(new MessageListener() { + @Override public void onMessage(Message arg0) { TextMessage m = (TextMessage) arg0; latch.countDown(); http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/transports/netty/NettyConnectorWithHTTPUpgradeTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/transports/netty/NettyConnectorWithHTTPUpgradeTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/transports/netty/NettyConnectorWithHTTPUpgradeTest.java index e455ac2..edcb588 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/transports/netty/NettyConnectorWithHTTPUpgradeTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/transports/netty/NettyConnectorWithHTTPUpgradeTest.java @@ -137,6 +137,7 @@ public class NettyConnectorWithHTTPUpgradeTest extends ActiveMQTestBase { startWebServer(HTTP_PORT); } + @Override @After public void tearDown() throws Exception { stopWebServer(); http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/xa/BasicXaTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/xa/BasicXaTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/xa/BasicXaTest.java index 7d82a25..ce253a7 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/xa/BasicXaTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/xa/BasicXaTest.java @@ -852,6 +852,7 @@ public class BasicXaTest extends ActiveMQTestBase { this.session = session; } + @Override public void onMessage(final ClientMessage message) { Xid xid = new XidImpl(UUIDGenerator.getInstance().generateStringUUID().getBytes(), 1, UUIDGenerator.getInstance().generateStringUUID().getBytes()); try { http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/xa/XaTimeoutTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/xa/XaTimeoutTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/xa/XaTimeoutTest.java index f244238..ea9d24a 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/xa/XaTimeoutTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/xa/XaTimeoutTest.java @@ -376,6 +376,7 @@ public class XaTimeoutTest extends ActiveMQTestBase { clientSession.setTransactionTimeout(2); MessageHandler handler = new MessageHandler() { + @Override public void onMessage(ClientMessage message) { try { latchReceives.countDown(); http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/util/NonSerializableFactory.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/util/NonSerializableFactory.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/util/NonSerializableFactory.java index aea3b70..0ace718 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/util/NonSerializableFactory.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/util/NonSerializableFactory.java @@ -85,6 +85,7 @@ public final class NonSerializableFactory implements ObjectFactory { return NonSerializableFactory.getWrapperMap().get(name); } + @Override public Object getObjectInstance(final Object obj, final Name name, final Context nameCtx, http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/25ae4724/tests/jms-tests/src/test/java/org/apache/activemq/artemis/jms/tests/AcknowledgementTest.java ---------------------------------------------------------------------- diff --git a/tests/jms-tests/src/test/java/org/apache/activemq/artemis/jms/tests/AcknowledgementTest.java b/tests/jms-tests/src/test/java/org/apache/activemq/artemis/jms/tests/AcknowledgementTest.java index 45f443a..b4edc54 100644 --- a/tests/jms-tests/src/test/java/org/apache/activemq/artemis/jms/tests/AcknowledgementTest.java +++ b/tests/jms-tests/src/test/java/org/apache/activemq/artemis/jms/tests/AcknowledgementTest.java @@ -936,6 +936,7 @@ public class AcknowledgementTest extends JMSTestCase { ProxyAssertSupport.assertTrue("failed to receive all messages", latch.await(2000, MILLISECONDS)); } + @Override public abstract void onMessage(Message m); }