svn commit: r1541518 - /incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsFiltersServiceTest.java

[ds...@apache.org]

Author: dsullivan
Date: Wed Nov 13 13:48:06 2013
New Revision: 1541518

URL: http://svn.apache.org/r1541518
Log:
new test for StreamsFiltersServiceTest

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

Modified: incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsFiltersServiceTest.java
URL: http://svn.apache.org/viewvc/incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsFiltersServiceTest.java?rev=1541518&r1=1541517&r2=1541518&view=diff
==============================================================================
--- incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsFiltersServiceTest.java (original)
+++ incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsFiltersServiceTest.java Wed Nov 13 13:48:06 2013
@@ -1,6 +1,8 @@
 package org.apache.streams.components.service;
 
+import org.apache.streams.components.activitysubscriber.ActivityStreamsSubscriber;
 import org.apache.streams.components.activitysubscriber.ActivityStreamsSubscriberWarehouse;
+import org.apache.streams.components.activitysubscriber.impl.ActivityStreamsSubscriberDelegate;
 import org.apache.streams.components.service.impl.StreamsFiltersServiceImpl;
 import org.apache.streams.persistence.model.ActivityStreamsSubscription;
 import org.junit.Before;
@@ -32,10 +34,12 @@ public class StreamsFiltersServiceTest {
         String subscriberId = "subscriberId";
         String tagsJson = "{\"add\":[\"this\"], \"remove\":[\"that\"]}";
         ActivityStreamsSubscription subscription = createMock(ActivityStreamsSubscription.class);
+        ActivityStreamsSubscriber subscriber = new ActivityStreamsSubscriberDelegate();
 
         repositoryService.updateFilters(eq(subscriberId), isA(Set.class), isA(Set.class));
         expectLastCall();
         expect(repositoryService.getSubscriptionByInRoute(subscriberId)).andReturn(subscription);
+        expect(subscriberWarehouse.getSubscriber(subscriberId)).andReturn(subscriber);
         subscriberWarehouse.updateSubscriber(subscription);
         expectLastCall();
         replay(repositoryService,subscriberWarehouse);
@@ -43,6 +47,7 @@ public class StreamsFiltersServiceTest {
         String returned = filtersService.updateFilters(subscriberId,tagsJson);
 
         assertThat(returned,is(equalTo("Filters Updated Successfully!")));
+        assertThat(subscriber.getLastUpdated().getTime(),is(equalTo(0L)));
     }
 
     @Test