Examples of PooledConnectionFactory

org.apache.activemq.jms.pool.PooledConnectionFactory
.apache.org/activemq.html">Camel and Spring's JmsTemplate and MessagListenerContainer. Connections, sessions and producers are returned to a pool after use so that they can be reused later without having to undergo the cost of creating them again. b>NOTE: while this implementation does allow the creation of a collection of active consumers, it does not 'pool' consumers. Pooling makes sense for connections, sessions and producers, which are expensive to create and can remain idle a minimal cost. Consumers, on the other hand, are usually just created at startup and left active, handling incoming messages as they come. When a consumer is complete, it is best to close it rather than return it to a pool for later reuse: this is because, even if a consumer is idle, ActiveMQ will keep delivering messages to the consumer's prefetch buffer, where they'll get held until the consumer is active again. If you are creating a collection of consumers (for example, for multi-threaded message consumption), you might want to consider using a lower prefetch value for each consumer (e.g. 10 or 20), to ensure that all messages don't end up going to just one of the consumers. See this FAQ entry for more detail: http://activemq.apache.org/i-do-not-receive-messages-in-my-second-consumer.html Optionally, one may configure the pool to examine and possibly evict objects as they sit idle in the pool. This is performed by an "idle object eviction" thread, which runs asynchronously. Caution should be used when configuring this optional feature. Eviction runs contend with client threads for access to objects in the pool, so if they run too frequently performance issues may result. The idle object eviction thread may be configured using the {@link org.apache.activemq.jms.pool.PooledConnectionFactory#setTimeBetweenExpirationCheckMillis} method. Bydefault the value is -1 which means no eviction thread will be run. Set to a non-negative value to configure the idle eviction thread to run.
org.apache.activemq.pool.PooledConnectionFactory
emq.org/Spring+Support">JmsTemplate. NOTE this implementation is only intended for use when sending messages. It does not deal with pooling of consumers; for that look at a library like Jencks such as in this example @version $Revision: 1.1 $
org.infinispan.loaders.jdbc.connectionfactory.PooledConnectionFactory
change.com/projects/c3p0/index.html#configuration">here. The connection pool can be configured in various ways, as described here. The simplest way is by having an c3p0.properties file in the classpath. If no such file is found, default, hardcoded values will be used. @author Mircea.Markus@jboss.com
org.infinispan.persistence.jdbc.connectionfactory.PooledConnectionFactory
change.com/projects/c3p0/index.html#configuration">here. The connection pool can be configured in various ways, as described here. The simplest way is by having an c3p0.properties file in the classpath. If no such file is found, default, hardcoded values will be used. @author Mircea.Markus@jboss.com @author Tristan Tarrant
org.jencks.amqpool.PooledConnectionFactory

Examples of org.infinispan.persistence.jdbc.connectionfactory.PooledConnectionFactory

      TableManipulation tableManipulation = new TableManipulation(storeBuilder.table().create());
      // database type must now be determined
      tableManipulation.databaseType = null;
      tableManipulation.setCacheName("GuessDatabaseType");


      PooledConnectionFactory factory = new PooledConnectionFactory();
      ConnectionFactoryConfiguration config = UnitTestDatabaseManager
            .configureUniqueConnectionFactory(storeBuilder).create();
      factory.start(config, Thread.currentThread().getContextClassLoader());
      tableManipulation.start(factory);
      tableManipulation.getUpdateRowSql();
      UnitTestDatabaseManager.verifyConnectionLeaks(factory);
      tableManipulation.stop();
      factory.stop();
   }

View Full Code Here

Examples of org.jencks.amqpool.PooledConnectionFactory

    }


    protected CamelContext createCamelContext() throws Exception {
        CamelContext camelContext = super.createCamelContext();


        PooledConnectionFactory pool = new PooledConnectionFactory(new ActiveMQConnectionFactory("vm://localhost?broker.persistent=false"));
        pool.setMaxConnections(10);


        camelContext.addComponent("jms", jmsComponentClientAcknowledge(pool));


        return camelContext;
    }

View Full Code Here

0 1 2 3 4 5

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.