You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2012/11/26 06:45:45 UTC
svn commit: r1413484 -
/camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/
Author: ningjiang
Date: Mon Nov 26 05:45:40 2012
New Revision: 1413484
URL: http://svn.apache.org/viewvc?rev=1413484&view=rev
Log:
Refact the camel-twitter unit tests
Added:
camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/CamelTwitterConsumerTestSupport.java
- copied, changed from r1412434, camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/SearchDirectTest.java
Modified:
camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/DailyTrendDirectTest.java
camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/DailyTrendPollingTest.java
camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/DirectMessageDirectTest.java
camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/DirectMessagePollingTest.java
camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/HomeTimeLineDirectTest.java
camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/HomeTimeLinePollingTest.java
camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/PublicTimeLineDirectTest.java
camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/PublicTimeLinePollingTest.java
camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/SearchDirectTest.java
camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/SearchPollingTest.java
camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/UserTimeLineDirectTest.java
camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/UserTimeLinePollingTest.java
camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/WeeklyTrendDirectTest.java
camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/WeeklyTrendPollingTest.java
Copied: camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/CamelTwitterConsumerTestSupport.java (from r1412434, camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/SearchDirectTest.java)
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/CamelTwitterConsumerTestSupport.java?p2=camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/CamelTwitterConsumerTestSupport.java&p1=camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/SearchDirectTest.java&r1=1412434&r2=1413484&rev=1413484&view=diff
==============================================================================
--- camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/SearchDirectTest.java (original)
+++ camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/CamelTwitterConsumerTestSupport.java Mon Nov 26 05:45:40 2012
@@ -23,33 +23,31 @@ import org.apache.camel.builder.RouteBui
import org.apache.camel.component.mock.MockEndpoint;
import org.junit.Test;
import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- * consumes tweets
- */
-public class SearchDirectTest extends CamelTwitterTestSupport {
- private static final transient Logger LOG = LoggerFactory.getLogger(SearchDirectTest.class);
+public abstract class CamelTwitterConsumerTestSupport extends CamelTwitterTestSupport {
+ protected abstract String getUri();
+
+ protected abstract Logger getLogger();
+
@Test
- public void testSearchTimeline() throws Exception {
+ public void testDailyTrend() throws Exception {
MockEndpoint mock = getMockEndpoint("mock:result");
mock.expectedMinimumMessageCount(1);
mock.assertIsSatisfied();
List<Exchange> tweets = mock.getExchanges();
- if (LOG.isInfoEnabled()) {
- for (Exchange e : tweets) {
- LOG.info("Tweet: " + e.getIn().getBody(String.class));
- }
+ for (Exchange e : tweets) {
+ getLogger().info("Tweet: " + e.getIn().getBody(String.class));
}
+
}
-
+
protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
- from("twitter://search?type=direct&keywords=java&" + getUriTokens())
+ from(getUri() + getUriTokens())
.transform(body().convertToString()).to("mock:result");
}
};
}
+
}
Modified: camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/DailyTrendDirectTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/DailyTrendDirectTest.java?rev=1413484&r1=1413483&r2=1413484&view=diff
==============================================================================
--- camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/DailyTrendDirectTest.java (original)
+++ camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/DailyTrendDirectTest.java Mon Nov 26 05:45:40 2012
@@ -16,43 +16,24 @@
*/
package org.apache.camel.component.twitter;
-import java.util.List;
-
-import org.apache.camel.Exchange;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* consumes tweets
*/
-public class DailyTrendDirectTest extends CamelTwitterTestSupport {
- private static final transient Logger LOG = LoggerFactory.getLogger(DailyTrendDirectTest.class);
-
+public class DailyTrendDirectTest extends CamelTwitterConsumerTestSupport {
- @Test
- public void testDailyTrend() throws Exception {
- MockEndpoint mock = getMockEndpoint("mock:result");
- mock.expectedMinimumMessageCount(1);
- mock.assertIsSatisfied();
- List<Exchange> tweets = mock.getExchanges();
- if (LOG.isInfoEnabled()) {
- for (Exchange e : tweets) {
- LOG.info("Tweet: " + e.getIn().getBody(String.class));
- }
- }
+ @Override
+ protected String getUri() {
+ // DO NOT test with 'date='. Twitter only allows dates up to
+ // a certain limit, so we can't have that as a long-term test
+ return "twitter://trends/daily?type=direct&";
}
- protected RouteBuilder createRouteBuilder() {
- return new RouteBuilder() {
- public void configure() {
- // DO NOT test with 'date='. Twitter only allows dates up to
- // a certain limit, so we can't have that as a long-term test.
- from("twitter://trends/daily?type=direct&" + getUriTokens())
- .transform(body().convertToString()).to("mock:result");
- }
- };
+ @Override
+ protected Logger getLogger() {
+ return LoggerFactory.getLogger(DailyTrendDirectTest.class);
}
+
}
Modified: camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/DailyTrendPollingTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/DailyTrendPollingTest.java?rev=1413484&r1=1413483&r2=1413484&view=diff
==============================================================================
--- camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/DailyTrendPollingTest.java (original)
+++ camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/DailyTrendPollingTest.java Mon Nov 26 05:45:40 2012
@@ -16,42 +16,24 @@
*/
package org.apache.camel.component.twitter;
-import java.util.List;
-
-import org.apache.camel.Exchange;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-
+
/**
* consumes tweets
*/
-public class DailyTrendPollingTest extends CamelTwitterTestSupport {
- private static final transient Logger LOG = LoggerFactory.getLogger(DailyTrendPollingTest.class);
-
- @Test
- public void testDailyTrendPoll() throws Exception {
- MockEndpoint mock = getMockEndpoint("mock:result");
- mock.expectedMinimumMessageCount(1);
- mock.assertIsSatisfied();
- List<Exchange> tweets = mock.getExchanges();
- if (LOG.isInfoEnabled()) {
- for (Exchange e : tweets) {
- LOG.info("Tweet: " + e.getIn().getBody(String.class));
- }
- }
+public class DailyTrendPollingTest extends CamelTwitterConsumerTestSupport {
+
+ @Override
+ protected String getUri() {
+ // DO NOT test with 'date='. Twitter only allows dates up to
+ // a certain limit, so we can't have that as a long-term test
+ return "twitter://trends/daily?type=polling&";
}
- protected RouteBuilder createRouteBuilder() {
- return new RouteBuilder() {
- public void configure() {
- // DO NOT test with 'date='. Twitter only allows dates up to
- // a certain limit, so we can't have that as a long-term test.
- from("twitter://trends/daily?type=polling&" + getUriTokens())
- .transform(body().convertToString()).to("mock:result");
- }
- };
+ @Override
+ protected Logger getLogger() {
+ return LoggerFactory.getLogger(DailyTrendPollingTest.class);
}
+
}
Modified: camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/DirectMessageDirectTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/DirectMessageDirectTest.java?rev=1413484&r1=1413483&r2=1413484&view=diff
==============================================================================
--- camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/DirectMessageDirectTest.java (original)
+++ camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/DirectMessageDirectTest.java Mon Nov 26 05:45:40 2012
@@ -16,41 +16,20 @@
*/
package org.apache.camel.component.twitter;
-import java.util.List;
-
-import org.apache.camel.Exchange;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* consumes tweets
*/
-public class DirectMessageDirectTest extends CamelTwitterTestSupport {
- private static final transient Logger LOG = LoggerFactory.getLogger(DirectMessageDirectTest.class);
-
-
- @Test
- public void testReadDirectMessage() throws Exception {
- MockEndpoint mock = getMockEndpoint("mock:result");
- mock.expectedMinimumMessageCount(1);
- mock.assertIsSatisfied();
- List<Exchange> tweets = mock.getExchanges();
- if (LOG.isInfoEnabled()) {
- for (Exchange e : tweets) {
- LOG.info("Tweet: " + e.getIn().getBody(String.class));
- }
- }
+public class DirectMessageDirectTest extends CamelTwitterConsumerTestSupport {
+ @Override
+ protected String getUri() {
+ return "twitter://directmessage?type=direct&";
}
- protected RouteBuilder createRouteBuilder() {
- return new RouteBuilder() {
- public void configure() {
- from("twitter://directmessage?type=direct&" + getUriTokens())
- .transform(body().convertToString()).to("mock:result");
- }
- };
+ @Override
+ protected Logger getLogger() {
+ return LoggerFactory.getLogger(DirectMessageDirectTest.class);
}
}
Modified: camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/DirectMessagePollingTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/DirectMessagePollingTest.java?rev=1413484&r1=1413483&r2=1413484&view=diff
==============================================================================
--- camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/DirectMessagePollingTest.java (original)
+++ camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/DirectMessagePollingTest.java Mon Nov 26 05:45:40 2012
@@ -16,40 +16,20 @@
*/
package org.apache.camel.component.twitter;
-import java.util.List;
-
-import org.apache.camel.Exchange;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* consumes tweets
*/
-public class DirectMessagePollingTest extends CamelTwitterTestSupport {
- private static final transient Logger LOG = LoggerFactory.getLogger(DirectMessagePollingTest.class);
-
- @Test
- public void testReadDirectMessage() throws Exception {
- MockEndpoint mock = getMockEndpoint("mock:result");
- mock.expectedMinimumMessageCount(1);
- mock.assertIsSatisfied();
- List<Exchange> tweets = mock.getExchanges();
- if (LOG.isInfoEnabled()) {
- for (Exchange e : tweets) {
- LOG.info("Tweet: " + e.getIn().getBody(String.class));
- }
- }
+public class DirectMessagePollingTest extends CamelTwitterConsumerTestSupport {
+ @Override
+ protected String getUri() {
+ return "twitter://directmessage?type=polling&";
}
- protected RouteBuilder createRouteBuilder() {
- return new RouteBuilder() {
- public void configure() {
- from("twitter://directmessage?type=polling&" + getUriTokens())
- .transform(body().convertToString()).to("mock:result");
- }
- };
+ @Override
+ protected Logger getLogger() {
+ return LoggerFactory.getLogger(DirectMessagePollingTest.class);
}
}
Modified: camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/HomeTimeLineDirectTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/HomeTimeLineDirectTest.java?rev=1413484&r1=1413483&r2=1413484&view=diff
==============================================================================
--- camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/HomeTimeLineDirectTest.java (original)
+++ camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/HomeTimeLineDirectTest.java Mon Nov 26 05:45:40 2012
@@ -16,41 +16,21 @@
*/
package org.apache.camel.component.twitter;
-import java.util.List;
-
-import org.apache.camel.Exchange;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* consumes tweets
*/
-public class HomeTimeLineDirectTest extends CamelTwitterTestSupport {
- private static final transient Logger LOG = LoggerFactory.getLogger(HomeTimeLineDirectTest.class);
-
+public class HomeTimeLineDirectTest extends CamelTwitterConsumerTestSupport {
- @Test
- public void testReadHomeTimeLine() throws Exception {
- MockEndpoint mock = getMockEndpoint("mock:result");
- mock.expectedMinimumMessageCount(1);
- mock.assertIsSatisfied();
- List<Exchange> tweets = mock.getExchanges();
- if (LOG.isInfoEnabled()) {
- for (Exchange e : tweets) {
- LOG.info("Tweet: " + e.getIn().getBody(String.class));
- }
- }
+ @Override
+ protected String getUri() {
+ return "twitter://timeline/home?type=direct&";
}
- protected RouteBuilder createRouteBuilder() {
- return new RouteBuilder() {
- public void configure() {
- from("twitter://timeline/home?type=direct&" + getUriTokens())
- .transform(body().convertToString()).to("mock:result");
- }
- };
+ @Override
+ protected Logger getLogger() {
+ return LoggerFactory.getLogger(HomeTimeLineDirectTest.class);
}
}
Modified: camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/HomeTimeLinePollingTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/HomeTimeLinePollingTest.java?rev=1413484&r1=1413483&r2=1413484&view=diff
==============================================================================
--- camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/HomeTimeLinePollingTest.java (original)
+++ camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/HomeTimeLinePollingTest.java Mon Nov 26 05:45:40 2012
@@ -16,40 +16,20 @@
*/
package org.apache.camel.component.twitter;
-import java.util.List;
-
-import org.apache.camel.Exchange;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* consumes tweets
*/
-public class HomeTimeLinePollingTest extends CamelTwitterTestSupport {
- private static final transient Logger LOG = LoggerFactory.getLogger(HomeTimeLinePollingTest.class);
-
- @Test
- public void testReadHomeTimeLine() throws Exception {
- MockEndpoint mock = getMockEndpoint("mock:result");
- mock.expectedMinimumMessageCount(1);
- mock.assertIsSatisfied();
- List<Exchange> tweets = mock.getExchanges();
- if (LOG.isInfoEnabled()) {
- for (Exchange e : tweets) {
- LOG.info("Tweet: " + e.getIn().getBody(String.class));
- }
- }
+public class HomeTimeLinePollingTest extends CamelTwitterConsumerTestSupport {
+ @Override
+ protected String getUri() {
+ return "twitter://timeline/home?type=polling&";
}
- protected RouteBuilder createRouteBuilder() {
- return new RouteBuilder() {
- public void configure() {
- from("twitter://timeline/home?type=polling&" + getUriTokens())
- .transform(body().convertToString()).to("mock:result");
- }
- };
+ @Override
+ protected Logger getLogger() {
+ return LoggerFactory.getLogger(HomeTimeLinePollingTest.class);
}
}
Modified: camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/PublicTimeLineDirectTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/PublicTimeLineDirectTest.java?rev=1413484&r1=1413483&r2=1413484&view=diff
==============================================================================
--- camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/PublicTimeLineDirectTest.java (original)
+++ camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/PublicTimeLineDirectTest.java Mon Nov 26 05:45:40 2012
@@ -16,40 +16,21 @@
*/
package org.apache.camel.component.twitter;
-import java.util.List;
-
-import org.apache.camel.Exchange;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* consumes tweets
*/
-public class PublicTimeLineDirectTest extends CamelTwitterTestSupport {
- private static final transient Logger LOG = LoggerFactory.getLogger(PublicTimeLineDirectTest.class);
+public class PublicTimeLineDirectTest extends CamelTwitterConsumerTestSupport {
- @Test
- public void testReadPublicTimeline() throws Exception {
- MockEndpoint mock = getMockEndpoint("mock:result");
- mock.expectedMinimumMessageCount(1);
- mock.assertIsSatisfied();
- List<Exchange> tweets = mock.getExchanges();
- if (LOG.isInfoEnabled()) {
- for (Exchange e : tweets) {
- LOG.info("Tweet: " + e.getIn().getBody(String.class));
- }
- }
+ @Override
+ protected String getUri() {
+ return "twitter://timeline/public?type=direct&";
}
- protected RouteBuilder createRouteBuilder() {
- return new RouteBuilder() {
- public void configure() {
- from("twitter://timeline/public?type=direct&" + getUriTokens())
- .transform(body().convertToString()).to("mock:result");
- }
- };
+ @Override
+ protected Logger getLogger() {
+ return LoggerFactory.getLogger(PublicTimeLineDirectTest.class);
}
}
Modified: camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/PublicTimeLinePollingTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/PublicTimeLinePollingTest.java?rev=1413484&r1=1413483&r2=1413484&view=diff
==============================================================================
--- camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/PublicTimeLinePollingTest.java (original)
+++ camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/PublicTimeLinePollingTest.java Mon Nov 26 05:45:40 2012
@@ -16,40 +16,21 @@
*/
package org.apache.camel.component.twitter;
-import java.util.List;
-
-import org.apache.camel.Exchange;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* consumes tweets
*/
-public class PublicTimeLinePollingTest extends CamelTwitterTestSupport {
- private static final transient Logger LOG = LoggerFactory.getLogger(PublicTimeLinePollingTest.class);
+public class PublicTimeLinePollingTest extends CamelTwitterConsumerTestSupport {
- @Test
- public void testReadPublicTimeline() throws Exception {
- MockEndpoint mock = getMockEndpoint("mock:result");
- mock.expectedMinimumMessageCount(1);
- mock.assertIsSatisfied();
- List<Exchange> tweets = mock.getExchanges();
- if (LOG.isInfoEnabled()) {
- for (Exchange e : tweets) {
- LOG.info("Tweet: " + e.getIn().getBody(String.class));
- }
- }
+ @Override
+ protected String getUri() {
+ return "twitter://timeline/public?type=polling&";
}
- protected RouteBuilder createRouteBuilder() {
- return new RouteBuilder() {
- public void configure() {
- from("twitter://timeline/public?type=polling&" + getUriTokens())
- .transform(body().convertToString()).to("mock:result");
- }
- };
+ @Override
+ protected Logger getLogger() {
+ return LoggerFactory.getLogger(PublicTimeLinePollingTest.class);
}
}
Modified: camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/SearchDirectTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/SearchDirectTest.java?rev=1413484&r1=1413483&r2=1413484&view=diff
==============================================================================
--- camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/SearchDirectTest.java (original)
+++ camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/SearchDirectTest.java Mon Nov 26 05:45:40 2012
@@ -16,40 +16,21 @@
*/
package org.apache.camel.component.twitter;
-import java.util.List;
-
-import org.apache.camel.Exchange;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* consumes tweets
*/
-public class SearchDirectTest extends CamelTwitterTestSupport {
- private static final transient Logger LOG = LoggerFactory.getLogger(SearchDirectTest.class);
-
- @Test
- public void testSearchTimeline() throws Exception {
- MockEndpoint mock = getMockEndpoint("mock:result");
- mock.expectedMinimumMessageCount(1);
- mock.assertIsSatisfied();
- List<Exchange> tweets = mock.getExchanges();
- if (LOG.isInfoEnabled()) {
- for (Exchange e : tweets) {
- LOG.info("Tweet: " + e.getIn().getBody(String.class));
- }
- }
+public class SearchDirectTest extends CamelTwitterConsumerTestSupport {
+
+ @Override
+ protected String getUri() {
+ return "twitter://search?type=direct&keywords=java&";
}
- protected RouteBuilder createRouteBuilder() {
- return new RouteBuilder() {
- public void configure() {
- from("twitter://search?type=direct&keywords=java&" + getUriTokens())
- .transform(body().convertToString()).to("mock:result");
- }
- };
+ @Override
+ protected Logger getLogger() {
+ return LoggerFactory.getLogger(SearchDirectTest.class);
}
}
Modified: camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/SearchPollingTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/SearchPollingTest.java?rev=1413484&r1=1413483&r2=1413484&view=diff
==============================================================================
--- camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/SearchPollingTest.java (original)
+++ camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/SearchPollingTest.java Mon Nov 26 05:45:40 2012
@@ -16,40 +16,20 @@
*/
package org.apache.camel.component.twitter;
-import java.util.List;
-
-import org.apache.camel.Exchange;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* consumes tweets
*/
-public class SearchPollingTest extends CamelTwitterTestSupport {
- private static final transient Logger LOG = LoggerFactory.getLogger(SearchPollingTest.class);
-
- @Test
- public void testSearchTimeline() throws Exception {
- MockEndpoint mock = getMockEndpoint("mock:result");
- mock.expectedMinimumMessageCount(1);
- mock.assertIsSatisfied();
- List<Exchange> tweets = mock.getExchanges();
- if (LOG.isInfoEnabled()) {
- for (Exchange e : tweets) {
- LOG.info("Tweet: " + e.getIn().getBody(String.class));
- }
- }
+public class SearchPollingTest extends CamelTwitterConsumerTestSupport {
+ @Override
+ protected String getUri() {
+ return "twitter://search?type=polling&keywords=java&";
}
- protected RouteBuilder createRouteBuilder() {
- return new RouteBuilder() {
- public void configure() {
- from("twitter://search?type=polling&keywords=java&" + getUriTokens())
- .transform(body().convertToString()).to("mock:result");
- }
- };
+ @Override
+ protected Logger getLogger() {
+ return LoggerFactory.getLogger(SearchPollingTest.class);
}
}
Modified: camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/UserTimeLineDirectTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/UserTimeLineDirectTest.java?rev=1413484&r1=1413483&r2=1413484&view=diff
==============================================================================
--- camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/UserTimeLineDirectTest.java (original)
+++ camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/UserTimeLineDirectTest.java Mon Nov 26 05:45:40 2012
@@ -16,40 +16,21 @@
*/
package org.apache.camel.component.twitter;
-import java.util.List;
-
-import org.apache.camel.Exchange;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* consumes tweets
*/
-public class UserTimeLineDirectTest extends CamelTwitterTestSupport {
- private static final transient Logger LOG = LoggerFactory.getLogger(UserTimeLineDirectTest.class);
-
- @Test
- public void testReadUserTimeline() throws Exception {
- MockEndpoint mock = getMockEndpoint("mock:result");
- mock.expectedMinimumMessageCount(1);
- mock.assertIsSatisfied();
- List<Exchange> tweets = mock.getExchanges();
- if (LOG.isInfoEnabled()) {
- for (Exchange e : tweets) {
- LOG.info("Tweet: " + e.getIn().getBody(String.class));
- }
- }
+public class UserTimeLineDirectTest extends CamelTwitterConsumerTestSupport {
+
+ @Override
+ protected String getUri() {
+ return "twitter://timeline/user?type=direct&user=brettemeyer&";
}
- protected RouteBuilder createRouteBuilder() {
- return new RouteBuilder() {
- public void configure() {
- from("twitter://timeline/user?type=direct&user=brettemeyer&" + getUriTokens())
- .transform(body().convertToString()).to("mock:result");
- }
- };
+ @Override
+ protected Logger getLogger() {
+ return LoggerFactory.getLogger(UserTimeLineDirectTest.class);
}
}
Modified: camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/UserTimeLinePollingTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/UserTimeLinePollingTest.java?rev=1413484&r1=1413483&r2=1413484&view=diff
==============================================================================
--- camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/UserTimeLinePollingTest.java (original)
+++ camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/UserTimeLinePollingTest.java Mon Nov 26 05:45:40 2012
@@ -16,40 +16,21 @@
*/
package org.apache.camel.component.twitter;
-import java.util.List;
-
-import org.apache.camel.Exchange;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* consumes tweets
*/
-public class UserTimeLinePollingTest extends CamelTwitterTestSupport {
- private static final transient Logger LOG = LoggerFactory.getLogger(UserTimeLinePollingTest.class);
+public class UserTimeLinePollingTest extends CamelTwitterConsumerTestSupport {
- @Test
- public void testReadUserTimeline() throws Exception {
- MockEndpoint mock = getMockEndpoint("mock:result");
- mock.expectedMinimumMessageCount(1);
- mock.assertIsSatisfied();
- List<Exchange> tweets = mock.getExchanges();
- if (LOG.isInfoEnabled()) {
- for (Exchange e : tweets) {
- LOG.info("Tweet: " + e.getIn().getBody(String.class));
- }
- }
+ @Override
+ protected String getUri() {
+ return "twitter://timeline/user?type=polling&user=brettemeyer&";
}
- protected RouteBuilder createRouteBuilder() {
- return new RouteBuilder() {
- public void configure() {
- from("twitter://timeline/user?type=polling&user=brettemeyer&" + getUriTokens())
- .transform(body().convertToString()).to("mock:result");
- }
- };
+ @Override
+ protected Logger getLogger() {
+ return LoggerFactory.getLogger(UserTimeLinePollingTest.class);
}
}
Modified: camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/WeeklyTrendDirectTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/WeeklyTrendDirectTest.java?rev=1413484&r1=1413483&r2=1413484&view=diff
==============================================================================
--- camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/WeeklyTrendDirectTest.java (original)
+++ camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/WeeklyTrendDirectTest.java Mon Nov 26 05:45:40 2012
@@ -16,43 +16,21 @@
*/
package org.apache.camel.component.twitter;
-import java.util.List;
-
-import org.apache.camel.Exchange;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* consumes tweets
*/
-public class WeeklyTrendDirectTest extends CamelTwitterTestSupport {
- private static final transient Logger LOG = LoggerFactory.getLogger(WeeklyTrendDirectTest.class);
-
-
- @Test
- public void testDailyTrend() throws Exception {
- MockEndpoint mock = getMockEndpoint("mock:result");
- mock.expectedMinimumMessageCount(1);
- mock.assertIsSatisfied();
- List<Exchange> tweets = mock.getExchanges();
- if (LOG.isInfoEnabled()) {
- for (Exchange e : tweets) {
- LOG.info("Tweet: " + e.getIn().getBody(String.class));
- }
- }
+public class WeeklyTrendDirectTest extends CamelTwitterConsumerTestSupport {
+
+ @Override
+ protected String getUri() {
+ return "twitter://trends/weekly?type=direct&";
}
- protected RouteBuilder createRouteBuilder() {
- return new RouteBuilder() {
- public void configure() {
- // DO NOT test with 'date='. Twitter only allows dates up to
- // a certain limit, so we can't have that as a long-term test.
- from("twitter://trends/weekly?type=direct&" + getUriTokens())
- .transform(body().convertToString()).to("mock:result");
- }
- };
+ @Override
+ protected Logger getLogger() {
+ return LoggerFactory.getLogger(WeeklyTrendDirectTest.class);
}
}
Modified: camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/WeeklyTrendPollingTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/WeeklyTrendPollingTest.java?rev=1413484&r1=1413483&r2=1413484&view=diff
==============================================================================
--- camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/WeeklyTrendPollingTest.java (original)
+++ camel/trunk/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/WeeklyTrendPollingTest.java Mon Nov 26 05:45:40 2012
@@ -16,42 +16,21 @@
*/
package org.apache.camel.component.twitter;
-import java.util.List;
-
-import org.apache.camel.Exchange;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* consumes tweets
*/
-public class WeeklyTrendPollingTest extends CamelTwitterTestSupport {
- private static final transient Logger LOG = LoggerFactory.getLogger(WeeklyTrendPollingTest.class);
-
- @Test
- public void testDailyTrendPoll() throws Exception {
- MockEndpoint mock = getMockEndpoint("mock:result");
- mock.expectedMinimumMessageCount(1);
- mock.assertIsSatisfied();
- List<Exchange> tweets = mock.getExchanges();
- if (LOG.isInfoEnabled()) {
- for (Exchange e : tweets) {
- LOG.info("Tweet: " + e.getIn().getBody(String.class));
- }
- }
+public class WeeklyTrendPollingTest extends CamelTwitterConsumerTestSupport {
+
+ @Override
+ protected String getUri() {
+ return "twitter://trends/weekly?type=polling&";
}
- protected RouteBuilder createRouteBuilder() {
- return new RouteBuilder() {
- public void configure() {
- // DO NOT test with 'date='. Twitter only allows dates up to
- // a certain limit, so we can't have that as a long-term test.
- from("twitter://trends/weekly?type=polling&" + getUriTokens())
- .transform(body().convertToString()).to("mock:result");
- }
- };
+ @Override
+ protected Logger getLogger() {
+ return LoggerFactory.getLogger(WeeklyTrendPollingTest.class);
}
}