MBeanProxyInfoRepository.java 文件源码

/**
 * Add the {@link ProxyInfo} into repository for future quick access
 * 
 * @param member Distributed Member
 * @param proxyInfo Proxy Info instance
 */
protected void addProxyToRepository(DistributedMember member, ProxyInfo proxyInfo) {
  ObjectName objectName = proxyInfo.getObjectName();
  if (logger.isTraceEnabled()) {
    logger.trace("ADDED TO PROXY REPO : {}", proxyInfo.getObjectName());
  }

  objectNameIndex.put(objectName, proxyInfo);
  if (memberIndex.get(member) != null) {
    memberIndex.get(member).add(proxyInfo.getObjectName());
  } else {
    Set<ObjectName> proxyInfoSet = new CopyOnWriteArraySet<ObjectName>();
    proxyInfoSet.add(proxyInfo.getObjectName());
    memberIndex.put(member, proxyInfoSet);
  }

}