From c2adf6899a3dcef73f55858c42d763c4427979f6 Mon Sep 17 00:00:00 2001 From: Olivier Lamy Date: Thu, 20 Jun 2013 12:10:41 +0000 Subject: [PATCH] use Slf4j as connection pool monitor git-svn-id: https://svn.apache.org/repos/asf/archiva/trunk@1494950 13f79535-47bb-0310-9956-ffa450edef68 --- .../cassandra/DefaultCassandraEntityManagerFactory.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/archiva-modules/plugins/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra/DefaultCassandraEntityManagerFactory.java b/archiva-modules/plugins/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra/DefaultCassandraEntityManagerFactory.java index a0ec6c579..a03ae394c 100644 --- a/archiva-modules/plugins/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra/DefaultCassandraEntityManagerFactory.java +++ b/archiva-modules/plugins/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra/DefaultCassandraEntityManagerFactory.java @@ -28,6 +28,7 @@ import com.netflix.astyanax.connectionpool.exceptions.NotFoundException; 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 DefaultCassandraEntityManagerFactory 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 DefaultCassandraEntityManagerFactory keyspace.createKeyspace( options ); } - - try { Properties properties = keyspace.getKeyspaceProperties(); -- 2.39.5