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/09/12 21:54:21 UTC
svn commit: r1522706 -
/incubator/streams/branches/cassandra/streams-cassandra/src/test/java/org/apache/streams/cassandra/repository/impl/CassandraActivityStreamsRepositoryTest.java
Author: dsullivan
Date: Thu Sep 12 19:54:21 2013
New Revision: 1522706
URL: http://svn.apache.org/r1522706
Log:
adding correct type for test
Modified:
incubator/streams/branches/cassandra/streams-cassandra/src/test/java/org/apache/streams/cassandra/repository/impl/CassandraActivityStreamsRepositoryTest.java
Modified: incubator/streams/branches/cassandra/streams-cassandra/src/test/java/org/apache/streams/cassandra/repository/impl/CassandraActivityStreamsRepositoryTest.java
URL: http://svn.apache.org/viewvc/incubator/streams/branches/cassandra/streams-cassandra/src/test/java/org/apache/streams/cassandra/repository/impl/CassandraActivityStreamsRepositoryTest.java?rev=1522706&r1=1522705&r2=1522706&view=diff
==============================================================================
--- incubator/streams/branches/cassandra/streams-cassandra/src/test/java/org/apache/streams/cassandra/repository/impl/CassandraActivityStreamsRepositoryTest.java (original)
+++ incubator/streams/branches/cassandra/streams-cassandra/src/test/java/org/apache/streams/cassandra/repository/impl/CassandraActivityStreamsRepositoryTest.java Thu Sep 12 19:54:21 2013
@@ -1,9 +1,11 @@
package org.apache.streams.cassandra.repository.impl;
+import com.datastax.driver.core.ResultSet;
import org.apache.rave.model.ActivityStreamsEntry;
import org.apache.rave.model.ActivityStreamsObject;
import org.apache.rave.portal.model.impl.ActivityStreamsEntryImpl;
import org.apache.rave.portal.model.impl.ActivityStreamsObjectImpl;
+import org.apache.streams.cassandra.model.CassandraActivityStreamsEntry;
import org.junit.Before;
import org.junit.Ignore;
import org.junit.Test;
@@ -29,6 +31,7 @@ public class CassandraActivityStreamsRep
ActivityStreamsObject actor = new ActivityStreamsObjectImpl();
ActivityStreamsObject target = new ActivityStreamsObjectImpl();
ActivityStreamsObject object = new ActivityStreamsObjectImpl();
+ ActivityStreamsObject provider = new ActivityStreamsObjectImpl();
actor.setId("actorid1");
actor.setUrl("actorurl1");
@@ -38,11 +41,15 @@ public class CassandraActivityStreamsRep
target.setUrl("targeturl1");
target.setDisplayName("r501");
+ provider.setUrl("providerurl");
+
object.setId("objectid1");
object.setDisplayName("objectname1");
entry.setId("one");
entry.setVerb("verb1");
+ entry.setTags("r501");
+ entry.setProvider(provider);
Date d = new Date();
entry.setPublished(d);
entry.setActor(actor);
@@ -55,10 +62,10 @@ public class CassandraActivityStreamsRep
@Ignore
@Test
public void getActivity() {
- String cql = "'r501'";
+ String cql = "r501";
List<String> f = Arrays.asList(cql);
Date d = new Date(0);
- List<ActivityStreamsEntry> results = repository.getActivitiesForFilters(f,d);
+ List<CassandraActivityStreamsEntry> results = repository.getActivitiesForFilters(f,d);
}
@Ignore