@Override
        public void onException(JMSException jmse) {
          LOG.error("JMS Exception listener received exception. Ignored the error", jmse);
        }
Create the JMS connection
@return newly created JMS connection
hcatalog/server-extensions/src/main/java/org/apache/hive/hcatalog/listener/NotificationListener.java