protected ConnectionFactory createConnectionFactory(String address) throws Exception {
		RabbitConnectionFactoryBean rcfb = new RabbitConnectionFactoryBean();
		rcfb.setUseSSL(this.useSSL);
		rcfb.setSslPropertiesLocation(this.sslPropertiesLocation);
		rcfb.setKeyStore(this.keyStore);
		rcfb.setKeyStorePassphrase(this.keyStorePassphrase);
		rcfb.setTrustStore(this.trustStore);
		rcfb.setKeyStorePassphrase(this.trustStorePassphrase);
		rcfb.afterPropertiesSet();
		CachingConnectionFactory ccf = new CachingConnectionFactory(rcfb.getObject());
		ccf.setAddresses(address);
		ccf.setUsername(this.username);
		ccf.setPassword(this.password);
		ccf.setVirtualHost(this.vhost);
		return ccf;
	}
Create a dedicated connection factory for the address.
@param address the address to which the factory should connect.
@return the connection factory.
@throws Exception if errors occur during creation.
spring-xd-messagebus-rabbit/src/main/java/org/springframework/xd/dirt/integration/rabbit/LocalizedQueueConnectionFactory.java