You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by ds...@apache.org on 2013/11/13 15:52:49 UTC
svn commit: r1541537 - in
/incubator/streams/branches/webservice/streams-persistence/src/main:
java/org/apache/streams/persistence/repository/cassandra/CassandraKeyspace.java
resources/cassandra.properties
Author: dsullivan
Date: Wed Nov 13 14:52:49 2013
New Revision: 1541537
URL: http://svn.apache.org/r1541537
Log:
adding cassandra configuration
Modified:
incubator/streams/branches/webservice/streams-persistence/src/main/java/org/apache/streams/persistence/repository/cassandra/CassandraKeyspace.java
incubator/streams/branches/webservice/streams-persistence/src/main/resources/cassandra.properties
Modified: incubator/streams/branches/webservice/streams-persistence/src/main/java/org/apache/streams/persistence/repository/cassandra/CassandraKeyspace.java
URL: http://svn.apache.org/viewvc/incubator/streams/branches/webservice/streams-persistence/src/main/java/org/apache/streams/persistence/repository/cassandra/CassandraKeyspace.java?rev=1541537&r1=1541536&r2=1541537&view=diff
==============================================================================
--- incubator/streams/branches/webservice/streams-persistence/src/main/java/org/apache/streams/persistence/repository/cassandra/CassandraKeyspace.java (original)
+++ incubator/streams/branches/webservice/streams-persistence/src/main/java/org/apache/streams/persistence/repository/cassandra/CassandraKeyspace.java Wed Nov 13 14:52:49 2013
@@ -21,7 +21,7 @@ public class CassandraKeyspace {
public CassandraKeyspace(CassandraConfiguration configuration){
this.configuration = configuration;
- cluster = Cluster.builder().addContactPoint(configuration.getCassandraPort()).build();
+ cluster = Cluster.builder().addContactPoint(configuration.getCassandraHost()).withPort(configuration.getCassandraPort()).build();
session = cluster.connect();
//TODO: cassandra 2 will have support for CREATE KEYSPACE IF NOT EXISTS
Modified: incubator/streams/branches/webservice/streams-persistence/src/main/resources/cassandra.properties
URL: http://svn.apache.org/viewvc/incubator/streams/branches/webservice/streams-persistence/src/main/resources/cassandra.properties?rev=1541537&r1=1541536&r2=1541537&view=diff
==============================================================================
--- incubator/streams/branches/webservice/streams-persistence/src/main/resources/cassandra.properties (original)
+++ incubator/streams/branches/webservice/streams-persistence/src/main/resources/cassandra.properties Wed Nov 13 14:52:49 2013
@@ -2,4 +2,5 @@ cassandra.keyspaceName=keyspaceB
cassandra.activitystreamsColumnFamilyName=activitystreamsE
cassandra.subscriptionColumnFamilyName=subscriptionsE
cassandra.publisherColumnFamilyName=publishersE
-cassandra.cassandraPort=127.0.0.1
\ No newline at end of file
+cassandra.cassandraPort=9042
+cassandra.cassandraHost=127.0.0.1
\ No newline at end of file