java - 没有 Spring 的ActiveMQ PooledConnectionFactory

Question

你能帮我解决一个简单的问题吗？我需要在没有 spring 的情况下使用 PooledConnectionFactory，JMSTemplate。 ActiveMQ 说这个类是池连接、生产者、 session ，让我困惑的是，我不知道如何从实例中获取它们。我在等待一些 takeConnection()，然后是 realeaseConnection() 和 takeProducer() 并实现 producer()。pooledConnectionFactory.start(); 之后我应该做什么？通常，我会做 Connection c = pooledConnectionFactory.createConnection...希望，我解释了我的问题。如果生产者和 session 是直接从 Connection 创建的，那么它们是如何合并的。

    connectionFactory = new ActiveMQConnectionFactory(
            userId, 
            passWord, 
            brokerURL);
    log.info("Queueing service init: BrokerURL: " + brokerURL + "  UserId: " + userId + "   Paasword: " + passWord);

    pooledConnectionFactory = new PooledConnectionFactory(connectionFactory);

    pooledConnectionFactory.setIdleTimeout(5000);
    pooledConnectionFactory.setMaxConnections(10);
    pooledConnectionFactory.setMaximumActive(5000);
    pooledConnectionFactory.start();

Answer 1

好吧，池化连接工厂在使用时与任何其他 jms 连接工厂一样。

只需调用:

pooledConnectionFactory.createConnection();//和你一样

连接工厂不会真正创建连接，但会为您提供一个池化连接。然后，connection.close();将再次将其释放到池中。但所有这些都在引擎盖下，只要像你习惯的那样使用它就可以了。这同样适用于 session 和生产者，但不是消费者。