svn commit: r1491405 - /archiva/sandbox/trunk/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra/DefaultCassandraEntityManagerFactory.java

[olamy]

Author: olamy
Date: Mon Jun 10 10:44:25 2013
New Revision: 1491405

URL: http://svn.apache.org/r1491405
Log:
cassandra host from system property

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

Modified: 
archiva/sandbox/trunk/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra/DefaultCassandraEntityManagerFactory.java
URL: 
http://svn.apache.org/viewvc/archiva/sandbox/trunk/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra/DefaultCassandraEntityManagerFactory.java?rev=1491405&r1=1491404&r2=1491405&view=diff
==============================================================================
--- 
archiva/sandbox/trunk/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra/DefaultCassandraEntityManagerFactory.java
 (original)
+++ 
archiva/sandbox/trunk/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra/DefaultCassandraEntityManagerFactory.java
 Mon Jun 10 10:44:25 2013
@@ -37,6 +37,7 @@ import javax.inject.Inject;
 
 /**
  * FIXME make all configuration not hardcoded :-)
+ *
  * @author Olivier Lamy
  */
 @Service("archivaEntityManagerFactory#cassandra")
@@ -60,6 +61,7 @@ public class DefaultCassandraEntityManag
     public void initialize()
         throws ConnectionException
     {
+        String cassandraHost = System.getProperty( "cassandraHost", 
"localhost" );
         String cassandraPort = System.getProperty( "cassandraPort" );
         keyspaceContext = new AstyanaxContext.Builder().forCluster( 
CLUSTER_NAME ).forKeyspace(
             KEYSPACE_NAME ).withAstyanaxConfiguration(
@@ -67,8 +69,8 @@ public class DefaultCassandraEntityManag
                 ConnectionPoolType.TOKEN_AWARE ) 
).withConnectionPoolConfiguration(
             new ConnectionPoolConfigurationImpl( CLUSTER_NAME + "_" + 
KEYSPACE_NAME ).setSocketTimeout(
                 30000 ).setMaxTimeoutWhenExhausted( 2000 ).setMaxConnsPerHost( 
20 ).setInitConnsPerHost( 10 ).setSeeds(
-                "localhost:"+ cassandraPort ) ).withConnectionPoolMonitor( new 
CountingConnectionPoolMonitor() ).buildKeyspace(
-            ThriftFamilyFactory.getInstance() );
+                cassandraHost + ":" + cassandraPort ) 
).withConnectionPoolMonitor(
+            new CountingConnectionPoolMonitor() ).buildKeyspace( 
ThriftFamilyFactory.getInstance() );
 
         keyspaceContext.start();