private  TopicConnection _conn =  null ;
     private  TopicSession _session =  null ;
     private  Topic _topic =  null ;
    ...
     public   void  setupPubSub()  throws  JMSException, NamingException
    {
        InitialContext iniCtx =  new  InitialContext();
        Object tmp = iniCtx.lookup("ConnectionFactory");
        TopicConnectionFactory tcf = (TopicConnectionFactory) tmp;
        _conn = tcf.createTopicConnection();

        _topic = (Topic) iniCtx.lookup("topic/OpenProcTopic");
        _session = _conn.createTopicSession(false,
                                            TopicSession.AUTO_ACKNOWLEDGE);
        _conn.start();
    }