import org.hornetq.api.jms.HornetQJMSClient; //导入依赖的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.api.jms.HornetQJMSClient; //导入依赖的package包/类
protected ConnectionFactory createRemoteConnectionFactory(final Options<CreateContextOption> options) {
    //TODO: possibly cache the remote cf's?
    Map<String, Object> transportOpts = new HashMap<>();
    transportOpts.put("host", options.getString(CreateContextOption.HOST));
    transportOpts.put("port", options.getInt(CreateContextOption.PORT));
    if (REMOTE_TYPE_WILDFLY.equals(options.getString(CreateContextOption.REMOTE_TYPE))) {
        transportOpts.put("http-upgrade-enabled", true);
    }

    TransportConfiguration config =
            new TransportConfiguration("org.hornetq.core.remoting.impl.netty.NettyConnectorFactory",
                                       transportOpts);
    HornetQConnectionFactory hornetQcf = HornetQJMSClient
            .createConnectionFactoryWithoutHA(options.has(CreateContextOption.XA) ?
                                                      JMSFactoryType.XA_CF :
                                                      JMSFactoryType.CF,
                                              config);

    hornetQcf.setReconnectAttempts(options.getInt(CreateContextOption.RECONNECT_ATTEMPTS));
    hornetQcf.setRetryInterval(options.getLong(CreateContextOption.RECONNECT_RETRY_INTERVAL));
    hornetQcf.setRetryIntervalMultiplier(options.getDouble(CreateContextOption.RECONNECT_RETRY_INTERVAL_MULTIPLIER));
    hornetQcf.setMaxRetryInterval(options.getLong(CreateContextOption.RECONNECT_MAX_RETRY_INTERVAL));

    // We have to cast for HornetQ 2.3 - the factory object that is returned is both a HornetQConnectionFactory
    // and a javax.jms.ConnectionFactory, but HornetQConnectionFactory doesn't implement j.j.ConnectionFactory.
    // With HornetQ 2.4, this cast is redundant.
    return (ConnectionFactory)hornetQcf;
}