Skip to content

Commit

Permalink
fix typo, SofaRegsitryClient -> SofaRegistryClient (sofastack#581)
Browse files Browse the repository at this point in the history
  • Loading branch information
dulong authored and JervyShi committed Apr 12, 2019
1 parent d7825d1 commit 1230c2a
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -137,7 +137,7 @@ protected void doRegister(String appName, String serviceName, String serviceData
addAttributes(publisherRegistration, group);

// 去注册
SofaRegsitryClient.getRegistryClient(appName, registryConfig).register(publisherRegistration, serviceData);
SofaRegistryClient.getRegistryClient(appName, registryConfig).register(publisherRegistration, serviceData);
}

@Override
Expand Down Expand Up @@ -183,7 +183,7 @@ public void unRegister(ProviderConfig config) {
*/
protected void doUnRegister(String appName, String serviceName, String group) {

SofaRegsitryClient.getRegistryClient(appName, registryConfig).unregister(serviceName, group,
SofaRegistryClient.getRegistryClient(appName, registryConfig).unregister(serviceName, group,
RegistryType.PUBLISHER);
}

Expand Down Expand Up @@ -246,10 +246,10 @@ public List<ProviderGroup> subscribe(ConsumerConfig config) {
// 去配置中心订阅

// 去注册
listSubscriber = SofaRegsitryClient.getRegistryClient(appName, registryConfig).register(
listSubscriber = SofaRegistryClient.getRegistryClient(appName, registryConfig).register(
subscriberRegistration);

attrSubscriber = SofaRegsitryClient.getRegistryClient(appName, registryConfig).register(configRegistration);
attrSubscriber = SofaRegistryClient.getRegistryClient(appName, registryConfig).register(configRegistration);

// 放入缓存
subscribers.put(serviceName, listSubscriber);
Expand All @@ -269,13 +269,13 @@ public void unSubscribe(ConsumerConfig config) {
callback.remove(serviceName, config);
if (callback.getListenerNum() == 0) {
// 已经没人订阅这个data Key了
SofaRegsitryClient.getRegistryClient(appName, registryConfig).unregister(serviceName,
SofaRegistryClient.getRegistryClient(appName, registryConfig).unregister(serviceName,
subscriber.getGroup(),
RegistryType.SUBSCRIBER);
subscribers.remove(serviceName);

// 已经没人订阅这个config Key了
SofaRegsitryClient.getRegistryClient(appName, registryConfig).unregister(serviceName,
SofaRegistryClient.getRegistryClient(appName, registryConfig).unregister(serviceName,
subscriber.getGroup(),
RegistryType.CONFIGURATOR);
configurators.remove(serviceName);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,9 +25,9 @@

/**
* @author bystander
* @version $Id: SofaRegsitryClient.java, v 0.1 2018年03月13日 10:20 AM bystander Exp $
* @version $Id: SofaRegistryClient.java, v 0.1 2018年03月13日 10:20 AM bystander Exp $
*/
public class SofaRegsitryClient {
public class SofaRegistryClient {

public static final String LOCAL_DATACENTER = "DefaultDataCenter";
public static final String LOCAL_REGION = "DEFAULT_ZONE";
Expand Down

0 comments on commit 1230c2a

Please sign in to comment.