code: @Override
  	public QueueConnection createQueueConnection(String userName, String password) throws JMSException
      {
          URI providerURL = getProviderURI();
          
          String scheme = providerURL.getScheme();
          if (scheme.equals(PacketTransportType.VM))
          {
              String engineName = providerURL.getHost();
              return FFMQEngine.getDeployedInstance(engineName).openQueueConnection(userName, password, clientID);
          }
          else 
          if (scheme.equals(PacketTransportType.TCP) ||
              scheme.equals(PacketTransportType.TCPS) ||
              scheme.equals(PacketTransportType.TCPNIO))
          {
              return new RemoteQueueConnection(providerURL, userName, password, clientID);
          }
          else
              throw new FFMQException("Unknown transport protocol : " + scheme,"INVALID_TRANSPORT_PROTOCOL");
      }
docs: /*
  (non-Javadoc)
  @see javax.jms.QueueConnectionFactory#createQueueConnection(java.lang.String, java.lang.String)