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

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

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

Message.setResourceName介绍

[英]Set the resource associated with this message
[中]设置与此消息关联的资源

代码示例

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

  1. newMessage.setResourceName(map.get("resourceName"));
  2. newMessage.setPartitionName(map.get("partitionName"));
  3. if (recipientCriteria.isSessionSpecific()) {

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

  1. newMessage.setResourceName(map.get("resourceName"));
  2. newMessage.setPartitionName(map.get("partitionName"));
  3. if (recipientCriteria.isSessionSpecific()) {

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

  1. newMessage.setResourceName(map.get("resourceName"));
  2. newMessage.setPartitionName(map.get("partitionName"));
  3. if (recipientCriteria.isSessionSpecific()) {

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

  1. newMessage.setResourceName(map.get("resourceName"));
  2. newMessage.setPartitionName(map.get("partitionName"));
  3. if (recipientCriteria.isSessionSpecific()) {

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

  1. newMessage.setResourceName(map.get("resourceName"));
  2. newMessage.setPartitionName(map.get("partitionName"));
  3. if (recipientCriteria.isSessionSpecific()) {

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

  1. @Override public void doInject(ClusterDataCache cache) {
  2.   String topStateNode = null;
  3.   for (String instance : cfg.initialCurrentStates.keySet()) {
  4.    if (cfg.initialCurrentStates.get(instance).currentState.equals("MASTER")) {
  5.     topStateNode = instance;
  6.     break;
  7.    }
  8.   }
  9.   // Simulate the previous top state instance goes offline
  10.   if (topStateNode != null) {
  11.    long originalStartTime = cfg.currentStateWithMissingTopState.get(topStateNode).startTime;
  12.    // Inject a message that fit expectedDuration
  13.    Message message =
  14.      new Message(Message.MessageType.STATE_TRANSITION, "thisisafakemessage");
  15.    message.setTgtSessionId(SESSION_PREFIX + topStateNode.split("_")[1]);
  16.    message.setToState("MASTER");
  17.    message.setCreateTimeStamp(originalStartTime - messageTimeBeforeMasterless);
  18.    message.setTgtName(topStateNode);
  19.    message.setResourceName(TEST_RESOURCE);
  20.    message.setPartitionName(PARTITION);
  21.    cache.cacheMessages(Collections.singletonList(message));
  22.   }
  23.  }
  24. }, 1, 0,

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

  1. public static Message createMessage(String msgId, String fromState, String toState,
  2.   String tgtName, String resourceName, String partitionName) {
  3.  Message msg = new Message(MessageType.STATE_TRANSITION, msgId);
  4.  msg.setFromState(fromState);
  5.  msg.setToState(toState);
  6.  msg.setTgtName(tgtName);
  7.  msg.setResourceName(resourceName);
  8.  msg.setPartitionName(partitionName);
  9.  msg.setStateModelDef("MasterSlave");
  10.  return msg;
  11. }

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

  1. private Message createStateTransitionCancellationMessage(HelixManager manager, Resource resource,
  2.   String partitionName, String instanceName, String sessionId, String stateModelDefName,
  3.   String fromState, String toState, String nextState, Message cancellationMessage, boolean isCancellationEnabled,
  4.   String currentState) {
  5.  if (isCancellationEnabled && cancellationMessage == null) {
  6.   LogUtil.logInfo(logger, _eventId,
  7.     "Send cancellation message of the state transition for " + resource.getResourceName()
  8.       + "." + partitionName + " on " + instanceName + ", currentState: " + currentState
  9.       + ", nextState: " + (nextState == null ? "N/A" : nextState));
  10.   String uuid = UUID.randomUUID().toString();
  11.   Message message = new Message(MessageType.STATE_TRANSITION_CANCELLATION, uuid);
  12.   message.setSrcName(manager.getInstanceName());
  13.   message.setTgtName(instanceName);
  14.   message.setMsgState(MessageState.NEW);
  15.   message.setPartitionName(partitionName);
  16.   message.setResourceName(resource.getResourceName());
  17.   message.setFromState(fromState);
  18.   message.setToState(toState);
  19.   message.setTgtSessionId(sessionId);
  20.   message.setSrcSessionId(manager.getSessionId());
  21.   message.setStateModelDef(stateModelDefName);
  22.   message.setStateModelFactoryName(resource.getStateModelFactoryname());
  23.   message.setBucketSize(resource.getBucketSize());
  24.   return message;
  25.  }
  26.  return null;
  27. }

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

  1. private Message createStateTransitionCancellationMessage(HelixManager manager, Resource resource,
  2.   String partitionName, String instanceName, String sessionId, String stateModelDefName,
  3.   String fromState, String toState, String nextState, Message cancellationMessage,
  4.   boolean isCancellationEnabled, String currentState) {
  5.  if (isCancellationEnabled && cancellationMessage == null) {
  6.   LogUtil.logInfo(logger, _eventId,
  7.     "Send cancellation message of the state transition for " + resource.getResourceName()
  8.       + "." + partitionName + " on " + instanceName + ", currentState: " + currentState
  9.       + ", nextState: " + (nextState == null ? "N/A" : nextState));
  10.   String uuid = UUID.randomUUID().toString();
  11.   Message message = new Message(MessageType.STATE_TRANSITION_CANCELLATION, uuid);
  12.   message.setSrcName(manager.getInstanceName());
  13.   message.setTgtName(instanceName);
  14.   message.setMsgState(MessageState.NEW);
  15.   message.setPartitionName(partitionName);
  16.   message.setResourceName(resource.getResourceName());
  17.   message.setFromState(fromState);
  18.   message.setToState(toState);
  19.   message.setTgtSessionId(sessionId);
  20.   message.setSrcSessionId(manager.getSessionId());
  21.   message.setStateModelDef(stateModelDefName);
  22.   message.setStateModelFactoryName(resource.getStateModelFactoryname());
  23.   message.setBucketSize(resource.getBucketSize());
  24.   return message;
  25.  }
  26.  return null;
  27. }

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

  1. msg1.setTgtSessionId("*");
  2. msg1.setPartitionName("P1");
  3. msg1.setResourceName("R1");
  4. msg1.setTgtName("Localhost_1123");
  5. msg1.setSrcName("127.101.1.23_2234");
  6. msg2.setTgtSessionId("*");
  7. msg2.setPartitionName("P1");
  8. msg2.setResourceName("R1");
  9. msg2.setTgtName("Localhost_1123");
  10. msg2.setSrcName("127.101.1.23_2234");

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

  1. msg.setSrcName("127.101.1.23_2234");
  2. msg.setPartitionName("Partition");
  3. msg.setResourceName("Resource");
  4. msg.setStateModelDef("DummyMasterSlave");
  5. msg.setFromState("SLAVE");

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

  1. private Message createStateTransitionMessage(HelixManager manager, Resource resource,
  2.   String partitionName, String instanceName, String currentState, String nextState,
  3.   String sessionId, String stateModelDefName) {
  4.  String uuid = UUID.randomUUID().toString();
  5.  Message message = new Message(MessageType.STATE_TRANSITION, uuid);
  6.  message.setSrcName(manager.getInstanceName());
  7.  message.setTgtName(instanceName);
  8.  message.setMsgState(MessageState.NEW);
  9.  message.setPartitionName(partitionName);
  10.  message.setResourceName(resource.getResourceName());
  11.  message.setFromState(currentState);
  12.  message.setToState(nextState);
  13.  message.setTgtSessionId(sessionId);
  14.  message.setSrcSessionId(manager.getSessionId());
  15.  message.setStateModelDef(stateModelDefName);
  16.  message.setStateModelFactoryName(resource.getStateModelFactoryname());
  17.  message.setBucketSize(resource.getBucketSize());
  18.  if (resource.getResourceGroupName() != null) {
  19.   message.setResourceGroupName(resource.getResourceGroupName());
  20.  }
  21.  if (resource.getResourceTag() != null) {
  22.   message.setResourceTag(resource.getResourceTag());
  23.  }
  24.  return message;
  25. }

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

  1. private Message createStateTransitionMessage(HelixManager manager, Resource resource, String partitionName,
  2.   String instanceName, String currentState, String nextState, String sessionId,
  3.   String stateModelDefName) {
  4.  String uuid = UUID.randomUUID().toString();
  5.  Message message = new Message(MessageType.STATE_TRANSITION, uuid);
  6.  message.setSrcName(manager.getInstanceName());
  7.  message.setTgtName(instanceName);
  8.  message.setMsgState(MessageState.NEW);
  9.  message.setPartitionName(partitionName);
  10.  message.setResourceName(resource.getResourceName());
  11.  message.setFromState(currentState);
  12.  message.setToState(nextState);
  13.  message.setTgtSessionId(sessionId);
  14.  message.setSrcSessionId(manager.getSessionId());
  15.  message.setStateModelDef(stateModelDefName);
  16.  message.setStateModelFactoryName(resource.getStateModelFactoryname());
  17.  message.setBucketSize(resource.getBucketSize());
  18.  if (resource.getResourceGroupName() != null) {
  19.   message.setResourceGroupName(resource.getResourceGroupName());
  20.  }
  21.  if (resource.getResourceTag() != null) {
  22.   message.setResourceTag(resource.getResourceTag());
  23.  }
  24.  return message;
  25. }

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

  1. private Message newMessage(String resourceName, String partitionName, String instanceName,
  2.   String fromState, String toState) {
  3.  String uuid = UUID.randomUUID().toString();
  4.  Message message = new Message(MessageType.STATE_TRANSITION, uuid);
  5.  message.setSrcName("controller");
  6.  message.setTgtName(instanceName);
  7.  message.setMsgState(MessageState.NEW);
  8.  message.setResourceName(resourceName);
  9.  message.setPartitionName(partitionName);
  10.  message.setFromState(fromState);
  11.  message.setToState(toState);
  12.  message.setTgtSessionId("sessionId");
  13.  message.setSrcSessionId("sessionId");
  14.  message.setStateModelDef("MasterSlave");
  15.  message.setStateModelFactoryName("DEFAULT");
  16.  message.setBucketSize(0);
  17.  return message;
  18. }

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

  1. new Message(MessageType.PARTICIPANT_ERROR_REPORT, UUID.randomUUID().toString());
  2. errorMessage2.setTgtSessionId("*");
  3. errorMessage2.setResourceName("TestDB");
  4. errorMessage2.setPartitionName("TestDB_14");
  5. errorMessage2.getRecord().setSimpleField(

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

  1. private Message generateMessage(String from, String to) {
  2.  String uuid = UUID.randomUUID().toString();
  3.  Message message = new Message(Message.MessageType.STATE_TRANSITION, uuid);
  4.  message.setSrcName("ADMIN");
  5.  message.setTgtName(_participant.getInstanceName());
  6.  message.setMsgState(Message.MessageState.NEW);
  7.  message.setPartitionName("P");
  8.  message.setResourceName(WorkflowGenerator.DEFAULT_TGT_DB);
  9.  message.setFromState(from);
  10.  message.setToState(to);
  11.  message.setTgtSessionId(_participant.getSessionId());
  12.  message.setSrcSessionId(_manager.getSessionId());
  13.  message.setStateModelDef("OnlineOffline");
  14.  message.setStateModelFactoryName("DEFAULT");
  15.  return message;
  16. }

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

  1. message.setMsgState(MessageState.NEW);
  2. message.setPartitionName(partition);
  3. message.setResourceName(TEST_DB);
  4. message.setFromState(rand ? "SLAVE" : "OFFLINE");
  5. message.setToState(rand ? "MASTER" : "SLAVE");
  6. message.setMsgState(MessageState.NEW);
  7. message.setPartitionName(partition);
  8. message.setResourceName(TEST_DB);
  9. message.setFromState(rand ? "MASTER" : "OFFLINE");
  10. message.setToState(rand ? "SLAVE" : "SLAVE");

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

  1. message.setPartitionName("TestDB_0");
  2. message.setMsgId("Some unique message id");
  3. message.setResourceName("TestDB");
  4. message.setTgtName("localhost");
  5. message.setStateModelDef("MasterSlave");

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

  1. message.setPartitionName("TestDB_0");
  2. message.setMsgId("Some unique message id");
  3. message.setResourceName("TestDB");
  4. message.setTgtName("localhost");
  5. message.setStateModelDef("MasterSlave");

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

  1. message.setToState("Slave");
  2. message.setPartitionName("TestDB_0");
  3. message.setResourceName("TestDB");
  4. message.setStateModelDef("MasterSlave");

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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