import org.hornetq.core.remoting.impl.netty.TransportConstants; //导入依赖的package包/类
@Bean
public MessageListenerContainer hornetQMessageListenerContainer() {
	Map<String, Object> map = new HashMap<String, Object>();
       map.put(TransportConstants.HOST_PROP_NAME, hornetq_host);  
       map.put(TransportConstants.PORT_PROP_NAME, hornetq_port);
	TransportConfiguration transportConfiguration =new TransportConfiguration(
			NettyConnectorFactory.class.getName(), map);
	
	HornetQConnectionFactory hornetQConnectionFactory = HornetQJMSClient.createConnectionFactoryWithoutHA(
			JMSFactoryType.CF, transportConfiguration);
	
	DefaultMessageListenerContainer container = new DefaultMessageListenerContainer();
	container.setConnectionFactory((ConnectionFactory) hornetQConnectionFactory);
	container.setDestination(HornetQJMSClient.createTopic(IMConstant.GATEWAY_USERREGISTER_TOPIC));
	container.setPubSubDomain(true);
	container.setPubSubNoLocal(true);
	container.setMessageListener(userRegisterListener);
	container.setSessionAcknowledgeMode(Session.AUTO_ACKNOWLEDGE);
	return container;
}
 

import org.hornetq.core.remoting.impl.netty.TransportConstants; //导入依赖的package包/类
/**
 * Constructor.
 * @param embedded true if you want to start embedded HornetQ server,
 * or false if you want to connect to remote HornetQ server.
 */
public HornetQMixIn(boolean embedded) {
    _startEmbedded = embedded;
    _transportParams = new HashMap<String,Object>();
    String host = System.getProperty(HOST_PROP_NAME);
    if (host == null) {
        host = TransportConstants.DEFAULT_HOST;
    }
    _transportParams.put(TransportConstants.HOST_PROP_NAME, host);
    String port = System.getProperty(PORT_PROP_NAME);
    if (port == null) {
        port = Integer.toString(TransportConstants.DEFAULT_PORT);
    }
    _transportParams.put(TransportConstants.PORT_PROP_NAME, port);
    String upgrade = System.getProperty(HTTP_UPGRADE_ENABLED_PROP_NAME);
    if (upgrade != null) {
        _transportParams.put(HORNETQ_HTTP_UPGRADE_ENABLED_PROP_NAME, upgrade);
        String endpoint = System.getProperty(HTTP_UPGRADE_ENDPOINT_PROP_NAME);
        _transportParams.put(HORNETQ_HTTP_UPGRADE_ENDPOINT_PROP_NAME,
                endpoint != null ? endpoint : HORNETQ_DEFAULT_HTTP_UPGRADE_ENDPOINT);
    }
}
 

import org.hornetq.core.remoting.impl.netty.TransportConstants; //导入依赖的package包/类
public static TransportConfiguration fromAuthority(@NonNull String authority) {
    String[] hostAndPort = authority.split(":");
    checkArgument(hostAndPort.length == 2);
    checkArgument(!hostAndPort[0].isEmpty());
    checkArgument(!hostAndPort[1].isEmpty());
    return new TransportConfiguration(NettyConnectorFactory.class.getName(), ImmutableMap.of(
            TransportConstants.HOST_PROP_NAME, hostAndPort[0],
            TransportConstants.PORT_PROP_NAME, hostAndPort[1]));
}
 

import org.hornetq.core.remoting.impl.netty.TransportConstants; //导入依赖的package包/类
private <T extends HornetQConnectionFactory> T createNativeConnectionFactory(
		Class<T> factoryClass) throws Exception {
	Map<String, Object> params = new HashMap<String, Object>();
	params.put(TransportConstants.HOST_PROP_NAME, this.properties.getHost());
	params.put(TransportConstants.PORT_PROP_NAME, this.properties.getPort());
	TransportConfiguration transportConfiguration = new TransportConfiguration(
			NettyConnectorFactory.class.getName(), params);
	Constructor<T> constructor = factoryClass.getDeclaredConstructor(
			HornetQProperties.class, boolean.class, TransportConfiguration[].class);
	return BeanUtils.instantiateClass(constructor, this.properties, false,
			new TransportConfiguration[] { transportConfiguration });
}
 

import org.hornetq.core.remoting.impl.netty.TransportConstants; //导入依赖的package包/类
private <T extends HornetQConnectionFactory> T createNativeConnectionFactory(
		Class<T> factoryClass) throws Exception {
	Map<String, Object> params = new HashMap<String, Object>();
	params.put(TransportConstants.HOST_PROP_NAME, this.properties.getHost());
	params.put(TransportConstants.PORT_PROP_NAME, this.properties.getPort());
	TransportConfiguration transportConfiguration = new TransportConfiguration(
			NettyConnectorFactory.class.getName(), params);
	Constructor<T> constructor = factoryClass.getConstructor(boolean.class,
			TransportConfiguration[].class);
	return constructor.newInstance(false,
			new TransportConfiguration[] { transportConfiguration });
}
 

import org.hornetq.core.remoting.impl.netty.TransportConstants; //导入依赖的package包/类
private Configuration coreConfiguration(AddressAndPort host) {
    Configuration configuration = new ConfigurationImpl();
    configuration.setPersistenceEnabled(false);
    configuration.setJournalDirectory("build/data/journal");
    configuration.setSecurityEnabled(false);
    Map<String, Object> params = new HashMap<String, Object>();
    params.put(TransportConstants.HOST_PROP_NAME, host.address());
    params.put(TransportConstants.PORT_PROP_NAME, host.port());
    configuration.getAcceptorConfigurations().add(new TransportConfiguration(NettyAcceptorFactory.class.getName(), params));
    TransportConfiguration connectorConfig = new TransportConfiguration(NettyConnectorFactory.class.getName(), params);
    configuration.getConnectorConfigurations().put("connector", connectorConfig);
    return configuration;
}
 

import org.hornetq.core.remoting.impl.netty.TransportConstants; //导入依赖的package包/类
public void init() throws InitException {



        Map<String, Object> connectionParams = new HashMap<>();

        connectionParams.put(TransportConstants.HOST_PROP_NAME, getHost());
        connectionParams.put(TransportConstants.PORT_PROP_NAME, getPort());

        TransportConfiguration transportConfiguration = new TransportConfiguration(NettyConnectorFactory.class.getName(),
                connectionParams);

        factory = new HornetQJMSConnectionFactory(false,transportConfiguration);

        try {
            connection = factory.createConnection(getUser(),getPassword());

            session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

            dest = (getDestType() == DestType.QUEUE) ? session.createQueue(getDestination()) : session.createTopic(getDestination());

            producer = session.createProducer(dest);
            connection.start();
        } catch (JMSException e) {
            throw new InitException(e.fillInStackTrace());
        }

    }
 

import org.hornetq.core.remoting.impl.netty.TransportConstants; //导入依赖的package包/类
/**
 * Set host address to connect.
 * @param host address
 * @return this instance
 */
public HornetQMixIn setHost(String host) {
    _transportParams.put(TransportConstants.HOST_PROP_NAME, host);
    return this;
}
 

import org.hornetq.core.remoting.impl.netty.TransportConstants; //导入依赖的package包/类
/**
 * Set port number to connect.
 * @param port port number
 * @return this instance
 */
public HornetQMixIn setPort(int port) {
    _transportParams.put(TransportConstants.PORT_PROP_NAME, port);
    return this;
}