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

ACTIVEMQ6-102 - fix check for scaledown when creating journal loader 

https://issues.apache.org/jira/browse/ACTIVEMQ6-102
This commit is contained in:
Andy Taylor 2015-05-11 13:22:09 +01:00 committed by Clebert Suconic
parent 18c9e790f6
commit 60906e3754
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,