javax.ws.rs.client.Entity.entity()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(10.4k)|赞(0)|评价(0)|浏览(248)

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

Entity.entity介绍

[英]Create an entity using a supplied content media type.
[中]使用提供的内容媒体类型创建实体。

代码示例

代码示例来源：origin: apache/nifi

private Response getClientResponse(OCSPReq ocspRequest) throws IOException {
  final WebTarget webTarget = client.target(validationAuthorityURI);
  return webTarget.request().post(Entity.entity(ocspRequest.getEncoded(), OCSP_REQUEST_CONTENT_TYPE));
}

代码示例来源：origin: docker-java/docker-java

@Override
  protected CreateNetworkResponse execute(CreateNetworkCmd command) {
    WebTarget webResource = getBaseResource().path("/networks/create");

    LOGGER.trace("POST: {}", webResource);
    return webResource.request().accept(MediaType.APPLICATION_JSON)
        .post(entity(command, MediaType.APPLICATION_JSON), CreateNetworkResponse.class);
  }
}

代码示例来源：origin: apache/nifi

@Override
public RegistryClientEntity createRegistryClient(final RegistryClientEntity registryClient) throws NiFiClientException, IOException {
  if (registryClient == null) {
    throw new IllegalArgumentException("Registry client entity cannot be null");
  }
  return executeAction("Error creating registry client", () -> {
    final WebTarget target = controllerTarget.path("registry-clients");
    return getRequestBuilder(target).post(
        Entity.entity(registryClient, MediaType.APPLICATION_JSON),
        RegistryClientEntity.class
    );
  });
}

代码示例来源：origin: docker-java/docker-java

@Override
  protected Void execute(DisconnectFromNetworkCmd command) {

    WebTarget webTarget = getBaseResource().path("/networks/" + command.getNetworkId() + "/disconnect");

    LOGGER.trace("POST: {}", webTarget);
    webTarget.request().post(entity(command, MediaType.APPLICATION_JSON));

    return null;
  }
}

代码示例来源：origin: aol/micro-server

public <V> T post(final String queryResourceUrl,
    final V request) {

  
  final WebTarget webResource = client.target(queryResourceUrl);
  return buildResponse(webResource
      .request(accept)
      .accept(accept)
       .post(Entity.entity(request, contentType),String.class));
  
}

代码示例来源：origin: apache/nifi

@Override
public NodeEntity offloadNode(final String nodeId, final NodeEntity nodeEntity) throws NiFiClientException, IOException {
  if (StringUtils.isBlank(nodeId)) {
    throw new IllegalArgumentException("Node ID cannot be null or empty");
  }
  if (nodeEntity == null) {
    throw new IllegalArgumentException("Node entity cannot be null");
  }
  return executeAction("Error offloading node", () -> {
    final WebTarget target = controllerTarget.path("cluster/nodes/" + nodeId);
    return getRequestBuilder(target).put(Entity.entity(nodeEntity, MediaType.APPLICATION_JSON), NodeEntity.class);
  });
}

代码示例来源：origin: docker-java/docker-java

@Override
  protected CreateVolumeResponse execute(CreateVolumeCmd command) {
    WebTarget webResource = getBaseResource().path("/volumes/create");

    LOGGER.trace("POST: {}", webResource);
    return webResource.request().accept(MediaType.APPLICATION_JSON)
        .post(entity(command, MediaType.APPLICATION_JSON), CreateVolumeResponse.class);
  }
}

代码示例来源：origin: apache/usergrid

@Override
Map<String, Object> userFromResource(String externalToken) {
  MultivaluedMap<String, String> formData = getMultivaluedMapImpl();
  formData.add("grant_type", "urn:pingidentity.com:oauth2:grant_type:validate_bearer");
  formData.add("client_id", clientId);
  formData.add("client_secret", clientSecret);
  formData.add("token", externalToken);
  JsonNode node = client.target(apiUrl).request()
    .post(Entity.entity(formData, MediaType.APPLICATION_FORM_URLENCODED_TYPE), JsonNode.class);
  String rawEmail = node.get("access_token").get("subject").asText();
  Map<String, Object> userMap = new HashMap<String, Object>();
  userMap.put("expiration", node.get("expires_in").asLong());
  userMap.put("username", pingUsernameFrom(rawEmail));
  userMap.put("name", "pinguser");
  userMap.put("email", rawEmail);
  return userMap;
}

代码示例来源：origin: apache/nifi

@Override
public NodeEntity disconnectNode(final String nodeId, final NodeEntity nodeEntity) throws NiFiClientException, IOException {
  if (StringUtils.isBlank(nodeId)) {
    throw new IllegalArgumentException("Node ID cannot be null or empty");
  }
  if (nodeEntity == null) {
    throw new IllegalArgumentException("Node entity cannot be null");
  }
  return executeAction("Error disconnecting node", () -> {
    final WebTarget target = controllerTarget.path("cluster/nodes/" + nodeId);
    return getRequestBuilder(target).put(Entity.entity(nodeEntity, MediaType.APPLICATION_JSON), NodeEntity.class);
  });
}

代码示例来源：origin: docker-java/docker-java

@Override
  protected Void execute(LoadImageCmd command) {
    WebTarget webTarget = getBaseResource().path("/images/load");

    LOGGER.trace("POST: {}", webTarget);
    webTarget.request().post(entity(command.getImageStream(), MediaType.APPLICATION_OCTET_STREAM));

    return null;
  }
}

代码示例来源：origin: jersey/jersey

@Override
public TokenResult refreshAccessToken(final String refreshToken) {
  refreshTokenProperties.put(OAuth2Parameters.REFRESH_TOKEN, refreshToken);
  final Form form = new Form();
  for (final Map.Entry<String, String> entry : refreshTokenProperties.entrySet()) {
    form.param(entry.getKey(), entry.getValue());
  }
  final Response response = client.target(refreshTokenUri)
      .request(MediaType.APPLICATION_JSON_TYPE)
      .post(Entity.entity(form, MediaType.APPLICATION_FORM_URLENCODED_TYPE));
  if (response.getStatus() != 200) {
    throw new ProcessingException(LocalizationMessages.ERROR_FLOW_REQUEST_REFRESH_TOKEN(response.getStatus()));
  }
  this.tokenResult = response.readEntity(TokenResult.class);
  return tokenResult;
}

代码示例来源：origin: apache/nifi

@Override
public NodeEntity connectNode(final String nodeId, final NodeEntity nodeEntity) throws NiFiClientException, IOException {
  if (StringUtils.isBlank(nodeId)) {
    throw new IllegalArgumentException("Node ID cannot be null or empty");
  }
  if (nodeEntity == null) {
    throw new IllegalArgumentException("Node entity cannot be null");
  }
  return executeAction("Error connecting node", () -> {
    final WebTarget target = controllerTarget.path("cluster/nodes/" + nodeId);
    return getRequestBuilder(target).put(Entity.entity(nodeEntity, MediaType.APPLICATION_JSON), NodeEntity.class);
  });
}

代码示例来源：origin: docker-java/docker-java

@Override
  protected Void execute(ConnectToNetworkCmd command) {

    WebTarget webTarget = getBaseResource().path("/networks/" + command.getNetworkId() + "/connect");

    LOGGER.trace("POST: {}", webTarget);
    webTarget.request().post(entity(command, MediaType.APPLICATION_JSON));

    return null;
  }
}

代码示例来源：origin: jersey/jersey

@Override
public TokenResult finish(final String authorizationCode, final String state) {
  if (!this.authorizationProperties.get(OAuth2Parameters.STATE).equals(state)) {
    throw new IllegalArgumentException(LocalizationMessages.ERROR_FLOW_WRONG_STATE());
  }
  accessTokenProperties.put(OAuth2Parameters.CODE, authorizationCode);
  final Form form = new Form();
  for (final Map.Entry<String, String> entry : accessTokenProperties.entrySet()) {
    form.param(entry.getKey(), entry.getValue());
  }
  final Response response = client.target(accessTokenUri)
      .request(MediaType.APPLICATION_JSON_TYPE)
      .post(Entity.entity(form, MediaType.APPLICATION_FORM_URLENCODED_TYPE));
  if (response.getStatus() != 200) {
    throw new ProcessingException(LocalizationMessages.ERROR_FLOW_REQUEST_ACCESS_TOKEN(response.getStatus()));
  }
  this.tokenResult = response.readEntity(TokenResult.class);
  return tokenResult;
}

代码示例来源：origin: apache/nifi

@Override
public ProcessGroupEntity createProcessGroup(final String parentGroupdId, final ProcessGroupEntity entity)
    throws NiFiClientException, IOException {
  if (StringUtils.isBlank(parentGroupdId)) {
    throw new IllegalArgumentException("Parent process group id cannot be null or blank");
  }
  if (entity == null){
    throw new IllegalArgumentException("Process group entity cannot be null");
  }
  return executeAction("Error creating process group", () -> {
    final WebTarget target = processGroupsTarget
        .path("{id}/process-groups")
        .resolveTemplate("id", parentGroupdId);
    return getRequestBuilder(target).post(
        Entity.entity(entity, MediaType.APPLICATION_JSON_TYPE),
        ProcessGroupEntity.class
    );
  });
}

代码示例来源：origin: docker-java/docker-java

@Override
  protected Void execute(JoinSwarmCmd command) {
    WebTarget webResource = getBaseResource().path("/swarm/join");

    LOGGER.trace("POST: {} ", webResource);
    webResource.request().accept(MediaType.APPLICATION_JSON)
        .post(entity(command, MediaType.APPLICATION_JSON)).close();
    return null;
  }
}

代码示例来源：origin: aol/micro-server

public <V> T put(final String queryResourceUrl,
    final V request) {
  CompletableFuture<T> result = new CompletableFuture<>();
  final WebTarget webResource = client.target(queryResourceUrl);
  return buildResponse(webResource
              .request(accept)
              .accept(accept)
              .put(Entity.entity(request, contentType),String.class));
}
public T delete(final String queryResourceUrl) {

代码示例来源：origin: apache/nifi

@Override
public VersionedFlowUpdateRequestEntity updateVersionControlInfo(final String processGroupId, final VersionControlInformationEntity entity)
    throws IOException, NiFiClientException {
  if (StringUtils.isBlank(processGroupId)) {
    throw new IllegalArgumentException("Process group id cannot be null or blank");
  }
  if (entity == null) {
    throw new IllegalArgumentException("Version control information entity cannot be null");
  }
  return executeAction("Error updating version control information", () -> {
    final WebTarget target = versionsTarget
        .path("update-requests/process-groups/{id}")
        .resolveTemplate("id", processGroupId);
    return getRequestBuilder(target).post(
        Entity.entity(entity, MediaType.APPLICATION_JSON_TYPE),
        VersionedFlowUpdateRequestEntity.class
    );
  });
}

代码示例来源：origin: docker-java/docker-java

@Override
  protected Void execute(InitializeSwarmCmd command) {
    WebTarget webResource = getBaseResource().path("/swarm/init");

    LOGGER.trace("POST: {} ", webResource);
    webResource.request().accept(MediaType.APPLICATION_JSON)
        .post(entity(command, MediaType.APPLICATION_JSON)).close();
    return null;
  }
}

代码示例来源：origin: spotify/apollo

@Override
public boolean post(String message) {
 Map<String, String> payload = ImmutableMap.of(
  "text", message,
  "username", slackConfig.username(),
  "icon_emoji", slackConfig.emoji()
 );
 try {
  Form form = new Form().param("payload", mapper.writeValueAsString(payload));
  this.target
    .request(MediaType.APPLICATION_JSON_TYPE)
    .post(Entity.entity(form, MediaType.APPLICATION_FORM_URLENCODED_TYPE));
  return true;
 } catch (IOException ex) {
  LOG.warn("Can't post message to slack", ex);
  return false;
 }
}

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

Entity

相关文章

    查看更多

    热门标签

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

    最新文章

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