Author: davsclaus Date: Sat Jul 14 07:03:19 2012 New Revision: 1361478 URL: http://svn.apache.org/viewvc?rev=1361478&view=rev Log: Reverted rev 1359674 so the example is as before
Modified: camel/trunk/examples/camel-example-twitter-websocket/src/main/java/org/apache/camel/example/websocket/TwitterWebSocketRoute.java Modified: camel/trunk/examples/camel-example-twitter-websocket/src/main/java/org/apache/camel/example/websocket/TwitterWebSocketRoute.java URL: http://svn.apache.org/viewvc/camel/trunk/examples/camel-example-twitter-websocket/src/main/java/org/apache/camel/example/websocket/TwitterWebSocketRoute.java?rev=1361478&r1=1361477&r2=1361478&view=diff ============================================================================== --- camel/trunk/examples/camel-example-twitter-websocket/src/main/java/org/apache/camel/example/websocket/TwitterWebSocketRoute.java (original) +++ camel/trunk/examples/camel-example-twitter-websocket/src/main/java/org/apache/camel/example/websocket/TwitterWebSocketRoute.java Sat Jul 14 07:03:19 2012 @@ -18,6 +18,7 @@ package org.apache.camel.example.websock import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.websocket.WebsocketComponent; +import org.apache.camel.component.twitter.TwitterComponent; /** * A Camel route that updates from twitter all tweets using having the search term. @@ -97,6 +98,13 @@ public class TwitterWebSocketRoute exten // we can serve static resources from the classpath: or file: system wc.setStaticResources("classpath:."); + // setup Twitter component + TwitterComponent tc = getContext().getComponent("twitter", TwitterComponent.class); + tc.setAccessToken(accessToken); + tc.setAccessTokenSecret(accessTokenSecret); + tc.setConsumerKey(consumerKey); + tc.setConsumerSecret(consumerSecret); + // poll twitter search for new tweets fromF("twitter://search?type=polling&delay=%s&keywords=%s", delay, searchTerm) // and push tweets to all web socket subscribers on camel-tweet