import org.hornetq.api.core.client.ServerLocator; //导入依赖的package包/类
private <T extends HornetQConnectionFactory> T createEmbeddedConnectionFactory(
		Class<T> factoryClass) throws Exception {
	try {
		TransportConfiguration transportConfiguration = new TransportConfiguration(
				InVMConnectorFactory.class.getName(),
				this.properties.getEmbedded().generateTransportParameters());
		ServerLocator serviceLocator = HornetQClient
				.createServerLocatorWithoutHA(transportConfiguration);
		Constructor<T> constructor = factoryClass
				.getDeclaredConstructor(HornetQProperties.class, ServerLocator.class);
		return BeanUtils.instantiateClass(constructor, this.properties,
				serviceLocator);
	}
	catch (NoClassDefFoundError ex) {
		throw new IllegalStateException("Unable to create InVM "
				+ "HornetQ connection, ensure that hornet-jms-server.jar "
				+ "is in the classpath", ex);
	}
}
 

import org.hornetq.api.core.client.ServerLocator; //导入依赖的package包/类
private <T extends HornetQConnectionFactory> T createEmbeddedConnectionFactory(
		Class<T> factoryClass) throws Exception {
	try {
		TransportConfiguration transportConfiguration = new TransportConfiguration(
				InVMConnectorFactory.class.getName(),
				this.properties.getEmbedded().generateTransportParameters());
		ServerLocator serviceLocator = HornetQClient
				.createServerLocatorWithoutHA(transportConfiguration);
		return factoryClass.getConstructor(ServerLocator.class)
				.newInstance(serviceLocator);
	}
	catch (NoClassDefFoundError ex) {
		throw new IllegalStateException("Unable to create InVM "
				+ "HornetQ connection, ensure that hornet-jms-server.jar "
				+ "is in the classpath", ex);
	}
}
 

import org.hornetq.api.core.client.ServerLocator; //导入依赖的package包/类
/**
 * check if another instance of ioFabric is running
 *
 * @return boolean
 */
private static boolean isAnotherInstanceRunning() {
	Map<String, Object> connectionParams = new HashMap<>();
	connectionParams.put("port", 55555);
	connectionParams.put("host", "localhost");

	ServerLocator serverLocator = HornetQClient.createServerLocatorWithoutHA(
			new TransportConfiguration(NettyConnectorFactory.class.getName(), connectionParams));
	try {
		sf = serverLocator.createSessionFactory();
	} catch (Exception e) {
		return false;
	}

	return true;
}
 

import org.hornetq.api.core.client.ServerLocator; //导入依赖的package包/类
SpringBootHornetQXAConnectionFactory(HornetQProperties properties,
		ServerLocator serverLocator) {
	super(serverLocator);
	this.properties = properties;
}
 

import org.hornetq.api.core.client.ServerLocator; //导入依赖的package包/类
SpringBootHornetQConnectionFactory(HornetQProperties properties,
		ServerLocator serverLocator) {
	super(serverLocator);
	this.properties = properties;
}
 

import org.hornetq.api.core.client.ServerLocator; //导入依赖的package包/类
@Bean
@DependsOn("hornetQServer")
public ClientSessionFactory clientSessionFactory() throws Exception {
    ServerLocator serverLocator = HornetQClient.createServerLocatorWithoutHA(new TransportConfiguration(InVMConnectorFactory.class.getName()));
    return serverLocator.createSessionFactory();
}
 

import org.hornetq.api.core.client.ServerLocator; //导入依赖的package包/类
/**
 * Closes the passed-in {@link ServerLocator}.
 * 
 * @param serverLocator the {@link ServerLocator} instance to close.
 */
public static void closeServerLocator(final ServerLocator serverLocator) {
    if (serverLocator != null) {
        serverLocator.close();
    }
}