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

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

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

Message.setMsgId介绍

[英]Set the unique identifier of this message
[中]设置此消息的唯一标识符

代码示例

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

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

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

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

代码示例来源：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: 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. /**
  2.  * Instantiate a message
  3.  * @param type {@link MessageType} as a string or a custom message type
  4.  * @param msgId unique message identifier
  5.  */
  6. public Message(String type, String msgId) {
  7.  super(new ZNRecord(msgId));
  8.  _record.setSimpleField(Attributes.MSG_TYPE.toString(), type);
  9.  setMsgId(msgId);
  10.  setMsgState(MessageState.NEW);
  11.  _record.setLongField(Attributes.CREATE_TIMESTAMP.toString(), new Date().getTime());
  12. }

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

  1. /**
  2.  * Instantiate a message
  3.  * @param type {@link MessageType} as a string or a custom message type
  4.  * @param msgId unique message identifier
  5.  */
  6. public Message(String type, String msgId) {
  7.  super(new ZNRecord(msgId));
  8.  _record.setSimpleField(Attributes.MSG_TYPE.toString(), type);
  9.  setMsgId(msgId);
  10.  setMsgState(MessageState.NEW);
  11.  _record.setLongField(Attributes.CREATE_TIMESTAMP.toString(), new Date().getTime());
  12. }

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

  1. private void syncSessionToController(HelixManager manager) {
  2.  if (_lastSessionSyncTime == null ||
  3.      System.currentTimeMillis() - _lastSessionSyncTime > SESSION_SYNC_INTERVAL) { // > delay since last sync
  4.   HelixDataAccessor accessor = manager.getHelixDataAccessor();
  5.   PropertyKey key = new Builder(manager.getClusterName()).controllerMessage(SESSION_SYNC);
  6.   if (accessor.getProperty(key) == null) {
  7.    LOG.info(String.format("Participant %s syncs session with controller", manager.getInstanceName()));
  8.    Message msg = new Message(MessageType.PARTICIPANT_SESSION_CHANGE, SESSION_SYNC);
  9.    msg.setSrcName(manager.getInstanceName());
  10.    msg.setTgtSessionId("*");
  11.    msg.setMsgState(MessageState.NEW);
  12.    msg.setMsgId(SESSION_SYNC);
  13.    Criteria cr = new Criteria();
  14.    cr.setRecipientInstanceType(InstanceType.CONTROLLER);
  15.    cr.setSessionSpecific(false);
  16.    manager.getMessagingService().send(cr, msg);
  17.    _lastSessionSyncTime = System.currentTimeMillis();
  18.   }
  19.  }
  20. }

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

  1. private void syncSessionToController(HelixManager manager) {
  2.  if (_lastSessionSyncTime == null ||
  3.      System.currentTimeMillis() - _lastSessionSyncTime > SESSION_SYNC_INTERVAL) { // > delay since last sync
  4.   HelixDataAccessor accessor = manager.getHelixDataAccessor();
  5.   PropertyKey key = new Builder(manager.getClusterName()).controllerMessage(SESSION_SYNC);
  6.   if (accessor.getProperty(key) == null) {
  7.    LOG.info(String.format("Participant %s syncs session with controller", manager.getInstanceName()));
  8.    Message msg = new Message(MessageType.PARTICIPANT_SESSION_CHANGE, SESSION_SYNC);
  9.    msg.setSrcName(manager.getInstanceName());
  10.    msg.setTgtSessionId("*");
  11.    msg.setMsgState(MessageState.NEW);
  12.    msg.setMsgId(SESSION_SYNC);
  13.    Criteria cr = new Criteria();
  14.    cr.setRecipientInstanceType(InstanceType.CONTROLLER);
  15.    cr.setSessionSpecific(false);
  16.    manager.getMessagingService().send(cr, msg);
  17.    _lastSessionSyncTime = System.currentTimeMillis();
  18.   }
  19.  }
  20. }

代码示例来源：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. void sendMessage(String msgId, String instanceName, String fromState, String toState,
  2.   String partitionKey, int partitionId) throws InterruptedException, JsonGenerationException,
  3.   JsonMappingException, IOException {
  4.  Message message = new Message(MessageType.STATE_TRANSITION, msgId);
  5.  message.setMsgId(msgId);
  6.  message.setSrcName(srcName);
  7.  message.setTgtName(instanceName);
  8.  message.setMsgState(MessageState.NEW);
  9.  message.setFromState(fromState);
  10.  message.setToState(toState);
  11.  // message.setPartitionId(partitionId);
  12.  message.setPartitionName(partitionKey);
  13.  String path = PropertyPathBuilder.instanceMessage(clusterName, instanceName, message.getId());
  14.  ObjectMapper mapper = new ObjectMapper();
  15.  StringWriter sw = new StringWriter();
  16.  mapper.writeValueUsingView(sw, message, Message.class);
  17.  System.out.println(sw.toString());
  18.  client.delete(path);
  19.  Thread.sleep(10000);
  20.  ZNRecord record = client.readData(PropertyPathBuilder.liveInstance(clusterName, instanceName));
  21.  message.setTgtSessionId(record.getSimpleField(LiveInstanceProperty.SESSION_ID.toString())
  22.    .toString());
  23.  client.createPersistent(path, message);
  24. }

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

  1. @Test()
  2. public void sendSelfMsg() {
  3.  String hostSrc = "localhost_" + START_PORT;
  4.  for (int i = 0; i < NODE_NR; i++) {
  5.   TestMessagingHandlerFactory factory = new TestMessagingHandlerFactory();
  6.   String hostDest = "localhost_" + (START_PORT + i);
  7.   _participants[i].getMessagingService().registerMessageHandlerFactory(
  8.     factory.getMessageTypes(), factory);
  9.  }
  10.  String msgId = new UUID(123, 456).toString();
  11.  Message msg = new Message(new TestMessagingHandlerFactory().getMessageTypes().get(0), msgId);
  12.  msg.setMsgId(msgId);
  13.  msg.setSrcName(hostSrc);
  14.  msg.setTgtSessionId("*");
  15.  msg.setMsgState(MessageState.NEW);
  16.  String para = "Testing messaging para";
  17.  msg.getRecord().setSimpleField("TestMessagingPara", para);
  18.  Criteria cr = new Criteria();
  19.  cr.setInstanceName("%");
  20.  cr.setRecipientInstanceType(InstanceType.PARTICIPANT);
  21.  cr.setSessionSpecific(false);
  22.  cr.setSelfExcluded(false);
  23.  AsyncCallback callback1 = new MockAsyncCallback();
  24.  int messageSent1 =
  25.    _participants[0].getMessagingService().sendAndWait(cr, msg, callback1, 10000);
  26.  AssertJUnit.assertTrue(callback1.getMessageReplied().size() == NODE_NR);
  27.  AssertJUnit.assertTrue(callback1.getMessageReplied().get(0).getRecord()
  28.    .getMapField(Message.Attributes.MESSAGE_RESULT.toString()).get("ReplyMessage")
  29.    .equals("TestReplyMessage"));
  30. }

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

  1. msg.setMsgId(msgId);
  2. msg.setSrcName(hostSrc);
  3. msg.setTgtSessionId("*");

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

  1. @Test()
  2. public void TestBlockingSendReceive() throws Exception {
  3.  String hostSrc = "localhost_" + START_PORT;
  4.  String hostDest = "localhost_" + (START_PORT + 1);
  5.  TestMessagingHandlerFactory factory = new TestMessagingHandlerFactory();
  6.  _participants[1].getMessagingService().registerMessageHandlerFactory(factory.getMessageTypes(),
  7.    factory);
  8.  String msgId = new UUID(123, 456).toString();
  9.  Message msg = new Message(factory.getMessageTypes().get(0), msgId);
  10.  msg.setMsgId(msgId);
  11.  msg.setSrcName(hostSrc);
  12.  msg.setTgtSessionId("*");
  13.  msg.setMsgState(MessageState.NEW);
  14.  String para = "Testing messaging para";
  15.  msg.getRecord().setSimpleField("TestMessagingPara", para);
  16.  Criteria cr = new Criteria();
  17.  cr.setInstanceName(hostDest);
  18.  cr.setRecipientInstanceType(InstanceType.PARTICIPANT);
  19.  cr.setSessionSpecific(false);
  20.  AsyncCallback asyncCallback = new MockAsyncCallback();
  21.  int messagesSent =
  22.    _participants[0].getMessagingService().sendAndWait(cr, msg, asyncCallback, 60000);
  23.  AssertJUnit.assertTrue(asyncCallback.getMessageReplied().get(0).getRecord()
  24.    .getMapField(Message.Attributes.MESSAGE_RESULT.toString()).get("ReplyMessage")
  25.    .equals("TestReplyMessage"));
  26.  AssertJUnit.assertTrue(asyncCallback.getMessageReplied().size() == 1);
  27.  AsyncCallback asyncCallback2 = new MockAsyncCallback();
  28.  messagesSent = _participants[0].getMessagingService().sendAndWait(cr, msg, asyncCallback2, 500);
  29.  AssertJUnit.assertTrue(asyncCallback2.isTimedOut());
  30. }

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

  1. @Test()
  2. public void TestBlockingSendReceive() {
  3.  String hostDest = "localhost_" + (START_PORT + 1);
  4.  TestMessagingHandlerFactory factory = new TestMessagingHandlerFactory();
  5.  _participants[1].getMessagingService()
  6.    .registerMessageHandlerFactory(factory.getMessageTypes(), factory);
  7.  String msgId = new UUID(123, 456).toString();
  8.  Message msg = new Message(factory.getMessageTypes().get(0), msgId);
  9.  msg.setMsgId(msgId);
  10.  msg.setSrcName(_hostSrc);
  11.  msg.setTgtSessionId("*");
  12.  msg.setMsgState(MessageState.NEW);
  13.  String para = "Testing messaging para";
  14.  msg.getRecord().setSimpleField("TestMessagingPara", para);
  15.  Criteria cr = new Criteria();
  16.  cr.setInstanceName(hostDest);
  17.  cr.setRecipientInstanceType(InstanceType.PARTICIPANT);
  18.  cr.setSessionSpecific(false);
  19.  cr.setClusterName(CLUSTER_NAME);
  20.  AsyncCallback asyncCallback = new MockAsyncCallback();
  21.  int messagesSent =
  22.    _adminController.getMessagingService().sendAndWait(cr, msg, asyncCallback, 60000);
  23.  AssertJUnit.assertTrue(asyncCallback.getMessageReplied().get(0).getRecord()
  24.    .getMapField(Message.Attributes.MESSAGE_RESULT.toString()).get("ReplyMessage")
  25.    .equals("TestReplyMessage"));
  26.  AssertJUnit.assertTrue(asyncCallback.getMessageReplied().size() == 1);
  27.  AsyncCallback asyncCallback2 = new MockAsyncCallback();
  28.  messagesSent = _adminController.getMessagingService().sendAndWait(cr, msg, asyncCallback2, 500);
  29.  AssertJUnit.assertTrue(asyncCallback2.isTimedOut());
  30. }

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

  1. msg.setMsgId(msgId);
  2. msg.setSrcName(_hostSrc);
  3. msg.setTgtSessionId("*");

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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