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

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

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

Message.getMsgId介绍

[英]Get the unique identifier of this message
[中]获取此消息的唯一标识符

代码示例

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

  1. @Override
  2.  public void onError(Exception e, ErrorCode code, ErrorType type) {
  3.   _logger.error("Message handling pipeline get an exception. MsgId:" + _message.getMsgId(), e);
  4.  }
  5. }

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

  1. @Override
  2.  public void onError(Exception e, ErrorCode code, ErrorType type) {
  3.   _logger.error("Message handling pipeline get an exception. MsgId:" + _message.getMsgId(), e);
  4.  }
  5. }

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

  1. @Override
  2.  public void onError(Exception e, ErrorCode code, ErrorType type) {
  3.   _logger.error("Message handling pipeline get an exception. MsgId:" + _message.getMsgId(), e);
  4.  }
  5. }

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

  1. @Override
  2.  public void onError(Exception e, ErrorCode code, ErrorType type) {
  3.   _logger.error("Message handling pipeline get an exception. MsgId:" + _message.getMsgId(), e);
  4.  }
  5. }

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

  1. @Override
  2.  public void onError(Exception e, ErrorCode code, ErrorType type) {
  3.   _logger.error("Message handling pipeline get an exception. MsgId:" + _message.getMsgId(), e);
  4.  }
  5. }

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

  1. private void removeMessageFromZK(HelixDataAccessor accessor, Message message,
  2.   String instanceName) {
  3.  if (HelixUtil.removeMessageFromZK(accessor, message, instanceName)) {
  4.   LOG.info("Successfully removed message {} from ZK.", message.getMsgId());
  5.  } else {
  6.   LOG.warn("Failed to remove message {} from ZK.", message.getMsgId());
  7.  }
  8. }

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

  1. @Override
  2. public void onTimeOut() {
  3.  _logger.info("Scheduler msg timeout " + _originalMessage.getMsgId() + " timout with "
  4.    + _timeout + " Ms");
  5.  _statusUpdateUtil.logError(_originalMessage, SchedulerAsyncCallback.class, "Task timeout",
  6.    _manager);
  7.  addSummary(_resultSummaryMap, _originalMessage, _manager, true);
  8. }

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

  1. @Override
  2. public void onReplyMessage(Message message) {
  3.  // TODO Auto-generated method stub
  4.  _repliedMessageId.add(message.getMsgId());
  5. }

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

  1. @Override
  2. public void onTimeOut() {
  3.  _logger.info("Scheduler msg timeout " + _originalMessage.getMsgId() + " timout with "
  4.    + _timeout + " Ms");
  5.  _statusUpdateUtil.logError(_originalMessage, SchedulerAsyncCallback.class, "Task timeout",
  6.    _manager);
  7.  addSummary(_resultSummaryMap, _originalMessage, _manager, true);
  8. }

代码示例来源：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: org.apache.helix/helix-core

  1. private String getStatusUpdateKey(Message message) {
  2.  if (message.getMsgType().equalsIgnoreCase(MessageType.STATE_TRANSITION.name())) {
  3.   return message.getPartitionName();
  4.  }
  5.  return message.getMsgId();
  6. }

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

  1. @Override
  2. public void run() {
  3.  Message message = _task.getMessage();
  4.  // NotificationContext context = _task.getNotificationContext();
  5.  // System.out.println("msg: " + message.getMsgId() + " timeouot.");
  6.  LOG.warn("Message time out, canceling. id:" + message.getMsgId() + " timeout : "
  7.    + message.getExecutionTimeout());
  8.  _task.onTimeout();
  9.  _executor.cancelTask(_task);
  10. }

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

  1. public void updateLatency(Message message) {
  2.  long latency = System.currentTimeMillis() - message.getCreateTimeStamp();
  3.  _logger.info(String.format("The latency of message %s is %d ms", message.getMsgId(), latency));
  4.  _totalMessageCount.updateValue(_totalMessageCount.getValue() + 1);
  5.  _totalMessageLatency.updateValue(_totalMessageLatency.getValue() + latency);
  6.  _messageLatencyGauge.updateValue(latency);
  7. }

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

  1. String getStatusUpdateRecordName(Message message) {
  2.  if (message.getMsgType().equalsIgnoreCase(MessageType.STATE_TRANSITION.name())) {
  3.   return message.getTgtSessionId() + "__" + message.getResourceName();
  4.  }
  5.  return message.getMsgId();
  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. @Override
  2. public void run() {
  3.  Message message = _task.getMessage();
  4.  // NotificationContext context = _task.getNotificationContext();
  5.  // System.out.println("msg: " + message.getMsgId() + " timeouot.");
  6.  LOG.warn("Message time out, canceling. id:" + message.getMsgId() + " timeout : "
  7.    + message.getExecutionTimeout());
  8.  _task.onTimeout();
  9.  _executor.cancelTask(_task);
  10. }

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

  1. @Override
  2. public MessageHandler createHandler(Message message, NotificationContext context) {
  3.  String type = message.getMsgType();
  4.  if (!type.equals(getMessageType())) {
  5.   throw new HelixException("Unexpected msg type for message " + message.getMsgId() + " type:"
  6.     + message.getMsgType());
  7.  }
  8.  return new DefaultControllerMessageHandler(message, context);
  9. }

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

  1. @Override
  2. public MessageHandler createHandler(Message message, NotificationContext context) {
  3.  String type = message.getMsgType();
  4.  if (!type.equals(getMessageType())) {
  5.   throw new HelixException("Unexpected msg type for message " + message.getMsgId() + " type:"
  6.     + message.getMsgType());
  7.  }
  8.  return new DefaultParticipantErrorMessageHandler(message, context, _manager);
  9. }

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

  1. @Override
  2. public MessageHandler createHandler(Message message, NotificationContext context) {
  3.  String type = message.getMsgType();
  4.  if (!type.equals(getMessageType())) {
  5.   throw new HelixException("Unexpected msg type for message " + message.getMsgId() + " type:"
  6.     + message.getMsgType());
  7.  }
  8.  return new DefaultSchedulerMessageHandler(message, context, _manager);
  9. }

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

  1. @Override
  2. public HelixTaskResult handleMessage() throws InterruptedException {
  3.  HelixTaskResult result = new HelixTaskResult();
  4.  result.setSuccess(true);
  5.  Thread.sleep(1000);
  6.  System.out.println("TestMessagingHandler " + _message.getMsgId());
  7.  _processedMsgIds.add(_message.getRecord().getSimpleField("TestMessagingPara"));
  8.  result.getTaskResultMap().put("ReplyMessage", "TestReplyMessage");
  9.  return result;
  10. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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