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