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/07 19:29:11 UTC
svn commit: r1539747 -
/incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsActivityReceivingServiceTest.java
Author: dsullivan
Date: Thu Nov 7 18:29:11 2013
New Revision: 1539747
URL: http://svn.apache.org/r1539747
Log:
adding StreamsActivityReceivingServiceTest
Added:
incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsActivityReceivingServiceTest.java
Added: incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsActivityReceivingServiceTest.java
URL: http://svn.apache.org/viewvc/incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsActivityReceivingServiceTest.java?rev=1539747&view=auto
==============================================================================
--- incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsActivityReceivingServiceTest.java (added)
+++ incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsActivityReceivingServiceTest.java Thu Nov 7 18:29:11 2013
@@ -0,0 +1,34 @@
+package org.apache.streams.components.service;
+
+import org.apache.streams.components.activitysubscriber.ActivityStreamsSubscriberWarehouse;
+import org.apache.streams.components.service.impl.StreamsActivityReceivingServiceImpl;
+import org.junit.Before;
+import org.junit.Test;
+
+import static org.easymock.EasyMock.*;
+import static org.hamcrest.CoreMatchers.is;
+import static org.hamcrest.core.IsEqual.equalTo;
+import static org.junit.Assert.assertThat;
+
+public class StreamsActivityReceivingServiceTest {
+ private StreamsActivityReceivingService acitivityReceivingService;
+ private ActivityStreamsSubscriberWarehouse activityStreamsSubscriberWarehouse;
+
+ @Before
+ public void setup(){
+ activityStreamsSubscriberWarehouse = createMock(ActivityStreamsSubscriberWarehouse.class);
+
+ acitivityReceivingService = new StreamsActivityReceivingServiceImpl(activityStreamsSubscriberWarehouse);
+ }
+
+ @Test
+ public void getActivityTest(){
+ String inRoute = "my inroute";
+ String stream = "hey look, it's a stream";
+
+ expect(activityStreamsSubscriberWarehouse.getStream(inRoute)).andReturn(stream);
+ replay(activityStreamsSubscriberWarehouse);
+
+ assertThat(stream, is(equalTo(acitivityReceivingService.getActivity(inRoute))));
+ }
+}