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:56:59 UTC
svn commit: r1541542 -
/incubator/streams/branches/webservice/streams-persistence/src/test/java/org/apache/streams/persistence/repository/cassandra/
Author: dsullivan
Date: Wed Nov 13 14:56:58 2013
New Revision: 1541542
URL: http://svn.apache.org/r1541542
Log:
adding cassandra configuration 3 tests
Modified:
incubator/streams/branches/webservice/streams-persistence/src/test/java/org/apache/streams/persistence/repository/cassandra/CassandraActiivtyStreamsRepositoryTest.java
incubator/streams/branches/webservice/streams-persistence/src/test/java/org/apache/streams/persistence/repository/cassandra/CassandraPublisherRepositoryTest.java
incubator/streams/branches/webservice/streams-persistence/src/test/java/org/apache/streams/persistence/repository/cassandra/CassandraSubscriptionRepositoryTest.java
Modified: incubator/streams/branches/webservice/streams-persistence/src/test/java/org/apache/streams/persistence/repository/cassandra/CassandraActiivtyStreamsRepositoryTest.java
URL: http://svn.apache.org/viewvc/incubator/streams/branches/webservice/streams-persistence/src/test/java/org/apache/streams/persistence/repository/cassandra/CassandraActiivtyStreamsRepositoryTest.java?rev=1541542&r1=1541541&r2=1541542&view=diff
==============================================================================
--- incubator/streams/branches/webservice/streams-persistence/src/test/java/org/apache/streams/persistence/repository/cassandra/CassandraActiivtyStreamsRepositoryTest.java (original)
+++ incubator/streams/branches/webservice/streams-persistence/src/test/java/org/apache/streams/persistence/repository/cassandra/CassandraActiivtyStreamsRepositoryTest.java Wed Nov 13 14:56:58 2013
@@ -5,10 +5,9 @@ import org.apache.streams.persistence.mo
import org.apache.streams.persistence.model.ActivityStreamsObject;
import org.apache.streams.persistence.model.cassandra.CassandraActivityStreamsEntry;
import org.apache.streams.persistence.model.cassandra.CassandraActivityStreamsObject;
-import org.junit.Before;
-import org.junit.Ignore;
-import org.junit.Test;
+import org.junit.*;
+import java.io.IOException;
import java.util.Arrays;
import java.util.Date;
import java.util.HashSet;
@@ -18,16 +17,21 @@ public class CassandraActiivtyStreamsRep
private CassandraActivityStreamsRepository repository;
@Before
- public void setup(){
+ public void setup() throws Exception {
CassandraConfiguration configuration = new CassandraConfiguration();
- configuration.setCassandraPort("127.0.0.1");
- configuration.setActivitystreamsColumnFamilyName("acitivites_Test7");
+ configuration.setCassandraHost("127.0.0.1");
+ configuration.setCassandraPort(9042);
+ configuration.setActivitystreamsColumnFamilyName("acitivites_Test8");
configuration.setKeyspaceName("keyspacetest");
CassandraKeyspace keyspace = new CassandraKeyspace(configuration);
repository = new CassandraActivityStreamsRepository(keyspace,configuration);
}
+ @After
+ public void takedown(){
+ }
+
@Ignore
@Test
public void testNullTags(){
Modified: incubator/streams/branches/webservice/streams-persistence/src/test/java/org/apache/streams/persistence/repository/cassandra/CassandraPublisherRepositoryTest.java
URL: http://svn.apache.org/viewvc/incubator/streams/branches/webservice/streams-persistence/src/test/java/org/apache/streams/persistence/repository/cassandra/CassandraPublisherRepositoryTest.java?rev=1541542&r1=1541541&r2=1541542&view=diff
==============================================================================
--- incubator/streams/branches/webservice/streams-persistence/src/test/java/org/apache/streams/persistence/repository/cassandra/CassandraPublisherRepositoryTest.java (original)
+++ incubator/streams/branches/webservice/streams-persistence/src/test/java/org/apache/streams/persistence/repository/cassandra/CassandraPublisherRepositoryTest.java Wed Nov 13 14:56:58 2013
@@ -15,7 +15,8 @@ public class CassandraPublisherRepositor
@Before
public void setup(){
CassandraConfiguration configuration = new CassandraConfiguration();
- configuration.setCassandraPort("127.0.0.1");
+ configuration.setCassandraHost("127.0.0.1");
+ configuration.setCassandraPort(9042);
configuration.setPublisherColumnFamilyName("publishersA");
configuration.setKeyspaceName("keyspacetest");
CassandraKeyspace keyspace = new CassandraKeyspace(configuration);
Modified: incubator/streams/branches/webservice/streams-persistence/src/test/java/org/apache/streams/persistence/repository/cassandra/CassandraSubscriptionRepositoryTest.java
URL: http://svn.apache.org/viewvc/incubator/streams/branches/webservice/streams-persistence/src/test/java/org/apache/streams/persistence/repository/cassandra/CassandraSubscriptionRepositoryTest.java?rev=1541542&r1=1541541&r2=1541542&view=diff
==============================================================================
--- incubator/streams/branches/webservice/streams-persistence/src/test/java/org/apache/streams/persistence/repository/cassandra/CassandraSubscriptionRepositoryTest.java (original)
+++ incubator/streams/branches/webservice/streams-persistence/src/test/java/org/apache/streams/persistence/repository/cassandra/CassandraSubscriptionRepositoryTest.java Wed Nov 13 14:56:58 2013
@@ -20,7 +20,8 @@ public class CassandraSubscriptionReposi
@Before
public void setup() {
CassandraConfiguration configuration = new CassandraConfiguration();
- configuration.setCassandraPort("127.0.0.1");
+ configuration.setCassandraHost("127.0.0.1");
+ configuration.setCassandraPort(9042);
configuration.setSubscriptionColumnFamilyName("subscriptionstestA");
configuration.setKeyspaceName("keyspacetest");
CassandraKeyspace keyspace = new CassandraKeyspace(configuration);