@Test public void testTriggerStart() { SdxCluster sdxCluster = sdxCluster(); sdxCluster.setEnvCrn("envCrn"); DescribeFreeIpaResponse freeIpaResponse = new DescribeFreeIpaResponse(); freeIpaResponse.setStatus(Status.AVAILABLE); when(freeipaService.describe("envCrn")).thenReturn(freeIpaResponse); underTest.triggerStartIfClusterNotRunning(sdxCluster); verify(sdxReactorFlowManager).triggerSdxStartFlow(sdxCluster); }
public FlowIdentifier triggerStartIfClusterNotRunning(SdxCluster cluster) { MDCBuilder.buildMdcContext(cluster); checkFreeipaRunning(cluster.getEnvCrn()); return sdxReactorFlowManager.triggerSdxStartFlow(cluster); }
SdxStartService { public FlowIdentifier triggerStartIfClusterNotRunning(SdxCluster cluster) { MDCBuilder.buildMdcContext(cluster); checkFreeipaRunning(cluster.getEnvCrn()); return sdxReactorFlowManager.triggerSdxStartFlow(cluster); } }
SdxStartService { public FlowIdentifier triggerStartIfClusterNotRunning(SdxCluster cluster) { MDCBuilder.buildMdcContext(cluster); checkFreeipaRunning(cluster.getEnvCrn()); return sdxReactorFlowManager.triggerSdxStartFlow(cluster); }  }
SdxStartService { public FlowIdentifier triggerStartIfClusterNotRunning(SdxCluster cluster) { MDCBuilder.buildMdcContext(cluster); checkFreeipaRunning(cluster.getEnvCrn()); return sdxReactorFlowManager.triggerSdxStartFlow(cluster); }  FlowIdentifier triggerStartIfClusterNotRunning(SdxCluster cluster); void start(Long sdxId); void waitCloudbreakCluster(Long sdxId, PollingConfig pollingConfig); }
SdxStartService { public FlowIdentifier triggerStartIfClusterNotRunning(SdxCluster cluster) { MDCBuilder.buildMdcContext(cluster); checkFreeipaRunning(cluster.getEnvCrn()); return sdxReactorFlowManager.triggerSdxStartFlow(cluster); }  FlowIdentifier triggerStartIfClusterNotRunning(SdxCluster cluster); void start(Long sdxId); void waitCloudbreakCluster(Long sdxId, PollingConfig pollingConfig);  }