@Override
  protected void finalize() throws Throwable {
    if (conn != null) {
      try {
        conn.close();
      } catch (Exception e) {
        LOG.error("Couldn't close jms connection, ignored the error", e);
      }
    }
  }
Create a JMS producer
@param topic
@return newly created message producer
@throws JMSException
hcatalog/server-extensions/src/main/java/org/apache/hive/hcatalog/listener/NotificationListener.java