code: @Override
  	public TopicConnection createTopicConnection(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).openTopicConnection(userName, password, clientID);
          }
          else 
      	if (scheme.equals(PacketTransportType.TCP) ||
              scheme.equals(PacketTransportType.TCPS) ||
              scheme.equals(PacketTransportType.TCPNIO))
      	{
              return new RemoteTopicConnection(providerURL, userName, password, clientID);
      	}
          else
              throw new FFMQException("Unknown transport protocol : " + scheme,"INVALID_TRANSPORT_PROTOCOL");
      }
docs: /* (non-Javadoc)
  @see javax.jms.TopicConnectionFactory#createTopicConnection(java.lang.String, java.lang.String)