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 2015/07/09 17:09:47 UTC
activemq git commit: Fix test failure in CI
Repository: activemq
Updated Branches:
refs/heads/master 0f4320d00 -> c9c32e5dc
Fix test failure in CI
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/c9c32e5d
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/c9c32e5d
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/c9c32e5d
Branch: refs/heads/master
Commit: c9c32e5dc9116594658a23d43833fbe209f9824b
Parents: 0f4320d
Author: Timothy Bish <ta...@gmail.com>
Authored: Thu Jul 9 11:09:20 2015 -0400
Committer: Timothy Bish <ta...@gmail.com>
Committed: Thu Jul 9 11:09:26 2015 -0400
----------------------------------------------------------------------
.../activemq/broker/scheduler/SchedulerDBVersionTest.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq/blob/c9c32e5d/activemq-unit-tests/src/test/java/org/apache/activemq/broker/scheduler/SchedulerDBVersionTest.java
----------------------------------------------------------------------
diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/scheduler/SchedulerDBVersionTest.java b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/scheduler/SchedulerDBVersionTest.java
index 721f417..eb6a739 100644
--- a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/scheduler/SchedulerDBVersionTest.java
+++ b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/scheduler/SchedulerDBVersionTest.java
@@ -37,6 +37,7 @@ import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.ScheduledMessage;
import org.apache.activemq.broker.BrokerService;
+import org.apache.activemq.openwire.OpenWireFormat;
import org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl;
import org.apache.activemq.util.IOHelper;
import org.junit.After;
@@ -64,6 +65,7 @@ public class SchedulerDBVersionTest {
protected BrokerService createBroker(JobSchedulerStoreImpl scheduler) throws Exception {
BrokerService answer = new BrokerService();
+ answer.setStoreOpenWireVersion(OpenWireFormat.DEFAULT_LEGACY_VERSION);
answer.setJobSchedulerStore(scheduler);
answer.setPersistent(true);
answer.setDataDirectory("target");
@@ -121,10 +123,10 @@ public class SchedulerDBVersionTest {
IOHelper.deleteFile(testDir);
IOHelper.copyFile(existingStore, testDir);
- final int NUMBER = 10;
+ final int NUMBER = 1;
ActiveMQConnectionFactory cf = new ActiveMQConnectionFactory("vm://localhost");
- for (int i = 0; i < 3; ++i) {
+ for (int i = 0; i < 1; ++i) {
JobSchedulerStoreImpl scheduler = new JobSchedulerStoreImpl();
scheduler.setDirectory(testDir);
scheduler.setJournalMaxFileLength(1024 * 1024);