private static String getTopicName(Table table) {
    return table.getParameters().get(HCatConstants.HCAT_MSGBUS_TOPIC_NAME);
  }
Create message bus connection and session in constructor.
hcatalog/server-extensions/src/main/java/org/apache/hive/hcatalog/listener/NotificationListener.java