protected boolean isConnectionHealthy() {
    try {
      Topic topic = createTopic(getTopicPrefix(getConf()) + "." + HEALTH_CHECK_TOPIC_SUFFIX);
      MessageProducer producer = createProducer(topic);
      Message msg = session.get().createTextMessage(HEALTH_CHECK_MSG);
      producer.send(msg, DeliveryMode.NON_PERSISTENT, 4, 0);
    } catch (Exception e) {
      return false;
    }
    return true;
  }
Send a dummy message to probe if the JMS connection is healthy
@return true if connection is healthy, false otherwise
hcatalog/server-extensions/src/main/java/org/apache/hive/hcatalog/listener/NotificationListener.java