activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r1305905 - in /activemq/activemq-apollo/trunk: apollo-distro/src/main/release/examples/cpp/ apollo-distro/src/main/release/examples/csharp/ apollo-distro/src/main/release/examples/csharp/ApolloExamples/ apollo-distro/src/main/release/exampl...
Date Tue, 27 Mar 2012 17:08:32 GMT
Author: chirino
Date: Tue Mar 27 17:08:28 2012
New Revision: 1305905

URL: http://svn.apache.org/viewvc?rev=1305905&view=rev
Log:
Fixes APLO-173 : Document how to use the MQTT protocol with Apollo.

Just added an MQTT Publisher / Listener example and re-organized the examples directory structure so that it's organized by protocol.

Added:
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/mqtt/
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/mqtt/java/
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/mqtt/java/pom.xml
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/java/pom.xml
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/mqtt/java/readme.md
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/mqtt/java/src/
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/mqtt/java/src/main/
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/mqtt/java/src/main/java/
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/mqtt/java/src/main/java/example/
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/mqtt/java/src/main/java/example/Listener.java
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/mqtt/java/src/main/java/example/Publisher.java
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/java/src/main/java/example/Publisher.java
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/cpp/
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/cpp/Listener.cpp
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/cpp/Listener.cpp
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/cpp/Publisher.cpp
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/cpp/Publisher.cpp
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/cpp/readme.md
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/cpp/readme.md
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/ApolloExamples.sln
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/ApolloExamples.sln
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/ApolloExamples.userprefs
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/ApolloExamples.userprefs
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Listener/
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Listener/AssemblyInfo.cs
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/Listener/AssemblyInfo.cs
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Listener/Listener.cs
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/Listener/Listener.cs
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Listener/Listener.csproj
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/Listener/Listener.csproj
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Listener/NMSTracer.cs
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/Listener/NMSTracer.cs
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Publisher/
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Publisher/AssemblyInfo.cs
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/Publisher/AssemblyInfo.cs
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Publisher/NMSTracer.cs
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/Publisher/NMSTracer.cs
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Publisher/Publisher.cs
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/Publisher/Publisher.cs
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Publisher/Publisher.csproj
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/Publisher/Publisher.csproj
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/readme.md
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/readme.md
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/java/
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/java/pom.xml
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/java/pom.xml
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/java/readme.md
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/java/readme.md
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/java/src/
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/java/src/main/
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/java/src/main/java/
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/java/src/main/java/example/
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/java/src/main/java/example/Listener.java
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/java/src/main/java/example/Listener.java
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/java/src/main/java/example/Publisher.java
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/java/src/main/java/example/Publisher.java
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/perl/
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/perl/listener
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/perl/listener
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/perl/publisher
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/perl/publisher
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/perl/readme.md
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/perl/readme.md
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/php/
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/php/listener.php
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/php/listener.php
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/php/publisher.php
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/php/publisher.php
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/php/readme.md
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/php/readme.md
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/listener.py
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/python/listener.py
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/publisher.py
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/python/publisher.py
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/readme.md
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/python/readme.md
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/catstomp.rb
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/ruby/catstomp.rb
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/listener.rb
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/ruby/listener.rb
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/publisher.rb
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/ruby/publisher.rb
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/readme.md
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/ruby/readme.md
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/stompcat.rb
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/ruby/stompcat.rb
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/websocket/
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/websocket/css/
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/websocket/css/bootstrap.min.css
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/js-websocket/css/bootstrap.min.css
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/websocket/css/bootstrap.min.responsive.css
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/js-websocket/css/bootstrap.min.responsive.css
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/websocket/img/
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/websocket/img/glyphicons-halflings-white.png
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/js-websocket/img/glyphicons-halflings-white.png
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/websocket/img/glyphicons-halflings.png
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/js-websocket/img/glyphicons-halflings.png
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/websocket/index.html
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/js-websocket/index.html
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/websocket/js/
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/websocket/js/stomp.js
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/js-websocket/js/stomp.js
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/websocket/readme.md
      - copied, changed from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/js-websocket/readme.md
Removed:
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/cpp/Listener.cpp
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/cpp/Publisher.cpp
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/cpp/readme.md
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/ApolloExamples.sln
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/ApolloExamples.userprefs
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/Listener/AssemblyInfo.cs
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/Listener/Listener.cs
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/Listener/Listener.csproj
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/Listener/NMSTracer.cs
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/Publisher/AssemblyInfo.cs
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/Publisher/NMSTracer.cs
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/Publisher/Publisher.cs
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/Publisher/Publisher.csproj
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/readme.md
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/java/pom.xml
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/java/readme.md
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/java/src/main/java/example/Listener.java
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/java/src/main/java/example/Publisher.java
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/js-websocket/css/bootstrap.min.css
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/js-websocket/css/bootstrap.min.responsive.css
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/js-websocket/img/glyphicons-halflings-white.png
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/js-websocket/img/glyphicons-halflings.png
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/js-websocket/index.html
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/js-websocket/js/stomp.js
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/js-websocket/readme.md
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/perl/listener
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/perl/publisher
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/perl/readme.md
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/php/listener.php
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/php/publisher.php
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/php/readme.md
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/python/listener.py
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/python/publisher.py
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/python/readme.md
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/ruby/catstomp.rb
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/ruby/listener.rb
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/ruby/publisher.rb
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/ruby/readme.md
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/ruby/stompcat.rb
Modified:
    activemq/activemq-apollo/trunk/apollo-website/src/documentation/user-manual.md
    activemq/activemq-apollo/trunk/apollo-website/src/documentation/verification.md

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/mqtt/java/pom.xml (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/java/pom.xml)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/mqtt/java/pom.xml?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/mqtt/java/pom.xml&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/java/pom.xml&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/java/pom.xml (original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/mqtt/java/pom.xml Tue Mar 27 17:08:28 2012
@@ -20,11 +20,11 @@
   <modelVersion>4.0.0</modelVersion>
   
   <groupId>example</groupId>
-  <artifactId>example</artifactId>
+  <artifactId>mqtt-example</artifactId>
   <version>0.1-SNAPSHOT</version>
   
   <name>example</name>
-  <description>Apollo Java Examples</description>
+  <description>Apollo MQTT Java Examples</description>
 
   <repositories>
     <repository>
@@ -36,14 +36,9 @@
   <dependencies>
     
     <dependency>
-      <groupId>org.apache.geronimo.specs</groupId>
-      <artifactId>geronimo-jms_1.1_spec</artifactId>
-      <version>1.1</version>
-    </dependency>
-    <dependency>
-      <groupId>org.fusesource.stompjms</groupId>
-      <artifactId>stompjms-client</artifactId>
-      <version>${stompjms-version}</version>
+      <groupId>org.fusesource.mqtt-client</groupId>
+      <artifactId>mqtt-client</artifactId>
+      <version>1.0</version>
     </dependency>
 
   </dependencies>

Added: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/mqtt/java/readme.md
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/mqtt/java/readme.md?rev=1305905&view=auto
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/mqtt/java/readme.md (added)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/mqtt/java/readme.md Tue Mar 27 17:08:28 2012
@@ -0,0 +1,33 @@
+## Overview
+
+This is an example of how use the MQTT protocol with Apollo.  
+
+## Prereqs
+
+- Install Java SDK
+- Install [Maven](http://maven.apache.org/download.html) 
+- Install the [MQTT protocol for Apollo](https://github.com/fusesource/fuse-extra/tree/master/fusemq-apollo/fusemq-apollo-mqtt)
+
+## Building
+
+Run:
+
+    mvn install
+
+## Running the Examples
+
+In one terminal window run:
+
+    java -cp target/mqtt-example-0.1-SNAPSHOT.jar example.Listener
+
+In another terminal window run:
+
+    java -cp target/mqtt-example-0.1-SNAPSHOT.jar example.Publisher
+
+You can control to which stomp server the examples try to connect to by
+setting the following environment variables: 
+
+* `MQTT_HOST`
+* `MQTT_PORT`
+* `MQTT_USER`
+* `MQTT_PASSWORD`

Added: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/mqtt/java/src/main/java/example/Listener.java
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/mqtt/java/src/main/java/example/Listener.java?rev=1305905&view=auto
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/mqtt/java/src/main/java/example/Listener.java (added)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/mqtt/java/src/main/java/example/Listener.java Tue Mar 27 17:08:28 2012
@@ -0,0 +1,123 @@
+/**
+ * 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 example;
+
+import org.fusesource.hawtbuf.*;
+import org.fusesource.mqtt.client.*;
+
+/**
+ * Uses an callback based interface to MQTT.  Callback based interfaces
+ * are harder to use but are slightly more efficient.
+ */
+class Listener {
+
+    public static void main(String []args) throws Exception {
+
+        String user = env("STOMP_USER", "admin");
+        String password = env("STOMP_PASSWORD", "password");
+        String host = env("STOMP_HOST", "localhost");
+        int port = Integer.parseInt(env("STOMP_PORT", "61613"));
+        final String destination = arg(args, 0, "/topic/event");
+
+
+        MQTT mqtt = new MQTT();
+        mqtt.setHost(host, port);
+        mqtt.setUserName(user);
+        mqtt.setPassword(password);
+
+
+        final CallbackConnection connection = mqtt.callbackConnection();
+        connection.listener(new org.fusesource.mqtt.client.Listener() {
+            long count = 0;
+            long start = System.currentTimeMillis();
+
+            public void onConnected() {
+            }
+            public void onDisconnected() {
+            }
+            public void onFailure(Throwable value) {
+                value.printStackTrace();
+                System.exit(-2);
+            }
+            public void onPublish(UTF8Buffer topic, Buffer msg, Runnable ack) {
+                String body = msg.utf8().toString();
+                if( "SHUTDOWN".equals(body)) {
+                    long diff = System.currentTimeMillis() - start;
+                    System.out.println(String.format("Received %d in %.2f seconds", count, (1.0*diff/1000.0)));
+                    connection.disconnect(new Callback<Void>() {
+                        @Override
+                        public void onSuccess(Void value) {
+                            System.exit(0);
+                        }
+                        @Override
+                        public void onFailure(Throwable value) {
+                            value.printStackTrace();
+                            System.exit(-2);
+                        }
+                    });
+                } else {
+                    if( count == 0 ) {
+                        start = System.currentTimeMillis();
+                    }
+                    if( count % 1000 == 0 ) {
+                        System.out.println(String.format("Received %d messages.", count));
+                    }
+                    count ++;
+                }
+            }
+        });
+        connection.connect(new Callback<Void>() {
+            @Override
+            public void onSuccess(Void value) {
+                Topic[] topics = {new Topic(destination, QoS.AT_LEAST_ONCE)};
+                connection.subscribe(topics, new Callback<byte[]>() {
+                    public void onSuccess(byte[] qoses) {
+                    }
+                    public void onFailure(Throwable value) {
+                        value.printStackTrace();
+                        System.exit(-2);
+                    }
+                });
+            }
+            @Override
+            public void onFailure(Throwable value) {
+                value.printStackTrace();
+                System.exit(-2);
+            }
+        });
+
+        // Wait forever..
+        synchronized (Listener.class) {
+            while(true)
+                Listener.class.wait();
+        }
+    }
+
+    private static String env(String key, String defaultValue) {
+        String rc = System.getenv(key);
+        if( rc== null )
+            return defaultValue;
+        return rc;
+    }
+
+    private static String arg(String []args, int index, String defaultValue) {
+        if( index < args.length )
+            return args[index];
+        else
+            return defaultValue;
+    }
+}
\ No newline at end of file

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/mqtt/java/src/main/java/example/Publisher.java (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/java/src/main/java/example/Publisher.java)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/mqtt/java/src/main/java/example/Publisher.java?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/mqtt/java/src/main/java/example/Publisher.java&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/java/src/main/java/example/Publisher.java&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/java/src/main/java/example/Publisher.java (original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/mqtt/java/src/main/java/example/Publisher.java Tue Mar 27 17:08:28 2012
@@ -16,18 +16,28 @@
  */
 package example;
 
-import org.fusesource.stomp.jms.*;
-import javax.jms.*;
+import org.fusesource.hawtbuf.AsciiBuffer;
+import org.fusesource.hawtbuf.Buffer;
+import org.fusesource.hawtbuf.UTF8Buffer;
+import org.fusesource.mqtt.client.Future;
+import org.fusesource.mqtt.client.FutureConnection;
+import org.fusesource.mqtt.client.MQTT;
+import org.fusesource.mqtt.client.QoS;
 
+import java.util.LinkedList;
+
+/**
+ * Uses a Future based API to MQTT.
+ */
 class Publisher {
 
-    public static void main(String []args) throws JMSException {
+    public static void main(String []args) throws Exception {
 
         String user = env("STOMP_USER", "admin");
         String password = env("STOMP_PASSWORD", "password");
         String host = env("STOMP_HOST", "localhost");
         int port = Integer.parseInt(env("STOMP_PORT", "61613"));
-        String destination = arg(args, 0, "/topic/event");
+        final String destination = arg(args, 0, "/topic/event");
 
         int messages = 10000;
         int size = 256;
@@ -37,29 +47,40 @@ class Publisher {
         for( int i=0; i < size; i ++) {
             body += DATA.charAt(i%DATA.length());
         }
+       Buffer msg = new AsciiBuffer(body);
 
-        StompJmsConnectionFactory factory = new StompJmsConnectionFactory();
-        factory.setBrokerURI("tcp://" + host + ":" + port);
+        MQTT mqtt = new MQTT();
+        mqtt.setHost(host, port);
+        mqtt.setUserName(user);
+        mqtt.setPassword(password);
 
-        Connection connection = factory.createConnection(user, password);
-        connection.start();
-        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
-        Destination dest = new StompJmsDestination(destination);
-        MessageProducer producer = session.createProducer(dest);
-        producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
+        FutureConnection connection = mqtt.futureConnection();
+        connection.connect().await();
 
+        final LinkedList<Future<Void>> queue = new LinkedList<Future<Void>>();
+        UTF8Buffer topic = new UTF8Buffer(destination);
         for( int i=1; i <= messages; i ++) {
-            TextMessage msg = session.createTextMessage(body);
-            msg.setIntProperty("id", i);
-            producer.send(msg);
-            if( (i % 1000) == 0) {
-                System.out.println(String.format("Sent %d messages", i));
+
+            // Send the publish without waiting for it to complete. This allows us
+            // to send multiple message without blocking..
+            queue.add(connection.publish(topic, msg, QoS.AT_LEAST_ONCE, false));
+
+            // Eventually we start waiting for old publish futures to complete
+            // so that we don't create a large in memory buffer of outgoing message.s
+            if( queue.size() >= 1000 ) {
+                queue.removeFirst().await();
             }
+
+        }
+
+        queue.add(connection.publish(topic, new AsciiBuffer("SHUTDOWN"), QoS.AT_LEAST_ONCE, false));
+        while( !queue.isEmpty() ) {
+            queue.removeFirst().await();
         }
 
-        producer.send(session.createTextMessage("SHUTDOWN"));
-        connection.close();
+        connection.disconnect().await();
 
+        System.exit(0);
     }
 
     private static String env(String key, String defaultValue) {

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/cpp/Listener.cpp (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/cpp/Listener.cpp)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/cpp/Listener.cpp?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/cpp/Listener.cpp&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/cpp/Listener.cpp&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
    (empty)

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/cpp/Publisher.cpp (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/cpp/Publisher.cpp)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/cpp/Publisher.cpp?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/cpp/Publisher.cpp&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/cpp/Publisher.cpp&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
    (empty)

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/cpp/readme.md (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/cpp/readme.md)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/cpp/readme.md?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/cpp/readme.md&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/cpp/readme.md&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
    (empty)

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/ApolloExamples.sln (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/ApolloExamples.sln)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/ApolloExamples.sln?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/ApolloExamples.sln&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/ApolloExamples.sln&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
    (empty)

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/ApolloExamples.userprefs (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/ApolloExamples.userprefs)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/ApolloExamples.userprefs?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/ApolloExamples.userprefs&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/ApolloExamples.userprefs&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
    (empty)

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Listener/AssemblyInfo.cs (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/Listener/AssemblyInfo.cs)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Listener/AssemblyInfo.cs?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Listener/AssemblyInfo.cs&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/Listener/AssemblyInfo.cs&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
    (empty)

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Listener/Listener.cs (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/Listener/Listener.cs)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Listener/Listener.cs?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Listener/Listener.cs&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/Listener/Listener.cs&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
    (empty)

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Listener/Listener.csproj (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/Listener/Listener.csproj)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Listener/Listener.csproj?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Listener/Listener.csproj&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/Listener/Listener.csproj&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
    (empty)

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Listener/NMSTracer.cs (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/Listener/NMSTracer.cs)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Listener/NMSTracer.cs?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Listener/NMSTracer.cs&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/Listener/NMSTracer.cs&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
    (empty)

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Publisher/AssemblyInfo.cs (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/Publisher/AssemblyInfo.cs)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Publisher/AssemblyInfo.cs?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Publisher/AssemblyInfo.cs&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/Publisher/AssemblyInfo.cs&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
    (empty)

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Publisher/NMSTracer.cs (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/Publisher/NMSTracer.cs)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Publisher/NMSTracer.cs?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Publisher/NMSTracer.cs&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/Publisher/NMSTracer.cs&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
    (empty)

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Publisher/Publisher.cs (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/Publisher/Publisher.cs)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Publisher/Publisher.cs?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Publisher/Publisher.cs&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/Publisher/Publisher.cs&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
    (empty)

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Publisher/Publisher.csproj (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/Publisher/Publisher.csproj)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Publisher/Publisher.csproj?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Publisher/Publisher.csproj&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/Publisher/Publisher.csproj&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
    (empty)

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/readme.md (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/readme.md)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/readme.md?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/readme.md&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/readme.md&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
    (empty)

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/java/pom.xml (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/java/pom.xml)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/java/pom.xml?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/java/pom.xml&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/java/pom.xml&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/java/pom.xml (original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/java/pom.xml Tue Mar 27 17:08:28 2012
@@ -20,11 +20,11 @@
   <modelVersion>4.0.0</modelVersion>
   
   <groupId>example</groupId>
-  <artifactId>example</artifactId>
+  <artifactId>stomp-example</artifactId>
   <version>0.1-SNAPSHOT</version>
   
   <name>example</name>
-  <description>Apollo Java Examples</description>
+  <description>Apollo STOMP Java Examples</description>
 
   <repositories>
     <repository>

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/java/readme.md (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/java/readme.md)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/java/readme.md?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/java/readme.md&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/java/readme.md&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/java/readme.md (original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/java/readme.md Tue Mar 27 17:08:28 2012
@@ -17,11 +17,11 @@ Run:
 
 In one terminal window run:
 
-    java -cp target/example-0.1-SNAPSHOT.jar example.Listener
+    java -cp target/stomp-example-0.1-SNAPSHOT.jar example.Listener
 
 In another terminal window run:
 
-    java -cp target/example-0.1-SNAPSHOT.jar example.Publisher
+    java -cp target/stomp-example-0.1-SNAPSHOT.jar example.Publisher
 
 You can control to which stomp server the examples try to connect to by
 setting the following environment variables: 

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/java/src/main/java/example/Listener.java (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/java/src/main/java/example/Listener.java)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/java/src/main/java/example/Listener.java?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/java/src/main/java/example/Listener.java&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/java/src/main/java/example/Listener.java&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
    (empty)

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/java/src/main/java/example/Publisher.java (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/java/src/main/java/example/Publisher.java)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/java/src/main/java/example/Publisher.java?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/java/src/main/java/example/Publisher.java&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/java/src/main/java/example/Publisher.java&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
    (empty)

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/perl/listener (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/perl/listener)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/perl/listener?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/perl/listener&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/perl/listener&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
    (empty)

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/perl/publisher (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/perl/publisher)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/perl/publisher?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/perl/publisher&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/perl/publisher&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
    (empty)

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/perl/readme.md (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/perl/readme.md)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/perl/readme.md?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/perl/readme.md&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/perl/readme.md&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
    (empty)

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/php/listener.php (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/php/listener.php)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/php/listener.php?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/php/listener.php&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/php/listener.php&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
    (empty)

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/php/publisher.php (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/php/publisher.php)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/php/publisher.php?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/php/publisher.php&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/php/publisher.php&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
    (empty)

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/php/readme.md (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/php/readme.md)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/php/readme.md?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/php/readme.md&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/php/readme.md&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
    (empty)

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/listener.py (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/python/listener.py)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/listener.py?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/listener.py&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/python/listener.py&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
    (empty)

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/publisher.py (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/python/publisher.py)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/publisher.py?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/publisher.py&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/python/publisher.py&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
    (empty)

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/readme.md (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/python/readme.md)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/readme.md?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/readme.md&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/python/readme.md&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
    (empty)

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/catstomp.rb (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/ruby/catstomp.rb)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/catstomp.rb?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/catstomp.rb&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/ruby/catstomp.rb&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
    (empty)

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/listener.rb (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/ruby/listener.rb)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/listener.rb?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/listener.rb&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/ruby/listener.rb&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
    (empty)

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/publisher.rb (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/ruby/publisher.rb)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/publisher.rb?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/publisher.rb&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/ruby/publisher.rb&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
    (empty)

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/readme.md (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/ruby/readme.md)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/readme.md?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/readme.md&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/ruby/readme.md&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
    (empty)

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/stompcat.rb (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/ruby/stompcat.rb)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/stompcat.rb?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/stompcat.rb&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/ruby/stompcat.rb&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
    (empty)

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/websocket/css/bootstrap.min.css (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/js-websocket/css/bootstrap.min.css)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/websocket/css/bootstrap.min.css?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/websocket/css/bootstrap.min.css&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/js-websocket/css/bootstrap.min.css&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
    (empty)

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/websocket/css/bootstrap.min.responsive.css (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/js-websocket/css/bootstrap.min.responsive.css)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/websocket/css/bootstrap.min.responsive.css?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/websocket/css/bootstrap.min.responsive.css&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/js-websocket/css/bootstrap.min.responsive.css&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
    (empty)

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/websocket/img/glyphicons-halflings-white.png (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/js-websocket/img/glyphicons-halflings-white.png)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/websocket/img/glyphicons-halflings-white.png?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/websocket/img/glyphicons-halflings-white.png&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/js-websocket/img/glyphicons-halflings-white.png&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
    (empty)

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/websocket/img/glyphicons-halflings.png (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/js-websocket/img/glyphicons-halflings.png)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/websocket/img/glyphicons-halflings.png?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/websocket/img/glyphicons-halflings.png&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/js-websocket/img/glyphicons-halflings.png&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
    (empty)

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/websocket/index.html (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/js-websocket/index.html)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/websocket/index.html?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/websocket/index.html&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/js-websocket/index.html&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
    (empty)

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/websocket/js/stomp.js (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/js-websocket/js/stomp.js)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/websocket/js/stomp.js?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/websocket/js/stomp.js&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/js-websocket/js/stomp.js&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
    (empty)

Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/websocket/readme.md (from r1303877, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/js-websocket/readme.md)
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/websocket/readme.md?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/websocket/readme.md&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/js-websocket/readme.md&r1=1303877&r2=1305905&rev=1305905&view=diff
==============================================================================
    (empty)

Modified: activemq/activemq-apollo/trunk/apollo-website/src/documentation/user-manual.md
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-website/src/documentation/user-manual.md?rev=1305905&r1=1305904&r2=1305905&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-website/src/documentation/user-manual.md (original)
+++ activemq/activemq-apollo/trunk/apollo-website/src/documentation/user-manual.md Tue Mar 27 17:08:28 2012
@@ -268,7 +268,7 @@ the broker over WebSockets:
 * [stomp-websocket](http://github.com/jmesnil/stomp-websocket)
 
 The Apollo distribution include a simple WebSocket based chat example
-in the `examples/js-websocket` directory.
+in the `examples/websocket` directory.
 
 #### Virtual Hosts
 

Modified: activemq/activemq-apollo/trunk/apollo-website/src/documentation/verification.md
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-website/src/documentation/verification.md?rev=1305905&r1=1305904&r2=1305905&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-website/src/documentation/verification.md (original)
+++ activemq/activemq-apollo/trunk/apollo-website/src/documentation/verification.md Tue Mar 27 17:08:28 2012
@@ -7,19 +7,19 @@ If you have not already done so, install
 
     gem install stomp
 
-Change to the `examples/ruby` directory that was included in the ${project_name} 
+Change to the `examples/stomp/ruby` directory that was included in the ${project_name} 
 distribution.  Then in a terminal window, run:
 
 {pygmentize_and_compare::}
 -----------------------------
 text: Unix/Linux/OS X
 -----------------------------
-cd ${APOLLO_HOME}/examples/ruby
+cd ${APOLLO_HOME}/examples/stomp/ruby
 ruby listener.rb
 -----------------------------
 text: Windows
 -----------------------------
-cd %APOLLO_HOME%\examples\ruby
+cd %APOLLO_HOME%\examples\stomp\ruby
 ruby listener.rb
 {pygmentize_and_compare}
 
@@ -28,12 +28,12 @@ Then in a separate terminal window, run:
 -----------------------------
 text: Unix/Linux/OS X
 -----------------------------
-cd ${APOLLO_HOME}/examples/ruby
+cd ${APOLLO_HOME}/examples/stomp/ruby
 ruby publisher.rb
 -----------------------------
 text: Windows
 -----------------------------
-cd %APOLLO_HOME%\examples\ruby
+cd %APOLLO_HOME%\examples\stomp\ruby
 ruby publisher.rb
 {pygmentize_and_compare}
 



Mime
View raw message