private void sendMessageToLocalTopicListener(TopicListener<String> topicListener, String topic, String path) {
    String message = null;
    try {
      ZNRecord zNRecord = helixStore.get(path, null, AccessOption.PERSISTENT);
      if (zNRecord != null) {
        message = zNRecord.getSimpleField(MESSAGE_KEY);
        long startTimeMs = System.currentTimeMillis();
        topicListener.onMessage(topic, message);
        logger.trace("Message has been sent to TopicListener={} on topic={} with message={} using {}ms", topicListener,
            topic, message, System.currentTimeMillis() - startTimeMs);
      } else {
        logger.debug("TopicListener={} on topic={} should receive a message, but the corresponding ZNRecord is null",
            topicListener, topic);
      }
    } catch (Exception e) {
      logger.error("Failed to send message to TopicListener={} for topic={} with message={}", topicListener, topic,
          message, e);
    }
  }
Sends a message to local {@link TopicListener} that subscribed topics through this {@code HelixNotifier}.
@param topicListener The {@link TopicListener} to send the message.
@param topic The topic which the message belongs to.
@param path The path to the topic.
ambry-commons/src/main/java/com/github/ambry/commons/HelixNotifier.java