import org.hornetq.api.core.client.HornetQClient; //导入依赖的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.HornetQClient; //导入依赖的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.HornetQClient; //导入依赖的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.HornetQClient; //导入依赖的package包/类
@Test
public void mustFallbacktoSuperclassBecauseNoAuthoritiesConfiguredNoWindowSize()
        throws Exception {
    ClusteredHornetQProperties noAuthorities = new ClusteredHornetQProperties();
    ClusteredHornetQConnectionFactoryFactory uut = spy(
            new ClusteredHornetQConnectionFactoryFactory(mockBeanFactory, noAuthorities));
    HornetQConnectionFactory connectionFactory = uut.createConnectionFactory(factoryClass);
    verify(uut, times(1)).callSuperCreateConnectionFactory(factoryClass);
    assertEquals(HornetQClient.DEFAULT_CONSUMER_WINDOW_SIZE, connectionFactory
            .getConsumerWindowSize());
}
 

import org.hornetq.api.core.client.HornetQClient; //导入依赖的package包/类
@Test
public void mustNotFallbacktoSuperclassBecauseTwoAuthoritiesConfiguredNoWindowSize()
        throws Exception {
    ClusteredHornetQProperties twoAuthorities = new ClusteredHornetQProperties();
    twoAuthorities.setAuthorities("foo:8888,bar:9999");
    ClusteredHornetQConnectionFactoryFactory uut = spy(
            new ClusteredHornetQConnectionFactoryFactory(mockBeanFactory, twoAuthorities));
    HornetQConnectionFactory connectionFactory = uut.createConnectionFactory(factoryClass);
    verify(uut, never()).callSuperCreateConnectionFactory(factoryClass);
    assertEquals(HornetQClient.DEFAULT_CONSUMER_WINDOW_SIZE, connectionFactory
            .getConsumerWindowSize());
}
 

import org.hornetq.api.core.client.HornetQClient; //导入依赖的package包/类
private org.hornetq.api.core.client.ClientSession createHQClientSession() throws Exception {
   Map<String, Object> map = new HashMap<>();
   map.put("host", "localhost");
   map.put("port", 5445);

   org.hornetq.api.core.client.ServerLocator serverLocator = HornetQClient.createServerLocatorWithoutHA(new org.hornetq.api.core.TransportConfiguration(org.hornetq.core.remoting.impl.netty.NettyConnectorFactory.class.getName(), map));
   org.hornetq.api.core.client.ClientSessionFactory sf = serverLocator.createSessionFactory();

   return sf.createSession();
}
 

import org.hornetq.api.core.client.HornetQClient; //导入依赖的package包/类
/**
 * Close the existing ClientSession if exists and create new one.
 * @return ClientSession instance
 */
public ClientSession createClientSession() {
    closeSession(_clientSession);
    
    try {
        if (_serverLocator == null || _clientSessionFactory == null) {
            if (_startEmbedded) {
                _serverLocator = HornetQClient.createServerLocatorWithoutHA(getTransports(getConfiguration()));
                _clientSessionFactory = _serverLocator.createSessionFactory();
            } else {
                _serverLocator = HornetQClient.createServerLocatorWithoutHA(
                        new TransportConfiguration(NettyConnectorFactory.class.getName(), _transportParams));
                _clientSessionFactory = _serverLocator.createSessionFactory();
            }
        }
        
        _clientSession = _clientSessionFactory.createSession(_user,
                                                            _passwd,
                                                            false,
                                                            true,
                                                            true,
                                                            _serverLocator.isPreAcknowledge(),
                                                            _serverLocator.getAckBatchSize());
        _clientSession.start();
        return _clientSession;
    } catch (Exception e) {
        throw new RuntimeException(e);
    }
}
 

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