camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject svn commit: r1301951 - in /camel/trunk/examples: ./ camel-example-twitter-websocket/ camel-example-twitter-websocket/src/ camel-example-twitter-websocket/src/main/ camel-example-twitter-websocket/src/main/java/ camel-example-twitter-websocket/src/main/...
Date Sat, 17 Mar 2012 15:30:52 GMT
Author: davsclaus
Date: Sat Mar 17 15:30:52 2012
New Revision: 1301951

URL: http://svn.apache.org/viewvc?rev=1301951&view=rev
Log:
Added twitter and websocket example

Added:
    camel/trunk/examples/camel-example-twitter-websocket/
    camel/trunk/examples/camel-example-twitter-websocket/pom.xml   (with props)
    camel/trunk/examples/camel-example-twitter-websocket/src/
    camel/trunk/examples/camel-example-twitter-websocket/src/main/
    camel/trunk/examples/camel-example-twitter-websocket/src/main/java/
    camel/trunk/examples/camel-example-twitter-websocket/src/main/java/org/
    camel/trunk/examples/camel-example-twitter-websocket/src/main/java/org/apache/
    camel/trunk/examples/camel-example-twitter-websocket/src/main/java/org/apache/camel/
    camel/trunk/examples/camel-example-twitter-websocket/src/main/java/org/apache/camel/example/
    camel/trunk/examples/camel-example-twitter-websocket/src/main/java/org/apache/camel/example/websocket/
    camel/trunk/examples/camel-example-twitter-websocket/src/main/java/org/apache/camel/example/websocket/CamelTwitterWebSocketMain.java
  (with props)
    camel/trunk/examples/camel-example-twitter-websocket/src/main/java/org/apache/camel/example/websocket/TwitterWebSocketRoute.java
  (with props)
    camel/trunk/examples/camel-example-twitter-websocket/src/main/resources/
    camel/trunk/examples/camel-example-twitter-websocket/src/main/resources/index.html   (with
props)
    camel/trunk/examples/camel-example-twitter-websocket/src/main/resources/log4j.properties
  (with props)
Modified:
    camel/trunk/examples/pom.xml

Added: camel/trunk/examples/camel-example-twitter-websocket/pom.xml
URL: http://svn.apache.org/viewvc/camel/trunk/examples/camel-example-twitter-websocket/pom.xml?rev=1301951&view=auto
==============================================================================
--- camel/trunk/examples/camel-example-twitter-websocket/pom.xml (added)
+++ camel/trunk/examples/camel-example-twitter-websocket/pom.xml Sat Mar 17 15:30:52 2012
@@ -0,0 +1,81 @@
+<?xml version="1.0" encoding="UTF-8"?>
+
+<!--
+
+    Licensed to the Apache Software Foundation (ASF) under one or more
+    contributor license agreements.  See the NOTICE file distributed with
+    this work for additional information regarding copyright ownership.
+    The ASF licenses this file to You under the Apache License, Version 2.0
+    (the "License"); you may not use this file except in compliance with
+    the License.  You may obtain a copy of the License at
+
+       http://www.apache.org/licenses/LICENSE-2.0
+
+    Unless required by applicable law or agreed to in writing, software
+    distributed under the License is distributed on an "AS IS" BASIS,
+    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+    See the License for the specific language governing permissions and
+    limitations under the License.
+
+-->
+
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
+
+  <modelVersion>4.0.0</modelVersion>
+
+  <parent>
+    <groupId>org.apache.camel</groupId>
+    <artifactId>examples</artifactId>
+    <version>2.10-SNAPSHOT</version>
+    <relativePath>..</relativePath>
+  </parent>
+
+  <artifactId>camel-example-twitter-websocket</artifactId>
+  <packaging>jar</packaging>
+  <name>Camel :: Example :: Twitter WebSocket</name>
+  <description>An example that pushes new tweets to a web page using web-socket</description>
+
+  <dependencies>
+
+    <dependency>
+      <groupId>org.apache.camel</groupId>
+      <artifactId>camel-core</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.apache.camel</groupId>
+      <artifactId>camel-twitter</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.apache.camel</groupId>
+      <artifactId>camel-websocket</artifactId>
+    </dependency>
+
+    <!-- logging to the console -->
+    <dependency>
+      <groupId>org.slf4j</groupId>
+      <artifactId>slf4j-log4j12</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>log4j</groupId>
+      <artifactId>log4j</artifactId>
+    </dependency>
+
+  </dependencies>
+
+  <build>
+    <plugins>
+      <!-- Allows the example to be run via 'mvn compile exec:java' -->
+      <plugin>
+        <groupId>org.codehaus.mojo</groupId>
+        <artifactId>exec-maven-plugin</artifactId>
+        <configuration>
+          <mainClass>org.apache.camel.example.websocket.CamelTwitterWebSocketMain</mainClass>
+          <includePluginDependencies>false</includePluginDependencies>
+        </configuration>
+      </plugin>
+    </plugins>
+
+  </build>
+
+</project>

Propchange: camel/trunk/examples/camel-example-twitter-websocket/pom.xml
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: camel/trunk/examples/camel-example-twitter-websocket/pom.xml
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Propchange: camel/trunk/examples/camel-example-twitter-websocket/pom.xml
------------------------------------------------------------------------------
    svn:mime-type = text/xml

Added: camel/trunk/examples/camel-example-twitter-websocket/src/main/java/org/apache/camel/example/websocket/CamelTwitterWebSocketMain.java
URL: http://svn.apache.org/viewvc/camel/trunk/examples/camel-example-twitter-websocket/src/main/java/org/apache/camel/example/websocket/CamelTwitterWebSocketMain.java?rev=1301951&view=auto
==============================================================================
--- camel/trunk/examples/camel-example-twitter-websocket/src/main/java/org/apache/camel/example/websocket/CamelTwitterWebSocketMain.java
(added)
+++ camel/trunk/examples/camel-example-twitter-websocket/src/main/java/org/apache/camel/example/websocket/CamelTwitterWebSocketMain.java
Sat Mar 17 15:30:52 2012
@@ -0,0 +1,78 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.example.websocket;
+
+import org.apache.camel.main.Main;
+
+/**
+ * A main to start this example.
+ */
+public class CamelTwitterWebSocketMain {
+
+    // Twitter now requires the use of OAuth for all client application authentication.
+    // In order to use camel-twitter with your account, you'll need to create a new application
+    // within Twitter at https://dev.twitter.com/apps/new and grant the application access
to your account.
+    // Finally, generate your access token and secret.
+    private static String consumerKey = "INSERT HERE";
+    private static String consumerSecret = "INSERT HERE";
+    private static String accessToken = "INSERT HERE";
+    private static String accessTokenSecret = "INSERT HERE";
+
+    public static void main(String[] args) throws Exception {
+        if (consumerKey.equals("INSERT HERE")) {
+            System.out.println("\n\n\n\n");
+            System.err.println("============================================================================");
+            System.err.println("Error you need to configure twitter application authentication
before using.");
+            System.err.println("See more details in this source code.");
+            System.err.println("============================================================================");
+            System.out.println("\n\n\n\n");
+            System.exit(0);
+        } else {
+            System.out.println("\n\n\n\n");
+            System.out.println("===============================================");
+            System.out.println("Open your web browser on http://localhost:9090");
+            System.out.println("Press ctrl+c to stop this example");
+            System.out.println("===============================================");
+            System.out.println("\n\n\n\n");
+        }
+
+        // create a new Camel Main so we can easily start Camel
+        Main main = new Main();
+
+        // enable hangup support which mean we detect when the JVM terminates, and stop Camel
graceful
+        main.enableHangupSupport();
+
+        TwitterWebSocketRoute route = new TwitterWebSocketRoute();
+
+        // setup twitter application authentication
+        route.setAccessToken(accessToken);
+        route.setAccessTokenSecret(accessTokenSecret);
+        route.setConsumerKey(consumerKey);
+        route.setConsumerSecret(consumerSecret);
+
+        // poll for gaga, every 2nd second
+        route.setSearchTerm("gaga");
+        route.setDelay(2);
+
+        // add our routes to Camel
+        main.addRouteBuilder(route);
+
+        // and run, which keeps blocking until we terminate the JVM (or stop CamelContext)
+        main.run();
+    }
+
+}

Propchange: camel/trunk/examples/camel-example-twitter-websocket/src/main/java/org/apache/camel/example/websocket/CamelTwitterWebSocketMain.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: camel/trunk/examples/camel-example-twitter-websocket/src/main/java/org/apache/camel/example/websocket/CamelTwitterWebSocketMain.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Added: 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=1301951&view=auto
==============================================================================
--- camel/trunk/examples/camel-example-twitter-websocket/src/main/java/org/apache/camel/example/websocket/TwitterWebSocketRoute.java
(added)
+++ camel/trunk/examples/camel-example-twitter-websocket/src/main/java/org/apache/camel/example/websocket/TwitterWebSocketRoute.java
Sat Mar 17 15:30:52 2012
@@ -0,0 +1,99 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.example.websocket;
+
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.component.websocket.WebsocketComponent;
+import org.apache.camel.component.websocket.WebsocketConstants;
+
+/**
+ * A Camel route that updates from twitter all tweets using having the search term.
+ * And post the changes to web-socket, that can be viewed from a web page
+ */
+public class TwitterWebSocketRoute extends RouteBuilder {
+
+    private String searchTerm;
+    private int delay = 2;
+    
+    private String consumerKey;
+    private String consumerSecret;
+    private String accessToken;
+    private String accessTokenSecret;
+
+    public String getAccessToken() {
+        return accessToken;
+    }
+
+    public void setAccessToken(String accessToken) {
+        this.accessToken = accessToken;
+    }
+
+    public String getAccessTokenSecret() {
+        return accessTokenSecret;
+    }
+
+    public void setAccessTokenSecret(String accessTokenSecret) {
+        this.accessTokenSecret = accessTokenSecret;
+    }
+
+    public String getConsumerKey() {
+        return consumerKey;
+    }
+
+    public void setConsumerKey(String consumerKey) {
+        this.consumerKey = consumerKey;
+    }
+
+    public String getConsumerSecret() {
+        return consumerSecret;
+    }
+
+    public void setConsumerSecret(String consumerSecret) {
+        this.consumerSecret = consumerSecret;
+    }
+
+    public int getDelay() {
+        return delay;
+    }
+
+    public void setDelay(int delay) {
+        this.delay = delay;
+    }
+
+    public String getSearchTerm() {
+        return searchTerm;
+    }
+
+    public void setSearchTerm(String searchTerm) {
+        this.searchTerm = searchTerm;
+    }
+
+    @Override
+    public void configure() throws Exception {
+        // setup Camel web-socket component on port 9090
+        WebsocketComponent wc = getContext().getComponent("websocket", WebsocketComponent.class);
+        wc.setPort(9090);
+        wc.setStaticResources("src/main/resources");
+
+        // poll twitter search for new tweets, and push tweets to all web socket subscribers
on camel-tweet
+        fromF("twitter://search?type=polling&delay=%s&keywords=%s"
+                + "&consumerKey=%s&consumerSecret=%s&accessToken=%s&accessTokenSecret=%s",
+                delay, searchTerm, consumerKey, consumerSecret, accessToken, accessTokenSecret)
+            .setHeader(WebsocketConstants.SEND_TO_ALL).constant(true)
+            .to("websocket:camel-tweet");
+    }
+}

Propchange: camel/trunk/examples/camel-example-twitter-websocket/src/main/java/org/apache/camel/example/websocket/TwitterWebSocketRoute.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: camel/trunk/examples/camel-example-twitter-websocket/src/main/java/org/apache/camel/example/websocket/TwitterWebSocketRoute.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Added: camel/trunk/examples/camel-example-twitter-websocket/src/main/resources/index.html
URL: http://svn.apache.org/viewvc/camel/trunk/examples/camel-example-twitter-websocket/src/main/resources/index.html?rev=1301951&view=auto
==============================================================================
--- camel/trunk/examples/camel-example-twitter-websocket/src/main/resources/index.html (added)
+++ camel/trunk/examples/camel-example-twitter-websocket/src/main/resources/index.html Sat
Mar 17 15:30:52 2012
@@ -0,0 +1,73 @@
+<?xml version="1.0" encoding="UTF-8"?>
+
+<!--
+
+    Licensed to the Apache Software Foundation (ASF) under one or more
+    contributor license agreements.  See the NOTICE file distributed with
+    this work for additional information regarding copyright ownership.
+    The ASF licenses this file to You under the Apache License, Version 2.0
+    (the "License"); you may not use this file except in compliance with
+    the License.  You may obtain a copy of the License at
+
+       http://www.apache.org/licenses/LICENSE-2.0
+
+    Unless required by applicable law or agreed to in writing, software
+    distributed under the License is distributed on an "AS IS" BASIS,
+    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+    See the License for the specific language governing permissions and
+    limitations under the License.
+
+-->
+
+<html>
+<head>
+    <title>Camel Twitter WebSocket Example</title>
+    <script type='text/javascript'>
+
+        if (!window.WebSocket) {
+        alert("WebSocket not supported by this browser");
+        }
+
+        function $() { return document.getElementById(arguments[0]); }
+
+        var room = {
+        join: function(name) {
+        this._username=name;
+        var location = "ws://localhost:9090/camel-tweet";
+        this._ws=new WebSocket(location);
+        this._ws.onmessage=this._onmessage;
+        this._ws.onclose=this._onclose;
+        },
+
+        _onmessage: function(m) {
+        if (m.data){
+        var chat=$('chat');
+        var spanText = document.createElement('span');
+        spanText.className='text';
+        spanText.innerHTML=m.data;
+        var lineBreak = document.createElement('br');
+        chat.appendChild(spanText);
+        chat.appendChild(lineBreak);
+        chat.scrollTop = chat.scrollHeight - chat.clientHeight;
+        }
+        },
+
+        _onclose: function(m) {
+        this._ws=null;
+        }
+
+        };
+
+    </script>
+    <style type='text/css'>
+        div { border: 0px solid black; }
+        div#chat { clear: both; width: 80em; height: 60ex; overflow: auto; background-color:
#f0f0f0; padding: 4px; border: 1px solid black; }
+    </style>
+</head>
+<body>
+<div id='chat'></div>
+<script type='text/javascript'>
+    room.join("Testing");
+</script>
+</body>
+</html>

Propchange: camel/trunk/examples/camel-example-twitter-websocket/src/main/resources/index.html
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: camel/trunk/examples/camel-example-twitter-websocket/src/main/resources/index.html
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Propchange: camel/trunk/examples/camel-example-twitter-websocket/src/main/resources/index.html
------------------------------------------------------------------------------
    svn:mime-type = text/html

Added: camel/trunk/examples/camel-example-twitter-websocket/src/main/resources/log4j.properties
URL: http://svn.apache.org/viewvc/camel/trunk/examples/camel-example-twitter-websocket/src/main/resources/log4j.properties?rev=1301951&view=auto
==============================================================================
--- camel/trunk/examples/camel-example-twitter-websocket/src/main/resources/log4j.properties
(added)
+++ camel/trunk/examples/camel-example-twitter-websocket/src/main/resources/log4j.properties
Sat Mar 17 15:30:52 2012
@@ -0,0 +1,10 @@
+log4j.rootLogger=INFO, out
+
+# uncomment the following line to turn on Camel debugging
+#log4j.logger.org.apache.camel.component.twitter=DEBUG
+#log4j.logger.org.apache.camel.component.websocket=DEBUG
+
+# CONSOLE appender not used by default
+log4j.appender.out=org.apache.log4j.ConsoleAppender
+log4j.appender.out.layout=org.apache.log4j.PatternLayout
+log4j.appender.out.layout.ConversionPattern=[%30.30t] %-30.30c{1} %-5p %m%n

Propchange: camel/trunk/examples/camel-example-twitter-websocket/src/main/resources/log4j.properties
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: camel/trunk/examples/camel-example-twitter-websocket/src/main/resources/log4j.properties
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Propchange: camel/trunk/examples/camel-example-twitter-websocket/src/main/resources/log4j.properties
------------------------------------------------------------------------------
    svn:mime-type = text/plain

Modified: camel/trunk/examples/pom.xml
URL: http://svn.apache.org/viewvc/camel/trunk/examples/pom.xml?rev=1301951&r1=1301950&r2=1301951&view=diff
==============================================================================
--- camel/trunk/examples/pom.xml (original)
+++ camel/trunk/examples/pom.xml Sat Mar 17 15:30:52 2012
@@ -65,6 +65,7 @@
     <module>camel-example-spring-security</module>
     <module>camel-example-ssh</module>
     <module>camel-example-tracer</module>
+    <module>camel-example-twitter-websocket</module>
   </modules>
  
   <properties>



Mime
View raw message