protected MessageProducer createProducer(Destination topic) throws JMSException {
    return session.get().createProducer(topic);
  }
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