import org.apache.activemq.jms.pool.PooledConnectionFactory; //导入依赖的package包/类
public static PooledConnectionFactory createPooledConnectionFactory() {
    ConnectionFactory cf = createConnectionFactory(null, null);
    PooledConnectionFactory pooled = new PooledConnectionFactory();
    pooled.setConnectionFactory(cf);
    pooled.setMaxConnections(8);
    return pooled;
}
 

import org.apache.activemq.jms.pool.PooledConnectionFactory; //导入依赖的package包/类
@Bean
ConnectionFactory jmsConnectionFactory() {
  if (this.config.isPooled()) {
    PooledConnectionFactory pool = new PooledConnectionFactory();
    pool.setConnectionFactory(new ActiveMQConnectionFactory(this.config.getBrokerURL()));
    return pool;
  } else {
    return new ActiveMQConnectionFactory(this.config.getBrokerURL());
  }
}
 

import org.apache.activemq.jms.pool.PooledConnectionFactory; //导入依赖的package包/类
private void init() {
    ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory();
    activeMQConnectionFactory.setBrokerURL(brokerConfiguration.getBrokerURL());
    activeMQConnectionFactory.setUserName(brokerConfiguration.getUsername());
    activeMQConnectionFactory.setPassword(brokerConfiguration.getPassword());

    pooledConnectionFactory = new PooledConnectionFactory();
    pooledConnectionFactory.setConnectionFactory(activeMQConnectionFactory);
    pooledConnectionFactory.setMaxConnections(brokerConfiguration.getMaxConnections());
    pooledConnectionFactory.setMaximumActiveSessionPerConnection(brokerConfiguration.getMaximumActiveSessionPerConnection());

    pooledConnectionFactory.initConnectionsPool();
}
 

import org.apache.activemq.jms.pool.PooledConnectionFactory; //导入依赖的package包/类
@Bean
ConnectionFactory jmsConnectionFactory() {
    PooledConnectionFactory pool = new PooledConnectionFactory();
    pool.setConnectionFactory(new ActiveMQConnectionFactory("vm://localhost"));
    return pool;
}