protected Session createSession() throws JMSException {
    if (conn == null) {
      return null;
    }
    // We want message to be sent when session commits, thus we run in
    // transacted mode.
    return conn.createSession(true, Session.SESSION_TRANSACTED);
  }
Creates a JMS session
@return newly create JMS session
@throws JMSException
hcatalog/server-extensions/src/main/java/org/apache/hive/hcatalog/listener/NotificationListener.java