public Publisher(boolean useProps,
    String jndi,
    String url,
    String connfactory,
    String topic,
    boolean useAuth,
    String user,
    String pwd) 
{
        super();
        Context ctx = initJNDI(useProps, jndi, url, useAuth, user, pwd);
        if (ctx != null) {
            initConnection(ctx, connfactory, topic);
        } else {
            log.error("Could not initialize JNDI Initial Context Factory");
        }
}

 public  void close() 
{
        try {
            log.info("Publisher closed");
            this.PUBLISHER.close();
            this.SESSION.close();
            this.CONN.close();
            this.PUBLISHER = null;
            this.SESSION = null;
            this.CONN = null;
        } catch (JMSException e) {
            log.error(e.getMessage());
        } catch (Throwable e) {
            log.error(e.getMessage());
        }
}

Clise will close the session

 public  void initConnection(Context ctx,
    String connfactory,
    String topic) 
{
        try {
            ConnectionFactory.getTopicConnectionFactory(ctx,connfactory);
            this.CONN = ConnectionFactory.getTopicConnection();
            this.TOPIC = InitialContextFactory.lookupTopic(ctx, topic);
            this.SESSION = this.CONN.createTopicSession(false, TopicSession.AUTO_ACKNOWLEDGE);
            this.PUBLISHER = this.SESSION.createPublisher(this.TOPIC);
            log.info("created the topic connection successfully");
        } catch (JMSException e) {
            log.error("Connection error: " + e.getMessage());
        }
}

 public Context initJNDI(boolean useProps,
    String jndi,
    String url,
    boolean useAuth,
    String user,
    String pwd) 
{
        if (useProps) {
            try {
                return new InitialContext();
            } catch (NamingException e) {
                log.error(e.getMessage());
                return null;
            }
        } else {
            return InitialContextFactory.lookupContext(jndi, url, useAuth, user, pwd);
        }
}

 public  void publish(String text) 
{
        try {
            TextMessage msg = this.SESSION.createTextMessage(text);
            this.PUBLISHER.publish(msg);
        } catch (JMSException e) {
            log.error(e.getMessage());
        }
}

 public  void publish(Serializable contents) 
{
        try {
            ObjectMessage msg = this.SESSION.createObjectMessage(contents);
            this.PUBLISHER.publish(msg);
        } catch (JMSException e) {
            log.error(e.getMessage());
        }
}