protected Topic createTopic(final String topicName) throws JMSException {
    return session.get().createTopic(topicName);
  }
Get the topic object for the topicName

@param topicName The String identifying the message-topic.
@return A {@link Topic} object corresponding to the specified topicName.
@throws JMSException
hcatalog/server-extensions/src/main/java/org/apache/hive/hcatalog/listener/NotificationListener.java