Skip to content

Commit

Permalink
Update VcrServerTest.java
Browse files Browse the repository at this point in the history
  • Loading branch information
snalli committed Dec 21, 2023
1 parent 24a5b13 commit 7ef613b
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions ambry-vcr/src/test/java/com/github/ambry/vcr/VcrServerTest.java
Original file line number Diff line number Diff line change
Expand Up @@ -73,8 +73,8 @@ public static void cleanUp() throws IOException {
@Test
public void testVCRServerWithStaticCluster() throws Exception {
VerifiableProperties verifiableProperties = getStaticClusterVcrProps();
com.github.ambry.cloud.VcrServer
vcrServer = new com.github.ambry.cloud.VcrServer(verifiableProperties, mockClusterAgentsFactory, notificationSystem, null);
VcrServer
vcrServer = new VcrServer(verifiableProperties, mockClusterAgentsFactory, notificationSystem, null);
vcrServer.startup();
Assert.assertNull("Expected null compactor", vcrServer.getVcrReplicationManager().getCloudStorageCompactor());
vcrServer.shutdown();
Expand All @@ -91,8 +91,8 @@ public void testVCRServerWithReporterFactory() throws Exception {
ObjectNameFactory spyObjectNameFactory = spy(new DefaultObjectNameFactory());
Function<MetricRegistry, JmxReporter> reporterFactory =
reporter -> JmxReporter.forRegistry(reporter).createsObjectNamesWith(spyObjectNameFactory).build();
com.github.ambry.cloud.VcrServer vcrServer =
new com.github.ambry.cloud.VcrServer(verifiableProperties, mockClusterAgentsFactory, notificationSystem, reporterFactory);
VcrServer vcrServer =
new VcrServer(verifiableProperties, mockClusterAgentsFactory, notificationSystem, reporterFactory);
vcrServer.startup();
// check that the custom ObjectNameFactory specified in reporterFactory was used.
verify(spyObjectNameFactory, atLeastOnce()).createName(anyString(), anyString(), anyString());
Expand Down Expand Up @@ -120,7 +120,7 @@ public void testVCRServerWithHelixCluster() throws Exception {
CloudDestinationFactory cloudDestinationFactory = new LatchBasedInMemoryCloudDestinationFactory(
new LatchBasedInMemoryCloudDestination(Collections.emptyList(), mockClusterMap));
VerifiableProperties verifiableProperties = new VerifiableProperties(props);
com.github.ambry.cloud.VcrServer vcrServer =
VcrServer vcrServer =
new VcrServer(verifiableProperties, mockClusterAgentsFactory, notificationSystem, cloudDestinationFactory,
null);
vcrServer.startup();
Expand Down

0 comments on commit 7ef613b

Please sign in to comment.