ARTEMIS-3297 Fixing Tests that do not support retention on the file system

This commit is contained in:
Clebert Suconic 2021-05-18 22:27:39 -04:00
parent e06555bdec
commit 5e622a642d
3 changed files with 17 additions and 2 deletions

View File

@ -185,6 +185,9 @@ public abstract class FailoverTestBase extends ActiveMQTestBase {
return new InVMNodeManager(true, backupConfig.getJournalLocation());
}
protected boolean supportsRetention() {
return true;
}
protected void createReplicatedConfigs() throws Exception {
final TransportConfiguration liveConnector = getConnectorTransportConfiguration(true);
@ -207,8 +210,10 @@ public abstract class FailoverTestBase extends ActiveMQTestBase {
liveServer = createTestableServer(liveConfig);
liveServer.getServer().getConfiguration().setJournalRetentionDirectory(getJournalDir(0, false) + "_retention");
backupServer.getServer().getConfiguration().setJournalRetentionDirectory(getJournalDir(0, true) + "_retention");
if (supportsRetention()) {
liveServer.getServer().getConfiguration().setJournalRetentionDirectory(getJournalDir(0, false) + "_retention");
backupServer.getServer().getConfiguration().setJournalRetentionDirectory(getJournalDir(0, true) + "_retention");
}
}
protected void setupHAPolicyConfiguration() {

View File

@ -28,6 +28,11 @@ public class ReplicatedLargeMessageWithDelayFailoverTest extends ReplicatedLarge
private BackupSyncDelay syncDelay;
@Override
protected boolean supportsRetention() {
return false;
}
@Override
@Before
public void setUp() throws Exception {

View File

@ -27,6 +27,11 @@ public class ReplicatedWithDelayFailoverTest extends ReplicatedFailoverTest {
private BackupSyncDelay syncDelay;
@Override
protected boolean supportsRetention() {
return false;
}
@Override
@Before
public void setUp() throws Exception {