fix tests

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1517978 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Timothy A. Bish 2013-08-27 20:42:57 +00:00
parent 61877f3477
commit 8b61c3919c
2 changed files with 4 additions and 2 deletions

View File

@ -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();
}

View File

@ -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();
}