org.apache.helix.model.Message.getRecord()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(8.3k)|赞(0)|评价(0)|浏览(245)

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

Message.getRecord介绍

暂无

代码示例

代码示例来源：origin: apache/incubator-pinot

  1. public TimeboundaryRefreshMessage(Message message) {
  2.   super(message.getRecord());
  3.   String msgSubType = message.getMsgSubType();
  4.   Preconditions.checkArgument(msgSubType.equals(REFRESH_TIME_BOUNDARY_MSG_SUB_TYPE),
  5.     "Invalid message sub type: " + msgSubType + " for TimeboundaryRefreshMessage");
  6.  }
  7. }

代码示例来源：origin: apache/incubator-pinot

  1. public SegmentReloadMessage(Message message) {
  2.   super(message.getRecord());
  3.   String msgSubType = message.getMsgSubType();
  4.   Preconditions.checkArgument(msgSubType.equals(RELOAD_SEGMENT_MSG_SUB_TYPE),
  5.     "Invalid message sub type: " + msgSubType + " for SegmentReloadMessage");
  6.  }
  7. }

代码示例来源：origin: apache/incubator-pinot

  1. /**
  2.  * @param message The incoming message that has been received from helix.
  3.  * @throws IllegalArgumentException if the message is not of right sub-type
  4.  */
  5. public SegmentRefreshMessage(final Message message) {
  6.  super(message.getRecord());
  7.  if (!message.getMsgSubType().equals(REFRESH_SEGMENT_MSG_SUB_TYPE)) {
  8.   throw new IllegalArgumentException("Invalid message subtype:" + message.getMsgSubType());
  9.  }
  10. }

代码示例来源：origin: apache/incubator-gobblin

  1. private List<Message> generateMessagesForController(Message message) {
  2.  List<Message> messages = new ArrayList<Message>();
  3.  String id = UUID.randomUUID().toString();
  4.  Message newMessage = new Message(message.getRecord(), id);
  5.  newMessage.setMsgId(id);
  6.  newMessage.setSrcName(_manager.getInstanceName());
  7.  newMessage.setTgtName("Controller");
  8.  messages.add(newMessage);
  9.  return messages;
  10. }

代码示例来源：origin: apache/incubator-gobblin

  1. Message newMessage = new Message(message.getRecord(), id);
  2. String srcInstanceName = _manager.getInstanceName();
  3. String tgtInstanceName = map.get("instanceName");

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

  1. /**
  2.  * Instantiate a message with a new id
  3.  * @param message message to be copied
  4.  * @param id unique message identifier
  5.  */
  6. public Message(Message message, String id) {
  7.  super(new ZNRecord(message.getRecord(), id));
  8.  setMsgId(id);
  9. }

代码示例来源：origin: com.linkedin.gobblin/gobblin-cluster

  1. private List<Message> generateMessagesForController(Message message) {
  2.  List<Message> messages = new ArrayList<Message>();
  3.  String id = UUID.randomUUID().toString();
  4.  Message newMessage = new Message(message.getRecord(), id);
  5.  newMessage.setMsgId(id);
  6.  newMessage.setSrcName(_manager.getInstanceName());
  7.  newMessage.setTgtName("Controller");
  8.  messages.add(newMessage);
  9.  return messages;
  10. }

代码示例来源：origin: org.apache.gobblin/gobblin-cluster

  1. private List<Message> generateMessagesForController(Message message) {
  2.  List<Message> messages = new ArrayList<Message>();
  3.  String id = UUID.randomUUID().toString();
  4.  Message newMessage = new Message(message.getRecord(), id);
  5.  newMessage.setMsgId(id);
  6.  newMessage.setSrcName(_manager.getInstanceName());
  7.  newMessage.setTgtName("Controller");
  8.  messages.add(newMessage);
  9.  return messages;
  10. }

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

  1. @GET
  2. @Path("{clusterId}/controller/messages/{messageId}")
  3. public Response getClusterControllerMessages(@PathParam("clusterId") String clusterId, @PathParam("messageId") String messageId) {
  4.  HelixDataAccessor dataAccessor = getDataAccssor(clusterId);
  5.  Message message = dataAccessor.getProperty(
  6.    dataAccessor.keyBuilder().controllerMessage(messageId));
  7.  return JSONRepresentation(message.getRecord());
  8. }

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

  1. @GET
  2. @Path("{instanceName}/messages/{messageId}")
  3. public Response getMessageOnInstance(@PathParam("clusterId") String clusterId,
  4.   @PathParam("instanceName") String instanceName,
  5.   @PathParam("messageId") String messageId) throws IOException {
  6.  HelixDataAccessor accessor = getDataAccssor(clusterId);
  7.  Message message = accessor.getProperty(accessor.keyBuilder().message(instanceName, messageId));
  8.  if (message != null) {
  9.   return JSONRepresentation(message.getRecord());
  10.  }
  11.  return notFound();
  12. }

代码示例来源：origin: org.apache.helix/helix-core

  1. public void postFaultInjectionMessage(String zkServer, String clusterName, String instanceName,
  2.   String payloadString, String partition) {
  3.  Message message = new Message("FaultInjection", UUID.randomUUID().toString());
  4.  if (payloadString != null) {
  5.   message.getRecord().setSimpleField("faultType", payloadString);
  6.  }
  7.  if (partition != null) {
  8.   message.setPartitionName(partition);
  9.  }
  10.  post(zkServer, message, clusterName, instanceName);
  11. }

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

  1. public void postFaultInjectionMessage(String zkServer, String clusterName, String instanceName,
  2.   String payloadString, String partition) {
  3.  Message message = new Message("FaultInjection", UUID.randomUUID().toString());
  4.  if (payloadString != null) {
  5.   message.getRecord().setSimpleField("faultType", payloadString);
  6.  }
  7.  if (partition != null) {
  8.   message.setPartitionName(partition);
  9.  }
  10.  post(zkServer, message, clusterName, instanceName);
  11. }

代码示例来源：origin: org.apache.helix/helix-core

  1. @Override
  2. public boolean createControllerMessage(Message message) {
  3.  return _baseDataAccessor.create(PropertyPathBuilder.controllerMessage(_clusterName,
  4.    message.getMsgId()),
  5.    message.getRecord(), AccessOption.PERSISTENT);
  6. }

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

  1. @Override
  2.  public void onError(Exception e, ErrorCode code, ErrorType type) {
  3.   // TODO Auto-generated method stub
  4.   _message.getRecord().setSimpleField("exception", e.getMessage());
  5.  }
  6. }

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

  1. @Override
  2. public boolean createControllerMessage(Message message) {
  3.  return _baseDataAccessor.create(PropertyPathBuilder.controllerMessage(_clusterName,
  4.    message.getMsgId()),
  5.    message.getRecord(), AccessOption.PERSISTENT);
  6. }

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

  1. private List<Message> generateMessagesForController(Message message) {
  2.  List<Message> messages = new ArrayList<Message>();
  3.  String id = (message.getMsgId() == null) ? UUID.randomUUID().toString() : message.getMsgId();
  4.  Message newMessage = new Message(message.getRecord(), id);
  5.  newMessage.setMsgId(id);
  6.  newMessage.setSrcName(_manager.getInstanceName());
  7.  newMessage.setTgtName(InstanceType.CONTROLLER.name());
  8.  messages.add(newMessage);
  9.  return messages;
  10. }

代码示例来源：origin: org.apache.helix/helix-core

  1. private List<Message> generateMessagesForController(Message message) {
  2.  List<Message> messages = new ArrayList<Message>();
  3.  String id = (message.getMsgId() == null) ? UUID.randomUUID().toString() : message.getMsgId();
  4.  Message newMessage = new Message(message.getRecord(), id);
  5.  newMessage.setMsgId(id);
  6.  newMessage.setSrcName(_manager.getInstanceName());
  7.  newMessage.setTgtName(InstanceType.CONTROLLER.name());
  8.  messages.add(newMessage);
  9.  return messages;
  10. }

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

  1. @Override
  2. public void onReplyMessage(Message message) {
  3.  // TODO Auto-generated method stub
  4.  System.out.println("OnreplyMessage: "
  5.    + message.getRecord().getMapField(Message.Attributes.MESSAGE_RESULT.toString())
  6.      .get("ReplyMessage"));
  7.  if (message.getRecord().getMapField(Message.Attributes.MESSAGE_RESULT.toString())
  8.    .get("ReplyMessage") == null) {
  9.  }
  10.  _replyedMessageContents.add(message.getRecord()
  11.    .getMapField(Message.Attributes.MESSAGE_RESULT.toString()).get("ReplyMessage"));
  12. }

代码示例来源：origin: org.apache.helix/helix-core

  1. public void post(String zkServer, Message message, String clusterName, String instanceName) {
  2.  ZkClient client = new ZkClient(zkServer);
  3.  client.setZkSerializer(new ZNRecordSerializer());
  4.  String path = PropertyPathBuilder.instanceMessage(clusterName, instanceName, message.getId());
  5.  client.delete(path);
  6.  ZNRecord record = client.readData(PropertyPathBuilder.liveInstance(clusterName, instanceName));
  7.  message.setTgtSessionId(record.getSimpleField(LiveInstanceProperty.SESSION_ID.toString()));
  8.  message.setTgtName(record.getId());
  9.  // System.out.println(message);
  10.  client.createPersistent(path, message.getRecord());
  11. }

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

  1. public void post(String zkServer, Message message, String clusterName, String instanceName) {
  2.  HelixZkClient client = SharedZkClientFactory.getInstance().buildZkClient(new HelixZkClient.ZkConnectionConfig(
  3.    zkServer));
  4.  client.setZkSerializer(new ZNRecordSerializer());
  5.  String path = PropertyPathBuilder.instanceMessage(clusterName, instanceName, message.getId());
  6.  client.delete(path);
  7.  ZNRecord record = client.readData(PropertyPathBuilder.liveInstance(clusterName, instanceName));
  8.  message.setTgtSessionId(record.getSimpleField(LiveInstanceProperty.SESSION_ID.toString()));
  9.  message.setTgtName(record.getId());
  10.  // System.out.println(message);
  11.  client.createPersistent(path, message.getRecord());
  12. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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