org.wso2.carbon.registry.core.Resource.getContent()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(14.2k)|赞(0)|评价(0)|浏览(85)

本文整理了Java中org.wso2.carbon.registry.core.Resource.getContent方法的一些代码示例，展示了Resource.getContent的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Resource.getContent方法的具体详情如下：
包路径：org.wso2.carbon.registry.core.Resource
类名称：Resource
方法名：getContent

Resource.getContent介绍

暂无

代码示例

代码示例来源：origin: org.wso2.carbon.governance/org.wso2.carbon.governance.registry.extensions

public static String getResourceContent(Resource tempResource) throws RegistryException {
  if (tempResource.getContent() instanceof String) {
    return (String) tempResource.getContent();
  } else if (tempResource.getContent() instanceof byte[]) {
    return RegistryUtils.decodeBytes((byte[]) tempResource.getContent());
  }
  return null;
}

代码示例来源：origin: org.wso2.carbon.governance/org.wso2.carbon.governance.list

private static String convertContentToString(Resource resource) throws RegistryException {
  if (resource.getContent() instanceof String) {
    return RegistryUtils.decodeBytes(((String) resource.getContent()).getBytes());
  } else if (resource.getContent() instanceof byte[]) {
    return RegistryUtils.decodeBytes((byte[]) resource.getContent());
  }
  return RegistryUtils.decodeBytes("".getBytes());
}

代码示例来源：origin: org.wso2.carbon.business-process/org.wso2.carbon.bpel

private List<String> getVersionsOfPackage(String packageLocation) throws RegistryException {
  List<String> versions = new ArrayList<String>();
  String versionsLocation = packageLocation + BPELConstants.BPEL_PACKAGE_VERSIONS;
  // If a new addition of a process fails to deploy there there will not be a collection called
  // version
  if (configRegistry.resourceExists(versionsLocation)) {
    Resource versionsResource = configRegistry.get(versionsLocation);
    // The above registry resource we retrieve only contains set of child collections.
    // So we can directly cast the returned object to a string array.
    String[] children = (String[]) versionsResource.getContent();
    for (String child : children) {
      versions.add(child.substring(child.lastIndexOf("/") + 1));
    }
    Collections.sort(versions, Utils.BY_VERSION);
  }
  return versions;
}

代码示例来源：origin: org.wso2.carbon.governance/org.wso2.carbon.governance.registry.extensions

private static String buildOMContent(Resource resource, StatCollection currentCollection) throws Exception {
  String content = null;
  String property = resource.getProperty(REGISTRY_LIFECYCLE_HISTORY_ORDER);
  int newOrder = 0;
  if (property != null) {
    newOrder = Integer.parseInt(property) + 1;
  }
  resource.setProperty(REGISTRY_LIFECYCLE_HISTORY_ORDER, "" + newOrder);
  if (resource.getContent() != null) {
    if (resource.getContent() instanceof String) {
      content = (String) resource.getContent();
    } else if (resource.getContent() instanceof byte[]) {
      content = RegistryUtils.decodeBytes((byte[]) resource.getContent());
    }
  }
  if (content == null) {
    content = buildInitialOMElement().toString();
  }
  return addNewContentElement(content, currentCollection, newOrder);
}

代码示例来源：origin: org.wso2.carbon.identity/org.wso2.carbon.identity.entitlement

/**
 * @param policyId
 * @param finder
 * @return
 * @throws EntitlementException
 */
public synchronized AbstractPolicy readPolicy(String policyId, PolicyFinder finder)
    throws EntitlementException {
  Resource resource = store.getPolicy(policyId, PDPConstants.ENTITLEMENT_POLICY_PAP);
  if (resource != null) {
    try {
      String policy = new String((byte[]) resource.getContent(), Charset.forName("UTF-8"));
      return PAPPolicyReader.getInstance(null).getPolicy(policy);
    } catch (RegistryException e) {
      log.error("Error while parsing entitlement policy", e);
      throw new EntitlementException("Error while loading entitlement policy");
    }
  }
  return null;
}

代码示例来源：origin: org.wso2.carbon.identity.framework/org.wso2.carbon.identity.entitlement

/**
 * @param policyId
 * @param finder
 * @return
 * @throws EntitlementException
 */
public synchronized AbstractPolicy readPolicy(String policyId, PolicyFinder finder)
    throws EntitlementException {
  Resource resource = store.getPolicy(policyId, PDPConstants.ENTITLEMENT_POLICY_PAP);
  if (resource != null) {
    try {
      String policy = new String((byte[]) resource.getContent(), Charset.forName("UTF-8"));
      return PAPPolicyReader.getInstance(null).getPolicy(policy);
    } catch (RegistryException e) {
      log.error("Error while parsing entitlement policy", e);
      throw new EntitlementException("Error while loading entitlement policy");
    }
  }
  return null;
}

代码示例来源：origin: org.wso2.carbon.governance/org.wso2.carbon.mashup.javascript.hostobjects.registry

public Object jsGet_content() throws CarbonException {
  try {
    Object result = this.resource.getContent();
    String mediaType = this.resource.getMediaType();
    if (result instanceof byte[]) {
      //if mediaType is xml related one, we return an e4x xml object
      if(mediaType.matches(".*[\\/].*[xX][mM][lL].*")) {
        return context.newObject(this, "XML", new Object[]{new String((byte[]) result)});
      }
      return new String((byte[]) result);
    } else if (result instanceof String[]) {
      return new NativeArray((String[])result);
    } else {
      return Context.toObject(result, this);
    }
  } catch (RegistryException e) {
    throw new CarbonException("Registry Exception while reading content property", e);
  }
}

代码示例来源：origin: org.wso2.carbon.business-process/org.wso2.carbon.bpel

public List<BPELPackageInfo> getBPELPackages() throws Exception {
  List<BPELPackageInfo> bpelPackages = new ArrayList<BPELPackageInfo>();
  try {
    if (configRegistry.resourceExists(BPELConstants.REG_PATH_OF_BPEL_PACKAGES)) {
      Resource parentCollection = configRegistry.get(
          BPELConstants.REG_PATH_OF_BPEL_PACKAGES);
      // The above registry resource we retrieve only contains set of child collections.
      // So we can directly cast the returned object to a string array.
      String[] children = (String[]) parentCollection.getContent();
      for (int i = children.length - 1; i >= 0; i--) {
        bpelPackages.add(getBPELPackageInfo(children[i]));
      }
      return sortByPackageName(bpelPackages);
    }
  } catch (RegistryException re) {
    handleExceptionWithRollback("Unable to get BPEL Packages from Repository.", re);
  }
  return null;
}

代码示例来源：origin: org.wso2.carbon.registry/org.wso2.carbon.registry.profiles

public ProfilesBean getUserProfile(String path) throws RegistryException,UserStoreException{
    Registry registry = getConfigSystemRegistry();
    Resource resource = registry.get(path);
    String contentString = (String)resource.getContent();

    ProfilesBean profbean = new ProfilesBean();
    profbean.setMainDataString(contentString);
//        profilebean.calculatevalues();
    return profbean;
  }
}

代码示例来源：origin: org.wso2.carbon.governance/org.wso2.carbon.governance.lcm

public static String getLifecycleConfiguration(String name, Registry registry) throws RegistryException, XMLStreamException {
  String path = getContextRoot() + name;
  Resource resource;
  if (lifeCycleExists(name, registry)) {
    resource = registry.get(path);
    return RegistryUtils.decodeBytes((byte[])resource.getContent());
  }
  return null;
}
public static String getLifecycleConfigurationVersion(String name, Registry registry) throws RegistryException, XMLStreamException {

代码示例来源：origin: org.wso2.carbon.identity.governance/org.wso2.carbon.identity.recovery

/**
 * Create a challenge question object from the registry resource
 *
 * @param resource
 * @return
 */
private ChallengeQuestion createChallengeQuestion(Resource resource) throws RegistryException {
  ChallengeQuestion challengeQuestion = null;
  byte[] resourceContent = (byte[]) resource.getContent();
  String questionText = new String(resourceContent, Charset.forName("UTF-8"));
  String questionSetId = resource.getProperty(IdentityRecoveryConstants.Questions.CHALLENGE_QUESTION_SET_ID);
  String questionId = resource.getProperty(IdentityRecoveryConstants.Questions.CHALLENGE_QUESTION_ID);
  String questionLocale = resource.getProperty(IdentityRecoveryConstants.Questions.CHALLENGE_QUESTION_LOCALE);
  if (questionSetId != null) {
    if (IdentityUtil.isBlank(questionLocale)) {
      questionLocale = LOCALE_EN_US;
    }
    challengeQuestion = new ChallengeQuestion(questionSetId, questionId, questionText, questionLocale);
  }
  return challengeQuestion;
}

代码示例来源：origin: org.wso2.carbon.identity.framework/org.wso2.carbon.identity.core

public SAMLSSOServiceProviderDO[] getServiceProviders() throws IdentityException {
  SAMLSSOServiceProviderDO[] serviceProvidersList = new SAMLSSOServiceProviderDO[0];
  try {
    if (registry.resourceExists(IdentityRegistryResources.SAML_SSO_SERVICE_PROVIDERS)) {
      String[] providers = (String[]) registry.get(
          IdentityRegistryResources.SAML_SSO_SERVICE_PROVIDERS).getContent();
      if (providers != null) {
        serviceProvidersList = new SAMLSSOServiceProviderDO[providers.length];
        for (int i = 0; i < providers.length; i++) {
          serviceProvidersList[i] = resourceToObject(registry.get(providers[i]));
        }
      }
    }
  } catch (RegistryException e) {
    log.error("Error reading Service Providers from Registry", e);
    throw IdentityException.error("Error reading Service Providers from Registry", e);
  }
  return serviceProvidersList;
}

代码示例来源：origin: org.wso2.carbon.identity/org.wso2.carbon.identity.core

public SAMLSSOServiceProviderDO[] getServiceProviders() throws IdentityException {
  SAMLSSOServiceProviderDO[] serviceProvidersList = new SAMLSSOServiceProviderDO[0];
  try {
    if (registry.resourceExists(IdentityRegistryResources.SAML_SSO_SERVICE_PROVIDERS)) {
      String[] providers = (String[]) registry.get(
          IdentityRegistryResources.SAML_SSO_SERVICE_PROVIDERS).getContent();
      if (providers != null) {
        serviceProvidersList = new SAMLSSOServiceProviderDO[providers.length];
        for (int i = 0; i < providers.length; i++) {
          serviceProvidersList[i] = resourceToObject(registry.get(providers[i]));
        }
      }
    }
  } catch (RegistryException e) {
    log.error("Error reading Service Providers from Registry", e);
    throw IdentityException.error("Error reading Service Providers from Registry", e);
  }
  return serviceProvidersList;
}

代码示例来源：origin: wso2/carbon-identity-framework

public SAMLSSOServiceProviderDO[] getServiceProviders() throws IdentityException {
  SAMLSSOServiceProviderDO[] serviceProvidersList = new SAMLSSOServiceProviderDO[0];
  try {
    if (registry.resourceExists(IdentityRegistryResources.SAML_SSO_SERVICE_PROVIDERS)) {
      String[] providers = (String[]) registry.get(
          IdentityRegistryResources.SAML_SSO_SERVICE_PROVIDERS).getContent();
      if (providers != null) {
        serviceProvidersList = new SAMLSSOServiceProviderDO[providers.length];
        for (int i = 0; i < providers.length; i++) {
          serviceProvidersList[i] = resourceToObject(registry.get(providers[i]));
        }
      }
    }
  } catch (RegistryException e) {
    log.error("Error reading Service Providers from Registry", e);
    throw IdentityException.error("Error reading Service Providers from Registry", e);
  }
  return serviceProvidersList;
}

代码示例来源：origin: org.wso2.carbon.registry/org.wso2.carbon.registry.indexing

/**
 * This method is used to get rxt data.
 *
 * @param userRegistry userRegistry.
 * @return
 * @throws RegistryException
 */
public static Map<String, List<String>> getRxtData(UserRegistry userRegistry) throws RegistryException {
  String[] paths = getRxtPathLists(userRegistry);
  Map<String, List<String>> RxtDetails = new ConcurrentHashMap<>();
  for (String path : paths) {
    String rxtContent = RegistryUtils.decodeBytes((byte[]) userRegistry.get(path).getContent());
    RxtUnboundedEntryBean rxtUnboundedEntryBean = getRxtUnboundedEntries(rxtContent);
    String mediaType = rxtUnboundedEntryBean.getMediaType();
    List<String> unboundedFields = rxtUnboundedEntryBean.getFields();
    if (mediaType != null && unboundedFields.size() > 0) {
      RxtDetails.put(rxtUnboundedEntryBean.getMediaType(), rxtUnboundedEntryBean.getFields());
    }
  }
  return RxtDetails;
}

代码示例来源：origin: org.wso2.carbon.registry/org.wso2.carbon.registry.resource

public static String getTextContent(String path, Registry registry) throws Exception {
  try {
    if (path != null && path.contains("..")) {
      path = FilenameUtils.normalize(path);
    }
    Resource resource = registry.get(path);
    byte[] content = (byte[]) resource.getContent();
    String contentString = "";
    if (content != null) {
      contentString = RegistryUtils.decodeBytes(content);
    }
    resource.discard();
    return contentString;
  } catch (RegistryException e) {
    String msg = "Could not get the content of the resource " +
        path + ". Caused by: " + ((e.getCause() instanceof SQLException) ?
        "" : e.getMessage());
    log.error(msg, e);
    throw new RegistryException(msg, e);
  }
}

代码示例来源：origin: org.wso2.carbon.registry/org.wso2.carbon.registry.extensions

private void preparePut(String path, RequestContext requestContext) throws RegistryException {
  Resource resource = requestContext.getResource();
  if (resource instanceof Collection) {
    filesystemManager.createDirectory(path);
  } else {
    Object content = resource.getContent();
    if (content instanceof String) {
      filesystemManager.createOrUpdateFile(path, RegistryUtils.encodeString(((String)content)));
    } else {
      filesystemManager.createOrUpdateFile(path, (byte[])content);
    }
    //resource.setContent("");
  }
}

代码示例来源：origin: org.wso2.carbon.registry/org.wso2.carbon.registry.extensions

public void put(RequestContext requestContext) throws RegistryException {
  if (!CommonUtil.isUpdateLockAvailable()) {
    return;
  }
  CommonUtil.acquireUpdateLock();
  try {
    SchemaValidator validator = new SchemaValidator();
    Resource resource = requestContext.getResource();
    Object resourceContent = resource.getContent();
    if (resourceContent instanceof byte[]) {
      InputStream in = new ByteArrayInputStream((byte[]) resourceContent);
      validator.validate(in, resource);
    }
    resource.setContentStream(null);
//        requestContext.getRegistry().put(resource.getPath() ,resource);
  } finally {
    CommonUtil.releaseUpdateLock();
  }
}

代码示例来源：origin: org.wso2.carbon.registry/org.wso2.carbon.registry.extensions

public void importResource(RequestContext requestContext) throws RegistryException {
  if (!CommonUtil.isUpdateLockAvailable()) {
    return;
  }
  CommonUtil.acquireUpdateLock();
  try {
    SchemaValidator validator = new SchemaValidator();
    Resource resource = requestContext.getResource();
    Object resourceContent = resource.getContent();
    if (resourceContent instanceof byte[]) {
      InputStream in = new ByteArrayInputStream((byte[]) resourceContent);
      validator.validate(in, resource);
    }
    resource.setContentStream(null);
    // requestContext.getRegistry().put(resource.getPath() ,resource);
  } finally {
    CommonUtil.releaseUpdateLock();
  }
}

代码示例来源：origin: org.wso2.carbon.registry/org.wso2.carbon.registry.extensions

private OMElement  setEndpoint(Registry registry, String definitionURL, OMElement serviceInfoElement)  throws RegistryException {
  Association[] associations = registry.getAssociations(definitionURL, CommonConstants.DEPENDS);
  for (Association association: associations) {
    String targetPath = association.getDestinationPath();
    if (registry.resourceExists(targetPath)) {
      Resource targetResource = registry.get(targetPath);
      if (CommonConstants.ENDPOINT_MEDIA_TYPE.equals(targetResource.getMediaType())) {
        byte[] sourceContent = (byte[]) targetResource.getContent();
        if (sourceContent == null) {
          return serviceInfoElement;
        }
        String endpointUrl = EndpointUtils.deriveEndpointFromContent(RegistryUtils.decodeBytes(sourceContent));
        try {
          serviceInfoElement = EndpointUtils.addEndpointToService(serviceInfoElement, endpointUrl, "");
        } catch (RegistryException e){}
      }
    }
  }
  return serviceInfoElement;
}

内容来源于网络，如有侵权，请联系作者删除！

Resource

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com