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