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