Skip to content

Commit

Permalink
Remove unused code. (sofastack#673)
Browse files Browse the repository at this point in the history
* remove unused code
  • Loading branch information
zhaojigang authored and leizhiyuan committed Jun 17, 2019
1 parent 9dfc25b commit ad8d7de
Show file tree
Hide file tree
Showing 3 changed files with 2 additions and 71 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ public final class ProviderInfoAttrs {

/*=====字段配置=====*/
/**
* 配置key:rpcVer
* 配置key:serialization
*/
public static final String ATTR_SERIALIZATION = RpcConstants.CONFIG_KEY_SERIALIZATION;
/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -129,13 +129,9 @@ public void register(ProviderConfig config) {
* @param group 服务分组
*/
protected void doRegister(String appName, String serviceName, String serviceData, String group) {
PublisherRegistration publisherRegistration;
// 生成注册对象,并添加额外属性
publisherRegistration = new PublisherRegistration(serviceName);

PublisherRegistration publisherRegistration = new PublisherRegistration(serviceName);
publisherRegistration.setGroup(group);
addAttributes(publisherRegistration, group);

// 去注册
SofaRegistryClient.getRegistryClient(appName, registryConfig).register(publisherRegistration, serviceData);
}
Expand Down Expand Up @@ -296,20 +292,6 @@ public void batchUnSubscribe(List<ConsumerConfig> configs) {
}
}

/**
* 添加额外的属性
*
* @param publisherRegistration 注册或者订阅对象
* @param group 分组
*/
private void addAttributes(PublisherRegistration publisherRegistration, String group) {
// if group == null; group = "DEFAULT_GROUP"
if (StringUtils.isNotEmpty(group)) {
publisherRegistration.setGroup(group);
}

}

/**
* 添加额外的属性
*
Expand Down

This file was deleted.

0 comments on commit ad8d7de

Please sign in to comment.