Skip to content

Commit

Permalink
0005101: fix tes
Browse files Browse the repository at this point in the history
  • Loading branch information
erilong committed Oct 25, 2021
1 parent 65522b0 commit cde8da9
Showing 1 changed file with 6 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -34,6 +34,7 @@

import org.jumpmind.db.model.Table;
import org.jumpmind.symmetric.ISymmetricEngine;
import org.jumpmind.symmetric.common.ParameterConstants;
import org.jumpmind.symmetric.io.data.DataEventType;
import org.jumpmind.symmetric.model.Data;
import org.jumpmind.symmetric.model.DataMetaData;
Expand All @@ -42,6 +43,7 @@
import org.jumpmind.symmetric.model.NodeGroupLink;
import org.jumpmind.symmetric.model.TriggerHistory;
import org.jumpmind.symmetric.service.IConfigurationService;
import org.jumpmind.symmetric.service.IParameterService;
import org.junit.jupiter.api.Test;

public class ConfigurationChangedDataRouterTest {
Expand Down Expand Up @@ -234,10 +236,14 @@ protected DataMetaData buildDataMetaData(String tableName, String nodeId) {
protected IDataRouter buildTestableRouter(final Node nodeThatIsRouting,
final List<NodeGroupLink> links, final NetworkedNode root) {
IConfigurationService configService = mock(IConfigurationService.class);
IParameterService paramService = mock(IParameterService.class);
when(configService.isMasterToMaster()).thenReturn(false);
ISymmetricEngine engine = mock(ISymmetricEngine.class);
when(engine.getConfigurationService()).thenReturn(configService);
when(engine.getParameterService()).thenReturn(paramService);
when(engine.getTablePrefix()).thenReturn("sym");
when(paramService.is(ParameterConstants.AUTO_SYNC_TRIGGERS)).thenReturn(true);
when(paramService.is(ParameterConstants.AUTO_SYNC_TRIGGERS_AFTER_CONFIG_CHANGED)).thenReturn(true);
ConfigurationChangedDataRouter router = new ConfigurationChangedDataRouter(engine) {
@Override
protected Node findIdentity() {
Expand Down

0 comments on commit cde8da9

Please sign in to comment.