Apache/archiva
1
0
Fork 0
mirror of https://github.com/apache/archiva.git synced 2025-02-22 01:44:47 +00:00
Code Issues Packages Projects Releases Wiki Activity

use Slf4j as connection pool monitor

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/archiva/trunk@1494950 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Olivier Lamy 2013-06-20 12:10:41 +00:00
parent 27c2cdaab4
commit c2adf6899a
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
archiva-modules/plugins/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra/DefaultCassandraEntityManagerFactory.java
View File

@ -28,6 +28,7 @@
import com.netflix.astyanax.connectionpool.impl.ConnectionPoolConfigurationImpl; import com.netflix.astyanax.connectionpool.impl.ConnectionPoolConfigurationImpl;
import com.netflix.astyanax.connectionpool.impl.ConnectionPoolType; import com.netflix.astyanax.connectionpool.impl.ConnectionPoolType;
import com.netflix.astyanax.connectionpool.impl.CountingConnectionPoolMonitor; import com.netflix.astyanax.connectionpool.impl.CountingConnectionPoolMonitor;
import com.netflix.astyanax.connectionpool.impl.Slf4jConnectionPoolMonitorImpl;
import com.netflix.astyanax.ddl.KeyspaceDefinition; import com.netflix.astyanax.ddl.KeyspaceDefinition;
import com.netflix.astyanax.entitystore.DefaultEntityManager; import com.netflix.astyanax.entitystore.DefaultEntityManager;
import com.netflix.astyanax.entitystore.EntityManager; import com.netflix.astyanax.entitystore.EntityManager;
@ -98,7 +99,7 @@ public void initialize()
new ConnectionPoolConfigurationImpl( CLUSTER_NAME + "_" + KEYSPACE_NAME ).setSocketTimeout( new ConnectionPoolConfigurationImpl( CLUSTER_NAME + "_" + KEYSPACE_NAME ).setSocketTimeout(
30000 ).setMaxTimeoutWhenExhausted( 2000 ).setMaxConnsPerHost( 20 ).setInitConnsPerHost( 10 ).setSeeds( 30000 ).setMaxTimeoutWhenExhausted( 2000 ).setMaxConnsPerHost( 20 ).setInitConnsPerHost( 10 ).setSeeds(
cassandraHost + ":" + cassandraPort ) ).withConnectionPoolMonitor( cassandraHost + ":" + cassandraPort ) ).withConnectionPoolMonitor(
new CountingConnectionPoolMonitor() ).buildKeyspace( ThriftFamilyFactory.getInstance() ); new Slf4jConnectionPoolMonitorImpl() ).buildKeyspace( ThriftFamilyFactory.getInstance() );
keyspaceContext.start(); keyspaceContext.start();
@ -130,8 +131,6 @@ public void initialize()
keyspace.createKeyspace( options ); keyspace.createKeyspace( options );
} }
try try
{ {
Properties properties = keyspace.getKeyspaceProperties(); Properties properties = keyspace.getKeyspaceProperties();