Rename NacosGatewayLocatorHeartBeat

pull/2881/head
ruansheng 2 years ago
parent 191a267ac8
commit de8d2c8cbf

@ -35,9 +35,9 @@ import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
* @author yuhuangbin
* @author ruansheng
*/
public class NacosGatewayLocatorHeartBeat implements ApplicationEventPublisherAware, SmartLifecycle {
public class GatewayLocatorHeartBeatPublisher implements ApplicationEventPublisherAware, SmartLifecycle {
private static final Logger log = LoggerFactory.getLogger(NacosGatewayLocatorHeartBeat.class);
private static final Logger log = LoggerFactory.getLogger(GatewayLocatorHeartBeatPublisher.class);
private final NacosDiscoveryProperties nacosDiscoveryProperties;
@ -47,7 +47,7 @@ public class NacosGatewayLocatorHeartBeat implements ApplicationEventPublisherAw
private ApplicationEventPublisher publisher;
private ScheduledFuture<?> watchFuture;
public NacosGatewayLocatorHeartBeat(NacosDiscoveryProperties nacosDiscoveryProperties) {
public GatewayLocatorHeartBeatPublisher(NacosDiscoveryProperties nacosDiscoveryProperties) {
this.nacosDiscoveryProperties = nacosDiscoveryProperties;
this.taskScheduler = getTaskScheduler();
}

@ -72,8 +72,8 @@ public class NacosDiscoveryClientConfiguration {
@Bean
@ConditionalOnMissingBean
@ConditionalOnProperty(value = "spring.cloud.gateway.discovery.locator.enabled", matchIfMissing = false)
public NacosGatewayLocatorHeartBeat nacosGatewayHeartBeat(NacosDiscoveryProperties nacosDiscoveryProperties) {
return new NacosGatewayLocatorHeartBeat(nacosDiscoveryProperties);
public GatewayLocatorHeartBeatPublisher gatewayLocatorHeartBeatPublisher(NacosDiscoveryProperties nacosDiscoveryProperties) {
return new GatewayLocatorHeartBeatPublisher(nacosDiscoveryProperties);
}
}

@ -77,18 +77,18 @@ public class NacosDiscoveryClientConfigurationTest {
}
@Test
public void testDefaultNacosGatewayLocatorHeartBeat() {
public void testDefaultGatewayLocatorHeartBeatPublisher() {
contextRunner.run(context ->
assertThat(context).doesNotHaveBean(NacosGatewayLocatorHeartBeat.class)
assertThat(context).doesNotHaveBean(GatewayLocatorHeartBeatPublisher.class)
);
}
@Test
public void testNacosGatewayLocatorHeartBeatEnabled() {
public void testGatewayLocatorHeartBeatPublisherEnabled() {
contextRunner
.withPropertyValues("spring.cloud.gateway.discovery.locator.enabled=true")
.run(context ->
assertThat(context).hasSingleBean(NacosGatewayLocatorHeartBeat.class)
assertThat(context).hasSingleBean(GatewayLocatorHeartBeatPublisher.class)
);
}

Loading…
Cancel
Save