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

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

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

Message.<init>介绍

[英]Instantiate a 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/incubator-gobblin

  1. @VisibleForTesting
  2. void sendShutdownRequest() {
  3. Criteria criteria = new Criteria();
  4. criteria.setInstanceName("%");
  5. criteria.setResource("%");
  6. criteria.setPartition("%");
  7. criteria.setPartitionState("%");
  8. criteria.setRecipientInstanceType(InstanceType.CONTROLLER);
  9. criteria.setSessionSpecific(true);
  10. Message shutdownRequest = new Message(GobblinHelixConstants.SHUTDOWN_MESSAGE_TYPE,
  11. HelixMessageSubTypes.APPLICATION_MASTER_SHUTDOWN.toString().toLowerCase() + UUID.randomUUID().toString());
  12. shutdownRequest.setMsgSubType(HelixMessageSubTypes.APPLICATION_MASTER_SHUTDOWN.toString());
  13. shutdownRequest.setMsgState(Message.MessageState.NEW);
  14. shutdownRequest.setTgtSessionId("*");
  15. int messagesSent = this.helixManager.getMessagingService().send(criteria, shutdownRequest);
  16. if (messagesSent == 0) {
  17. LOGGER.error(String.format("Failed to send the %s message to the controller", shutdownRequest.getMsgSubType()));
  18. }
  19. }

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

  1. Message newMessage = new Message(message.getRecord(), id);
  2. String srcInstanceName = _manager.getInstanceName();
  3. String tgtInstanceName = map.get("instanceName");

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

  1. Message tokenFileUpdatedMessage = new Message(Message.MessageType.USER_DEFINE_MSG,
  2. HelixMessageSubTypes.TOKEN_FILE_UPDATED.toString().toLowerCase() + UUID.randomUUID().toString());
  3. tokenFileUpdatedMessage.setMsgSubType(HelixMessageSubTypes.TOKEN_FILE_UPDATED.toString());

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

  1. @VisibleForTesting
  2. void sendShutdownRequest() {
  3. final Criteria criteria = new Criteria();
  4. criteria.setInstanceName("%");
  5. criteria.setResource("%");
  6. criteria.setPartition("%");
  7. criteria.setPartitionState("%");
  8. criteria.setRecipientInstanceType(InstanceType.CONTROLLER);
  9. criteria.setSessionSpecific(true);
  10. final Message shutdownRequest = new Message(GobblinHelixConstants.SHUTDOWN_MESSAGE_TYPE,
  11. HelixMessageSubTypes.APPLICATION_MASTER_SHUTDOWN.toString().toLowerCase() + UUID.randomUUID().toString());
  12. shutdownRequest.setMsgSubType(HelixMessageSubTypes.APPLICATION_MASTER_SHUTDOWN.toString());
  13. shutdownRequest.setMsgState(Message.MessageState.NEW);
  14. shutdownRequest.setTgtSessionId("*");
  15. // Wait for 5 minutes
  16. final int timeout = 300000;
  17. // Send shutdown request to Cluster master, which will send shutdown request to workers
  18. // Upon receiving shutdown response from workers, master will shut itself down and call back shutdownASG()
  19. final int messagesSent = this.helixManager.getMessagingService().send(criteria, shutdownRequest,
  20. shutdownASG(),timeout);
  21. if (messagesSent == 0) {
  22. LOGGER.error(String.format("Failed to send the %s message to the controller", shutdownRequest.getMsgSubType()));
  23. }
  24. }

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

  1. @VisibleForTesting
  2. void sendShutdownRequest() {
  3. Criteria criteria = new Criteria();
  4. criteria.setInstanceName("%");
  5. criteria.setResource("%");
  6. criteria.setPartition("%");
  7. criteria.setPartitionState("%");
  8. criteria.setRecipientInstanceType(InstanceType.PARTICIPANT);
  9. // #HELIX-0.6.7-WORKAROUND
  10. // Add this back when messaging to instances is ported to 0.6 branch
  11. //criteria.setDataSource(Criteria.DataSource.LIVEINSTANCES);
  12. criteria.setSessionSpecific(true);
  13. Message shutdownRequest = new Message(GobblinHelixConstants.SHUTDOWN_MESSAGE_TYPE,
  14. HelixMessageSubTypes.WORK_UNIT_RUNNER_SHUTDOWN.toString().toLowerCase() + UUID.randomUUID().toString());
  15. shutdownRequest.setMsgSubType(HelixMessageSubTypes.WORK_UNIT_RUNNER_SHUTDOWN.toString());
  16. shutdownRequest.setMsgState(Message.MessageState.NEW);
  17. // Wait for 5 minutes
  18. final int timeout = 300000;
  19. // #HELIX-0.6.7-WORKAROUND
  20. // Temporarily bypass the default messaging service to allow upgrade to 0.6.7 which is missing support
  21. // for messaging to instances
  22. //int messagesSent = this.helixManager.getMessagingService().send(criteria, shutdownRequest,
  23. // new NoopReplyHandler(), timeout);
  24. GobblinHelixMessagingService messagingService = new GobblinHelixMessagingService(this.multiManager.getJobClusterHelixManager());
  25. int messagesSent = messagingService.send(criteria, shutdownRequest,
  26. new NoopReplyHandler(), timeout);
  27. if (messagesSent == 0) {
  28. LOGGER.error(String.format("Failed to send the %s message to the participants", shutdownRequest.getMsgSubType()));
  29. }
  30. }

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

  1. @VisibleForTesting
  2. public static void sendUserDefinedMessage(String messageSubType, String messageVal, String messageId,
  3. InstanceType instanceType, HelixManager helixManager, Logger logger) {
  4. Criteria criteria = new Criteria();
  5. criteria.setInstanceName("%");
  6. criteria.setResource("%");
  7. criteria.setPartition("%");
  8. criteria.setPartitionState("%");
  9. criteria.setRecipientInstanceType(instanceType);
  10. criteria.setSessionSpecific(true);
  11. Message message = new Message(Message.MessageType.USER_DEFINE_MSG.toString(), messageId);
  12. message.setMsgSubType(messageSubType);
  13. message.setAttribute(Message.Attributes.INNER_MESSAGE, messageVal);
  14. message.setMsgState(Message.MessageState.NEW);
  15. message.setTgtSessionId("*");
  16. int messagesSent = helixManager.getMessagingService().send(criteria, message);
  17. if (messagesSent == 0) {
  18. logger.error(String.format("Failed to send the %s message to the participants", message));
  19. }
  20. }
  21. }

代码示例来源: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. public void postFaultInjectionMessage(String zkServer, String clusterName, String instanceName,
  2. String payloadString, String partition) {
  3. Message message = new Message("FaultInjection", UUID.randomUUID().toString());
  4. if (payloadString != null) {
  5. message.getRecord().setSimpleField("faultType", payloadString);
  6. }
  7. if (partition != null) {
  8. message.setPartitionName(partition);
  9. }
  10. post(zkServer, message, clusterName, instanceName);
  11. }

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

  1. @Test()
  2. public void testDistControllerStateModelFactory() {
  3. DistClusterControllerStateModelFactory factory =
  4. new DistClusterControllerStateModelFactory(zkAddr);
  5. DistClusterControllerStateModel stateModel = factory.createNewStateModel("name", "key");
  6. stateModel.onBecomeStandbyFromOffline(new Message(new ZNRecord("Test")), null);
  7. }
  8. }

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

相关文章