Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

This closes #239 - scaledown check on the journal

This commit is contained in:
Clebert Suconic 2015-05-11 10:20:00 -04:00
parent 18c9e790f6 60906e3754
commit 0f724aea53
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/SharedNothingBackupActivation.java
View File

@ -339,7 +339,7 @@ public final class SharedNothingBackupActivation extends Activation
@Override
public JournalLoader createJournalLoader(PostOffice postOffice, PagingManager pagingManager, StorageManager storageManager, QueueFactory queueFactory, NodeManager nodeManager, ManagementService managementService, GroupingHandler groupingHandler, Configuration configuration, ActiveMQServer parentServer) throws ActiveMQException
{
if (replicaPolicy.getScaleDownPolicy() != null)
if (replicaPolicy.getScaleDownPolicy() != null && replicaPolicy.getScaleDownPolicy().isEnabled())
{
return new BackupRecoveryJournalLoader(postOffice,
pagingManager,

2
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/SharedStoreBackupActivation.java
View File

@ -194,7 +194,7 @@ public final class SharedStoreBackupActivation extends Activation
@Override
public JournalLoader createJournalLoader(PostOffice postOffice, PagingManager pagingManager, StorageManager storageManager, QueueFactory queueFactory, NodeManager nodeManager, ManagementService managementService, GroupingHandler groupingHandler, Configuration configuration, ActiveMQServer parentServer) throws ActiveMQException
{
if (sharedStoreSlavePolicy.getScaleDownPolicy() != null)
if (sharedStoreSlavePolicy.getScaleDownPolicy() != null && sharedStoreSlavePolicy.getScaleDownPolicy().isEnabled())
{
return new BackupRecoveryJournalLoader(postOffice,
pagingManager,