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

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

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

Message.setTgtName介绍

[英]Set the instance for which this message is targeted
[中]设置此消息的目标实例

代码示例

代码示例来源：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. newMessage.setTgtName(tgtInstanceName);
  2. newMessage.setResourceName(map.get("resourceName"));
  3. newMessage.setPartitionName(map.get("partitionName"));

代码示例来源：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: 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.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. 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. private static Message newMsg() {
  2.   Message msg = new Message(DUMMY_MSG_TYPE, UUID.randomUUID().toString());
  3.   msg.setTgtSessionId("*");
  4.   msg.setTgtName("localhost_12918");
  5.   return msg;
  6.  }
  7. }

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

  1. @Test()
  2. public void testOnBecomeOfflineFromStandby() {
  3.  Message message = new Message(MessageType.STATE_TRANSITION, "0");
  4.  message.setPartitionName(clusterName);
  5.  message.setTgtName("controller_0");
  6.  stateModel.onBecomeOfflineFromStandby(message, null);
  7. }

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

  1. private void sendNopMessageInternal() {
  2.  try {
  3.   Message nopMsg = new Message(MessageType.NO_OP, UUID.randomUUID().toString());
  4.   nopMsg.setSrcName(_manager.getInstanceName());
  5.   HelixDataAccessor accessor = _manager.getHelixDataAccessor();
  6.   Builder keyBuilder = accessor.keyBuilder();
  7.   if (_manager.getInstanceType() == InstanceType.CONTROLLER
  8.     || _manager.getInstanceType() == InstanceType.CONTROLLER_PARTICIPANT) {
  9.    nopMsg.setTgtName(InstanceType.CONTROLLER.name());
  10.    accessor.setProperty(keyBuilder.controllerMessage(nopMsg.getId()), nopMsg);
  11.   }
  12.   if (_manager.getInstanceType() == InstanceType.PARTICIPANT
  13.     || _manager.getInstanceType() == InstanceType.CONTROLLER_PARTICIPANT) {
  14.    nopMsg.setTgtName(_manager.getInstanceName());
  15.    accessor.setProperty(keyBuilder.message(nopMsg.getTgtName(), nopMsg.getId()), nopMsg);
  16.   }
  17.  } catch (Exception e) {
  18.   _logger.error(e.toString());
  19.  }
  20. }

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

  1. @Test()
  2. public void testReset() {
  3.  Message message = new Message(MessageType.STATE_TRANSITION, "0");
  4.  message.setPartitionName(clusterName);
  5.  message.setTgtName("controller_0");
  6.  try {
  7.   stateModel.onBecomeLeaderFromStandby(message, new NotificationContext(null));
  8.  } catch (Exception e) {
  9.   LOG.error("Exception becoming leader from standby", e);
  10.  }
  11.  stateModel.reset();
  12. }

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

  1. @Test()
  2. public void testOnBecomeStandbyFromLeader() {
  3.  Message message = new Message(MessageType.STATE_TRANSITION, "0");
  4.  message.setPartitionName(clusterName);
  5.  message.setTgtName("controller_0");
  6.  stateModel.onBecomeStandbyFromLeader(message, new NotificationContext(null));
  7. }

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

  1. @Test()
  2. public void testRollbackOnError() {
  3.  Message message = new Message(MessageType.STATE_TRANSITION, "0");
  4.  message.setPartitionName(clusterName);
  5.  message.setTgtName("controller_0");
  6.  try {
  7.   stateModel.onBecomeLeaderFromStandby(message, new NotificationContext(null));
  8.  } catch (Exception e) {
  9.   LOG.error("Exception becoming leader from standby", e);
  10.  }
  11.  stateModel.rollbackOnError(message, new NotificationContext(null), null);
  12. }

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

  1. @Test()
  2. public void testOnBecomeLeaderFromStandby() {
  3.  Message message = new Message(MessageType.STATE_TRANSITION, "0");
  4.  message.setPartitionName(clusterName);
  5.  message.setTgtName("controller_0");
  6.  try {
  7.   stateModel.onBecomeLeaderFromStandby(message, new NotificationContext(null));
  8.  } catch (Exception e) {
  9.   LOG.error("Exception becoming leader from standby", e);
  10.  }
  11.  stateModel.onBecomeStandbyFromLeader(message, new NotificationContext(null));
  12. }

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

  1. public void postTestMessage(String zkServer, String clusterName, String instanceName) {
  2.  String msgSrc = "cm-instance-0";
  3.  String msgId = "TestMessageId-2";
  4.  Message message = new Message(MessageType.STATE_TRANSITION, msgId);
  5.  message.setMsgId(msgId);
  6.  message.setSrcName(msgSrc);
  7.  message.setTgtName(instanceName);
  8.  message.setMsgState(MessageState.NEW);
  9.  message.setFromState("Slave");
  10.  message.setToState("Master");
  11.  message.setPartitionName("EspressoDB.partition-0." + instanceName);
  12.  post(zkServer, message, clusterName, instanceName);
  13. }

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

  1. public void postTestMessage(String zkServer, String clusterName, String instanceName) {
  2.  String msgSrc = "cm-instance-0";
  3.  String msgId = "TestMessageId-2";
  4.  Message message = new Message(MessageType.STATE_TRANSITION, msgId);
  5.  message.setMsgId(msgId);
  6.  message.setSrcName(msgSrc);
  7.  message.setTgtName(instanceName);
  8.  message.setMsgState(MessageState.NEW);
  9.  message.setFromState("Slave");
  10.  message.setToState("Master");
  11.  message.setPartitionName("EspressoDB.partition-0." + instanceName);
  12.  post(zkServer, message, clusterName, instanceName);
  13. }

代码示例来源：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. 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. protected Message createMessage(Message.MessageType type, String msgId, String fromState, String toState,
  2.   String resourceName, String tgtName) {
  3.  Message msg = new Message(type.toString(), msgId);
  4.  msg.setFromState(fromState);
  5.  msg.setToState(toState);
  6.  msg.getRecord().setSimpleField(Message.Attributes.RESOURCE_NAME.toString(), resourceName);
  7.  msg.setTgtName(tgtName);
  8.  return msg;
  9. }

代码示例来源：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. }

代码示例来源：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. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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