svn commit: r1494950 - /archiva/trunk/archiva-modules/plugins/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra/DefaultCassandraEntityManagerFactory.java

[olamy]

Author: olamy
Date: Thu Jun 20 12:10:41 2013
New Revision: 1494950

URL: http://svn.apache.org/r1494950
Log:
use Slf4j as connection pool monitor

Modified:
    
archiva/trunk/archiva-modules/plugins/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra/DefaultCassandraEntityManagerFactory.java

Modified: 
archiva/trunk/archiva-modules/plugins/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra/DefaultCassandraEntityManagerFactory.java
URL: 
http://svn.apache.org/viewvc/archiva/trunk/archiva-modules/plugins/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra/DefaultCassandraEntityManagerFactory.java?rev=1494950&r1=1494949&r2=1494950&view=diff
==============================================================================
--- 
archiva/trunk/archiva-modules/plugins/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra/DefaultCassandraEntityManagerFactory.java
 (original)
+++ 
archiva/trunk/archiva-modules/plugins/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra/DefaultCassandraEntityManagerFactory.java
 Thu Jun 20 12:10:41 2013
@@ -28,6 +28,7 @@ import com.netflix.astyanax.connectionpo
 import 
com.netflix.astyanax.connectionpool.impl.ConnectionPoolConfigurationImpl;
 import com.netflix.astyanax.connectionpool.impl.ConnectionPoolType;
 import com.netflix.astyanax.connectionpool.impl.CountingConnectionPoolMonitor;
+import com.netflix.astyanax.connectionpool.impl.Slf4jConnectionPoolMonitorImpl;
 import com.netflix.astyanax.ddl.KeyspaceDefinition;
 import com.netflix.astyanax.entitystore.DefaultEntityManager;
 import com.netflix.astyanax.entitystore.EntityManager;
@@ -98,7 +99,7 @@ public class DefaultCassandraEntityManag
             new ConnectionPoolConfigurationImpl( CLUSTER_NAME + "_" + 
KEYSPACE_NAME ).setSocketTimeout(
                 30000 ).setMaxTimeoutWhenExhausted( 2000 ).setMaxConnsPerHost( 
20 ).setInitConnsPerHost( 10 ).setSeeds(
                 cassandraHost + ":" + cassandraPort ) 
).withConnectionPoolMonitor(
-            new CountingConnectionPoolMonitor() ).buildKeyspace( 
ThriftFamilyFactory.getInstance() );
+            new Slf4jConnectionPoolMonitorImpl() ).buildKeyspace( 
ThriftFamilyFactory.getInstance() );
 
         keyspaceContext.start();
 
@@ -130,8 +131,6 @@ public class DefaultCassandraEntityManag
             keyspace.createKeyspace( options );
         }
 
-
-
         try
         {
             Properties properties = keyspace.getKeyspaceProperties();