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

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

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

Message.getMsgType介绍

[英]Get the type of this message
[中]获取此消息的类型

代码示例

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

  1. @Test(enabled = false)
  2. @Override
  3. public void assertMessageReception(Message message) {
  4.  Assert.assertEquals(message.getMsgType(), GobblinHelixConstants.SHUTDOWN_MESSAGE_TYPE);
  5.  Assert.assertEquals(message.getMsgSubType(), HelixMessageSubTypes.APPLICATION_MASTER_SHUTDOWN.toString());
  6. }

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

  1. @Test(enabled = false)
  2.  @Override
  3.  public void assertMessageReception(Message message) {
  4.   Assert.assertEquals(message.getMsgType(), GobblinHelixConstants.SHUTDOWN_MESSAGE_TYPE);
  5.   Assert.assertEquals(message.getMsgSubType(), HelixMessageSubTypes.APPLICATION_MASTER_SHUTDOWN.toString());
  6.  }
  7. }

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

  1. @Test(enabled = false)
  2.  @Override
  3.  public void assertMessageReception(Message message) {
  4.   Assert.assertEquals(message.getMsgType(), GobblinHelixConstants.SHUTDOWN_MESSAGE_TYPE);
  5.   Assert.assertEquals(message.getMsgSubType(), HelixMessageSubTypes.WORK_UNIT_RUNNER_SHUTDOWN.toString());
  6.  }
  7. }

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

  1. /**
  2.  * Generate the sub-path under STATUSUPDATE or ERROR path for a status update
  3.  */
  4. String getStatusUpdateSubPath(Message message) {
  5.  if (message.getMsgType().equalsIgnoreCase(MessageType.STATE_TRANSITION.name())) {
  6.   return message.getResourceName();
  7.  }
  8.  return message.getMsgType();
  9. }

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

  1. /**
  2.  * Generate the sub-path under STATUSUPDATE or ERROR path for a status update
  3.  */
  4. String getStatusUpdateSubPath(Message message) {
  5.  if (message.getMsgType().equalsIgnoreCase(MessageType.STATE_TRANSITION.name())) {
  6.   return message.getResourceName();
  7.  }
  8.  return message.getMsgType();
  9. }

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

  1. private String getRecordIdForMessage(Message message) {
  2.  if (message.getMsgType().equals(MessageType.STATE_TRANSITION)) {
  3.   return message.getPartitionName() + " Trans:" + message.getFromState().charAt(0) + "->"
  4.     + message.getToState().charAt(0) + "  " + UUID.randomUUID().toString();
  5.  } else {
  6.   return message.getMsgType() + " " + UUID.randomUUID().toString();
  7.  }
  8. }

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

  1. private String getRecordIdForMessage(Message message) {
  2.  if (message.getMsgType().equals(MessageType.STATE_TRANSITION)) {
  3.   return message.getPartitionName() + " Trans:" + message.getFromState().charAt(0) + "->"
  4.     + message.getToState().charAt(0) + "  " + UUID.randomUUID().toString();
  5.  } else {
  6.   return message.getMsgType() + " " + UUID.randomUUID().toString();
  7.  }
  8. }

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

  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: apache/helix

  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 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. private void setMessageState(CurrentStateOutput currentStateOutput, String resourceName,
  2.    Partition partition, String instanceName, Message message) {
  3.   if (MessageType.STATE_TRANSITION.name().equalsIgnoreCase(message.getMsgType())) {
  4.    currentStateOutput.setPendingMessage(resourceName, partition, instanceName, message);
  5.   } else {
  6.    currentStateOutput.setCancellationMessage(resourceName, partition, instanceName, message);
  7.   }
  8.  }
  9. }

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

  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. private void setMessageState(CurrentStateOutput currentStateOutput, String resourceName,
  2.   Partition partition, String instanceName, Message message) {
  3.  if (MessageType.STATE_TRANSITION.name().equalsIgnoreCase(message.getMsgType())) {
  4.   currentStateOutput.setPendingState(resourceName, partition, instanceName, message);
  5.  } else {
  6.   currentStateOutput.setCancellationState(resourceName, partition, instanceName, message);
  7.  }
  8. }

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

  1. @Override
  2. public HelixTaskResult handleMessage() throws InterruptedException {
  3.  String type = _message.getMsgType();
  4.  HelixTaskResult result = new HelixTaskResult();
  5.  if (!type.equals(MessageType.CONTROLLER_MSG.name())) {
  6.   throw new HelixException("Unexpected msg type for message " + _message.getMsgId()
  7.     + " type:" + _message.getMsgType());
  8.  }
  9.  result.getTaskResultMap().put("ControllerResult",
  10.    "msg " + _message.getMsgId() + " from " + _message.getMsgSrc() + " processed");
  11.  result.setSuccess(true);
  12.  return result;
  13. }

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

  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. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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