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:58:34 UTC

svn commit: r1541546 - in /incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service: StreamsPublisherRegistrationServiceIntegrationTest.java StreamsSubscriberRegistrationServiceIntegrationTest.java

Author: dsullivan
Date: Wed Nov 13 14:58:34 2013
New Revision: 1541546

URL: http://svn.apache.org/r1541546
Log:
adding cassandra configuration 4 integration tests

Modified:
    incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsPublisherRegistrationServiceIntegrationTest.java
    incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsSubscriberRegistrationServiceIntegrationTest.java

Modified: incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsPublisherRegistrationServiceIntegrationTest.java
URL: http://svn.apache.org/viewvc/incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsPublisherRegistrationServiceIntegrationTest.java?rev=1541546&r1=1541545&r2=1541546&view=diff
==============================================================================
--- incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsPublisherRegistrationServiceIntegrationTest.java (original)
+++ incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsPublisherRegistrationServiceIntegrationTest.java Wed Nov 13 14:58:34 2013
@@ -24,7 +24,7 @@ public class StreamsPublisherRegistratio
     public void setup(){
 
         CassandraConfiguration configuration = new CassandraConfiguration();
-        configuration.setCassandraPort("127.0.0.1");
+        configuration.setCassandraPort(9042);
         configuration.setPublisherColumnFamilyName("publishertestD");
         configuration.setKeyspaceName("keyspacetest");
 

Modified: incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsSubscriberRegistrationServiceIntegrationTest.java
URL: http://svn.apache.org/viewvc/incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsSubscriberRegistrationServiceIntegrationTest.java?rev=1541546&r1=1541545&r2=1541546&view=diff
==============================================================================
--- incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsSubscriberRegistrationServiceIntegrationTest.java (original)
+++ incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsSubscriberRegistrationServiceIntegrationTest.java Wed Nov 13 14:58:34 2013
@@ -20,7 +20,7 @@ public class StreamsSubscriberRegistrati
     public void setup(){
 
         CassandraConfiguration configuration = new CassandraConfiguration();
-        configuration.setCassandraPort("127.0.0.1");
+        configuration.setCassandraPort(9042);
         configuration.setSubscriptionColumnFamilyName("subscriptionstestB");
         configuration.setKeyspaceName("keyspacetest");