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 21:13:26 UTC
svn commit: r1539790 -
/incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsPublisherRepositoryServiceTest.java
Author: dsullivan
Date: Thu Nov 7 20:13:26 2013
New Revision: 1539790
URL: http://svn.apache.org/r1539790
Log:
adding StreamsPublisherRepositoryServiceTest
Added:
incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsPublisherRepositoryServiceTest.java
Added: incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsPublisherRepositoryServiceTest.java
URL: http://svn.apache.org/viewvc/incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsPublisherRepositoryServiceTest.java?rev=1539790&view=auto
==============================================================================
--- incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsPublisherRepositoryServiceTest.java (added)
+++ incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsPublisherRepositoryServiceTest.java Thu Nov 7 20:13:26 2013
@@ -0,0 +1,69 @@
+package org.apache.streams.components.service;
+
+import org.apache.streams.components.service.impl.CassandraPublisherService;
+import org.apache.streams.persistence.model.ActivityStreamsPublisher;
+import org.apache.streams.persistence.model.cassandra.CassandraPublisher;
+import org.apache.streams.persistence.repository.PublisherRepository;
+import org.junit.Before;
+import org.junit.Test;
+
+import static org.easymock.EasyMock.*;
+import static org.hamcrest.CoreMatchers.instanceOf;
+import static org.hamcrest.CoreMatchers.is;
+import static org.hamcrest.CoreMatchers.sameInstance;
+import static org.hamcrest.core.IsEqual.equalTo;
+import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertThat;
+
+public class StreamsPublisherRepositoryServiceTest {
+
+ private StreamsPublisherRepositoryService publisherRepositoryService;
+ private PublisherRepository repository;
+
+ @Before
+ public void setup(){
+ repository = createMock(PublisherRepository.class);
+ publisherRepositoryService = new CassandraPublisherService(repository);
+ }
+
+ @Test
+ public void savePublisherTest(){
+ ActivityStreamsPublisher publisher = new CassandraPublisher();
+
+ repository.save(publisher);
+ expectLastCall();
+
+ replay(repository);
+
+ publisherRepositoryService.savePublisher(publisher);
+
+ assertNotNull(publisher.getId());
+ verify(repository);
+ }
+
+ @Test
+ public void getActivityStreamsPublisherBySrcTest(){
+ String src = "dis be ma src";
+ ActivityStreamsPublisher publisher = createMock(ActivityStreamsPublisher.class);
+
+ expect(repository.getPublisherBySrc(src)).andReturn(publisher);
+ replay(repository);
+
+ ActivityStreamsPublisher returned = publisherRepositoryService.getActivityStreamsPublisherBySrc(src);
+
+ assertThat(publisher,sameInstance(returned));
+ }
+
+ @Test
+ public void getActivityStreamsPublisherByInRoute(){
+ String inRoute = "dis be ma inRoute";
+ ActivityStreamsPublisher publisher = createMock(ActivityStreamsPublisher.class);
+
+ expect(repository.getPublisherByInRoute(inRoute)).andReturn(publisher);
+ replay(repository);
+
+ ActivityStreamsPublisher returned = publisherRepositoryService.getActivityStreamsPublisherByInRoute(inRoute);
+
+ assertThat(publisher,sameInstance(returned));
+ }
+}