org.kurento.jsonrpc.JsonUtils.fromJson()方法的使用及代码示例

x33g5p2x  于2022-01-22 转载在 其他  
字(7.9k)|赞(0)|评价(0)|浏览(198)

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

JsonUtils.fromJson介绍

暂无

代码示例

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

public static <T> Request<T> fromJsonRequest(String json, Class<T> paramsClass) {
 if (INJECT_SESSION_ID) {
  // TODO Optimise this implementation if possible
  return fromJsonRequestInject(fromJson(json, JsonObject.class), paramsClass);
 }
 return getGson().fromJson(json,
   $Gson$Types.newParameterizedTypeWithOwner(null, Request.class, paramsClass));
}

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

public static Message fromJsonMessage(String message) {
 JsonObject json = fromJson(message, JsonObject.class);
 if (json.has(METHOD_PROPERTY)) {
  return fromJsonRequest(json, JsonObject.class);
 } else {
  return fromJsonResponse(json, JsonElement.class);
 }
}

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

public static <T> Response<T> fromJsonResponse(String json, Class<T> resultClass) {
 if (INJECT_SESSION_ID) {
  // TODO Optimise this implementation if possible
  return fromJsonResponseInject(fromJson(json, JsonObject.class), resultClass);
 }
 try {
  return getGson().fromJson(json,
    $Gson$Types.newParameterizedTypeWithOwner(null, Response.class, resultClass));
 } catch (JsonSyntaxException e) {
  throw new JsonRpcException("Exception converting Json '" + json
    + "' to a JSON-RPC response with params as class " + resultClass.getName(), e);
 }
}

代码示例来源：origin: org.kurento/kurento-jsonrpc-server

public void processMessage(String messageJson, ServerSessionFactory factory,
  ResponseSender responseSender, String internalSessionId) throws IOException {
 JsonObject messagetJsonObject = JsonUtils.fromJson(messageJson, JsonObject.class);
 processMessage(messagetJsonObject, factory, responseSender, internalSessionId);
}

代码示例来源：origin: org.kurento/kurento-jsonrpc-server

}.getType();
List<Response<JsonElement>> responseList = JsonUtils.fromJson(request.getParams(),
  collectionType);

代码示例来源：origin: org.kurento/kurento-client

public static <E> E convertFromResult(JsonElement result, Type type) {
 if (type == Void.class || type == void.class) {
  return null;
 }
 JsonElement extractResult = extractValueFromResponse(result, type);
 return JsonUtils.fromJson(extractResult, type);
}

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

}.getType();
List<Response<JsonElement>> responseList = JsonUtils.fromJson(request.getParams(),
  collectionType);

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

public static JsonObject toJsonObject(Object obj) {
 // TODO Optimise this implementation if possible
 return fromJson(getGson().toJson(obj), JsonObject.class);
}

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

public static <E> E convertFromResult(JsonElement result, Type type) {
 if (type == Void.class || type == void.class) {
  return null;
 }
 JsonElement extractResult = extractValueFromResponse(result, type);
 return JsonUtils.fromJson(extractResult, type);
}

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

public void processMessage(String messageJson, ServerSessionFactory factory,
  ResponseSender responseSender, String internalSessionId) throws IOException {
 JsonObject messagetJsonObject = JsonUtils.fromJson(messageJson, JsonObject.class);
 processMessage(messagetJsonObject, factory, responseSender, internalSessionId);
}

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

public static <E> E extractJavaValueFromResult(JsonElement result, Type type) {
 if (type == Void.class || type == void.class) {
  return null;
 }
 JsonElement extractResult = extractJsonValueFromResponse(result, type);
 return JsonUtils.fromJson(extractResult, type);
}

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

private void processEvent(RomEventHandler eventHandler, Request<JsonObject> request) {
 JsonObject params = request.getParams();
 try {
  params = (JsonObject) params.get("value");
 } catch (Exception e) {
  log.trace("Exception processing event: getting value", e);
 }
 String objectRef = params.get(ONEVENT_OBJECT).getAsString();
 String subscription = "";
 if (params.has(ONEVENT_SUBSCRIPTION)) {
  subscription = params.get(ONEVENT_SUBSCRIPTION).getAsString();
 }
 String type = params.get(ONEVENT_TYPE).getAsString();
 JsonObject jsonData = (JsonObject) params.get(ONEVENT_DATA);
 Props data = JsonUtils.fromJson(jsonData, Props.class);
 eventHandler.processEvent(objectRef, subscription, type, data);
}

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

protected void receivedTextMessage(String message) {
 try {
  JsonObject jsonMessage = fromJson(message, JsonObject.class);
  if (jsonMessage.has(JsonRpcConstants.METHOD_PROPERTY)) {
   handleRequestFromServer(jsonMessage);
  } else {
   handleResponseFromServer(jsonMessage);
  }
 } catch (Exception e) {
  log.error("{} Exception processing jsonRpc message {}", label, message, e);
 }
}

代码示例来源：origin: org.kurento/kurento-client

private void processEvent(RomEventHandler eventHandler, Request<JsonObject> request) {
 JsonObject params = request.getParams();
 try {
  params = (JsonObject) params.get("value");
 } catch (Exception e) {
  log.trace("Exception processing event: getting value", e);
 }
 String objectRef = params.get(ONEVENT_OBJECT).getAsString();
 String subscription = "";
 if (params.has(ONEVENT_SUBSCRIPTION)) {
  subscription = params.get(ONEVENT_SUBSCRIPTION).getAsString();
 }
 String type = params.get(ONEVENT_TYPE).getAsString();
 JsonObject jsonData = (JsonObject) params.get(ONEVENT_DATA);
 Props data = JsonUtils.fromJson(jsonData, Props.class);
 eventHandler.processEvent(objectRef, subscription, type, data);
}

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

private void handleCreateCommand(Transaction transaction, String type,
  JsonObject constructorParams) throws IOException {
 Object result = server.create(type, JsonUtils.fromJson(constructorParams, Props.class));
 transaction.sendResponse(result);
}

代码示例来源：origin: org.kurento/kurento-client

private void handleInvokeCommand(Transaction transaction, String objectRef, String operationName,
  JsonObject operationParams) throws IOException {
 Object result = server.invoke(objectRef, operationName,
   JsonUtils.fromJson(operationParams, Props.class), Object.class);
 transaction.sendResponse(result);
}

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

private void handleInvokeCommand(Transaction transaction, String objectRef, String operationName,
  JsonObject operationParams) throws IOException {
 Object result = server.invoke(objectRef, operationName,
   JsonUtils.fromJson(operationParams, Props.class), Object.class);
 transaction.sendResponse(result);
}

代码示例来源：origin: org.kurento/kurento-client

private void handleCreateCommand(Transaction transaction, String type,
  JsonObject constructorParams) throws IOException {
 Object result = server.create(type, JsonUtils.fromJson(constructorParams, Props.class));
 transaction.sendResponse(result);
}

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

private static <T> Response<T> fromJsonResponseInject(JsonObject jsonObject,
  Class<T> resultClass) {
 try {
  String sessionId = extractSessionId(jsonObject, RESULT_PROPERTY);
  Response<T> response;
  if (resultClass != null) {
   response = JsonUtils.fromJson(jsonObject,
     $Gson$Types.newParameterizedTypeWithOwner(null, Response.class, resultClass));
  } else {
   response = JsonUtils.fromJson(jsonObject,
     $Gson$Types.newParameterizedTypeWithOwner(null, Response.class, JsonElement.class));
  }
  response.setSessionId(sessionId);
  return response;
 } catch (JsonSyntaxException e) {
  throw new JsonRpcException("Exception converting Json '" + jsonObject
    + "' to a JSON-RPC response with params as class " + resultClass.getName(), e);
 }
}

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

private void longPooling() {
 while (true) {
  try {
   Thread.sleep(1000);
  } catch (InterruptedException e) {
   log.debug("Long polling thread interrupted", e);
  }
  if (Thread.interrupted()) {
   break;
  }
  try {
   JsonElement requestsListJsonObject = this.sendRequest(Request.POLL_METHOD_NAME,
     rs.getResponseListToSend(), JsonElement.class);
   log.debug("Response from pool: {}", requestsListJsonObject);
   Type collectionType = new TypeToken<List<Request<JsonElement>>>() {
   }.getType();
   List<Request<JsonElement>> requestList = JsonUtils.fromJson(requestsListJsonObject,
     collectionType);
   processServerRequests(requestList);
  } catch (IOException e) {
   // TODO Decide what to do in this case. If the net connection is
   // lost, this will retry indefinitely
   log.error("Exception when waiting for events (long-polling). Retry", e);
  }
 }
}

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

JsonUtils

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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