You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2013/08/27 22:42:58 UTC
svn commit: r1517978 - in
/activemq/trunk/activemq-unit-tests/src/test/java/org/apache/activemq/bugs:
AMQ3140Test.java AMQ3141Test.java
Author: tabish
Date: Tue Aug 27 20:42:57 2013
New Revision: 1517978
URL: http://svn.apache.org/r1517978
Log:
fix tests
Modified:
activemq/trunk/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3140Test.java
activemq/trunk/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3141Test.java
Modified: activemq/trunk/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3140Test.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3140Test.java?rev=1517978&r1=1517977&r2=1517978&view=diff
==============================================================================
--- activemq/trunk/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3140Test.java (original)
+++ activemq/trunk/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3140Test.java Tue Aug 27 20:42:57 2013
@@ -86,7 +86,7 @@ public class AMQ3140Test {
broker = new BrokerService();
broker.setSchedulerSupport(true);
- broker.setPersistent(false);
+ broker.setPersistent(true);
broker.setDeleteAllMessagesOnStartup(true);
broker.setDataDirectory("target");
broker.setSchedulerDirectoryFile(schedulerDirectory);
@@ -115,6 +115,7 @@ public class AMQ3140Test {
MessageConsumer consumer = session.createConsumer(session.createQueue(QUEUE_NAME));
consumer.setMessageListener(new MessageListener() {
+ @Override
public void onMessage(Message message) {
receiveCounter.incrementAndGet();
}
Modified: activemq/trunk/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3141Test.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3141Test.java?rev=1517978&r1=1517977&r2=1517978&view=diff
==============================================================================
--- activemq/trunk/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3141Test.java (original)
+++ activemq/trunk/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3141Test.java Tue Aug 27 20:42:57 2013
@@ -56,7 +56,7 @@ public class AMQ3141Test {
public void setup() throws Exception {
broker = new BrokerService();
- broker.setPersistent(false);
+ broker.setPersistent(true);
broker.setSchedulerSupport(true);
broker.setDataDirectory("target");
broker.setUseJmx(false);
@@ -95,6 +95,7 @@ public class AMQ3141Test {
MessageConsumer consumer = session.createConsumer(session.createQueue(QUEUE_NAME));
consumer.setMessageListener(new MessageListener() {
+ @Override
public void onMessage(Message message) {
messageCountDown.countDown();
}