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:23:13 UTC

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

Author: dsullivan
Date: Thu Nov  7 18:23:12 2013
New Revision: 1539745

URL: http://svn.apache.org/r1539745
Log:
adding StreamsActivityPublishingServiceTest

Added:
    incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsActivityPublishingServiceTest.java

Added: incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsActivityPublishingServiceTest.java
URL: http://svn.apache.org/viewvc/incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsActivityPublishingServiceTest.java?rev=1539745&view=auto
==============================================================================
--- incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsActivityPublishingServiceTest.java (added)
+++ incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsActivityPublishingServiceTest.java Thu Nov  7 18:23:12 2013
@@ -0,0 +1,41 @@
+package org.apache.streams.components.service;
+
+import org.apache.streams.components.service.impl.StreamsActivityPublishingServiceImpl;
+import org.apache.streams.persistence.model.ActivityStreamsPublisher;
+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 StreamsActivityPublishingServiceTest {
+
+    private StreamsActivityPublishingService activityPublishingService;
+    private StreamsActivityRepositoryService activityService;
+    private StreamsPublisherRepositoryService publisherService;
+
+    @Before
+    public void setup(){
+        activityService = createMock(StreamsActivityRepositoryService.class);
+        publisherService = createMock(StreamsPublisherRepositoryService.class);
+
+        activityPublishingService = new StreamsActivityPublishingServiceImpl(activityService, publisherService);
+    }
+
+    @Test
+    public void publishTest() throws Exception {
+        String inRoute = "myInRoute";
+        String activityJson = "myActionJson";
+        ActivityStreamsPublisher publisher = createMock(ActivityStreamsPublisher.class);
+
+        expect(publisherService.getActivityStreamsPublisherByInRoute(inRoute)).andReturn(publisher);
+        activityService.receiveActivity(publisher, activityJson);
+        expectLastCall();
+
+        replay(publisherService,activityService);
+
+        assertThat(activityJson, is(equalTo(activityPublishingService.publish(inRoute, activityJson))));
+    }
+}