code: @Override
  	public synchronized TopicSession createTopicSession(boolean transacted, int acknowledgeMode) throws JMSException
      {
          checkNotClosed();
          LocalTopicSession session =  new LocalTopicSession(idProvider.createID(),this,engine,transacted,acknowledgeMode);
          registerSession(session);
          return session;
      }
docs: /*
  (non-Javadoc)
  @see javax.jms.TopicConnection#createTopicSession(boolean, int)