activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r1418046 - in /activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples: mqtt/java/src/main/java/example/ stomp/cpp/ stomp/csharp/ stomp/csharp/ApolloExamples/Listener/ stomp/csharp/ApolloExamples/Publisher/ stomp/java/ stomp/...
Date Thu, 06 Dec 2012 19:57:00 GMT
Author: chirino
Date: Thu Dec  6 19:56:58 2012
New Revision: 1418046

URL: http://svn.apache.org/viewvc?rev=1418046&view=rev
Log:
Make the environment variable less protocol specific so that way the same settings can work
against the different examples.

Modified:
    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
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/cpp/Listener.cpp
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/cpp/Publisher.cpp
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/cpp/readme.md
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Listener/Listener.cs
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Publisher/Publisher.cs
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/readme.md
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/java/readme.md
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/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
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/perl/listener
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/perl/publisher
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/php/listener.php
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/php/publisher.php
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/stompest/async/listener.py
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/stompest/async/publisher.py
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/stompest/sync/listener.py
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/stompest/sync/publisher.py
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/stomppy/listener.py
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/stomppy/publisher.py
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/catstomp.rb
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/listener.rb
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/publisher.rb
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/stompcat.rb

Modified: 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=1418046&r1=1418045&r2=1418046&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/mqtt/java/src/main/java/example/Listener.java
(original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/mqtt/java/src/main/java/example/Listener.java
Thu Dec  6 19:56:58 2012
@@ -27,10 +27,10 @@ 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"));
+        String user = env("APOLLO_USER", "admin");
+        String password = env("APOLLO_PASSWORD", "password");
+        String host = env("APOLLO_HOST", "localhost");
+        int port = Integer.parseInt(env("APOLLO_PORT", "61613"));
         final String destination = arg(args, 0, "/topic/event");
 
 

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/mqtt/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?rev=1418046&r1=1418045&r2=1418046&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/mqtt/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
Thu Dec  6 19:56:58 2012
@@ -33,10 +33,10 @@ class Publisher {
 
     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 user = env("APOLLO_USER", "admin");
+        String password = env("APOLLO_PASSWORD", "password");
+        String host = env("APOLLO_HOST", "localhost");
+        int port = Integer.parseInt(env("APOLLO_PORT", "61613"));
         final String destination = arg(args, 0, "/topic/event");
 
         int messages = 10000;

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/cpp/Listener.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/cpp/Listener.cpp?rev=1418046&r1=1418045&r2=1418046&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/cpp/Listener.cpp
(original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/cpp/Listener.cpp
Thu Dec  6 19:56:58 2012
@@ -66,10 +66,10 @@ int main(int argc AMQCPP_UNUSED, char* a
     std::cout << "Starting the Listener example:" << std::endl;
     std::cout << "-----------------------------------------------------\n";
 
-    std::string user = getEnv("STOMP_USER", "admin");
-    std::string password = getEnv("STOMP_PASSWORD", "password");
-    std::string host = getEnv("STOMP_HOST", "localhost");
-    int port = Integer::parseInt(getEnv("STOMP_PORT", "61613"));
+    std::string user = getEnv("APOLLO_USER", "admin");
+    std::string password = getEnv("APOLLO_PASSWORD", "password");
+    std::string host = getEnv("APOLLO_HOST", "localhost");
+    int port = Integer::parseInt(getEnv("APOLLO_PORT", "61613"));
     std::string destination = getArg(argv, argc, 1, "event");
 
     {

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/cpp/Publisher.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/cpp/Publisher.cpp?rev=1418046&r1=1418045&r2=1418046&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/cpp/Publisher.cpp
(original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/cpp/Publisher.cpp
Thu Dec  6 19:56:58 2012
@@ -68,10 +68,10 @@ int main(int argc, char* argv[]) {
     std::cout << "Starting the Publisher example:" << std::endl;
     std::cout << "-----------------------------------------------------\n";
 
-    std::string user = getEnv("STOMP_USER", "admin");
-    std::string password = getEnv("STOMP_PASSWORD", "password");
-    std::string host = getEnv("STOMP_HOST", "localhost");
-    int port = Integer::parseInt(getEnv("STOMP_PORT", "61613"));
+    std::string user = getEnv("APOLLO_USER", "admin");
+    std::string password = getEnv("APOLLO_PASSWORD", "password");
+    std::string host = getEnv("APOLLO_HOST", "localhost");
+    int port = Integer::parseInt(getEnv("APOLLO_PORT", "61613"));
     std::string destination = getArg(argv, argc, 1, "event");
 
     int messages = 10000;

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/cpp/readme.md
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/cpp/readme.md?rev=1418046&r1=1418045&r2=1418046&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/cpp/readme.md
(original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/cpp/readme.md
Thu Dec  6 19:56:58 2012
@@ -38,7 +38,7 @@ In another terminal window run:
 You can control to which stomp server the examples try to connect to by
 setting the following environment variables: 
 
-* `STOMP_HOST`
-* `STOMP_PORT`
-* `STOMP_USER`
-* `STOMP_PASSWORD`
+* `APOLLO_HOST`
+* `APOLLO_PORT`
+* `APOLLO_USER`
+* `APOLLO_PASSWORD`

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/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?rev=1418046&r1=1418045&r2=1418046&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Listener/Listener.cs
(original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Listener/Listener.cs
Thu Dec  6 19:56:58 2012
@@ -28,10 +28,10 @@ namespace Apollo.Example
 		{
 			Console.WriteLine("Starting up Listener.");			
 						
-	        String user = env("STOMP_USER", "admin");
-	        String password = env("STOMP_PASSWORD", "password");
-	        String host = env("STOMP_HOST", "localhost");
-	        int port = Int32.Parse(env("STOMP_PORT", "61613"));
+	        String user = env("APOLLO_USER", "admin");
+	        String password = env("APOLLO_PASSWORD", "password");
+	        String host = env("APOLLO_HOST", "localhost");
+	        int port = Int32.Parse(env("APOLLO_PORT", "61613"));
 	        String destination = arg(args, 0, "event");
 	
 			String brokerUri = "stomp:tcp://" + host + ":" + port + "?transport.useLogging=true";

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/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?rev=1418046&r1=1418045&r2=1418046&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Publisher/Publisher.cs
(original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/ApolloExamples/Publisher/Publisher.cs
Thu Dec  6 19:56:58 2012
@@ -26,10 +26,10 @@ namespace Apollo.Example
 	{
 		public static void Main (string[] args)
 		{
-	        String user = env("STOMP_USER", "admin");
-	        String password = env("STOMP_PASSWORD", "password");
-	        String host = env("STOMP_HOST", "localhost");
-	        int port = Int32.Parse(env("STOMP_PORT", "61613"));
+	        String user = env("APOLLO_USER", "admin");
+	        String password = env("APOLLO_PASSWORD", "password");
+	        String host = env("APOLLO_HOST", "localhost");
+	        int port = Int32.Parse(env("APOLLO_PORT", "61613"));
 			String destination = arg(args, 0, "event");
 	
 	        int messages = 10000;

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/readme.md
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/readme.md?rev=1418046&r1=1418045&r2=1418046&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/readme.md
(original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/csharp/readme.md
Thu Dec  6 19:56:58 2012
@@ -25,7 +25,7 @@ In another terminal window run:
 You can control to which stomp server the examples try to connect to by
 setting the following environment variables: 
 
-* `STOMP_HOST`
-* `STOMP_PORT`
-* `STOMP_USER`
-* `STOMP_PASSWORD`
+* `APOLLO_HOST`
+* `APOLLO_PORT`
+* `APOLLO_USER`
+* `APOLLO_PASSWORD`

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/java/readme.md
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/java/readme.md?rev=1418046&r1=1418045&r2=1418046&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/java/readme.md
(original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/java/readme.md
Thu Dec  6 19:56:58 2012
@@ -26,7 +26,7 @@ In another terminal window run:
 You can control to which stomp server the examples try to connect to by
 setting the following environment variables: 
 
-* `STOMP_HOST`
-* `STOMP_PORT`
-* `STOMP_USER`
-* `STOMP_PASSWORD`
+* `APOLLO_HOST`
+* `APOLLO_PORT`
+* `APOLLO_USER`
+* `APOLLO_PASSWORD`

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/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?rev=1418046&r1=1418045&r2=1418046&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/java/src/main/java/example/Listener.java
(original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/java/src/main/java/example/Listener.java
Thu Dec  6 19:56:58 2012
@@ -23,10 +23,10 @@ class Listener {
 
     public static void main(String []args) throws JMSException {
 
-        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 user = env("APOLLO_USER", "admin");
+        String password = env("APOLLO_PASSWORD", "password");
+        String host = env("APOLLO_HOST", "localhost");
+        int port = Integer.parseInt(env("APOLLO_PORT", "61613"));
         String destination = arg(args, 0, "/topic/event");
 
         StompJmsConnectionFactory factory = new StompJmsConnectionFactory();

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/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?rev=1418046&r1=1418045&r2=1418046&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/java/src/main/java/example/Publisher.java
(original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/java/src/main/java/example/Publisher.java
Thu Dec  6 19:56:58 2012
@@ -23,10 +23,10 @@ class Publisher {
 
     public static void main(String []args) throws JMSException {
 
-        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 user = env("APOLLO_USER", "admin");
+        String password = env("APOLLO_PASSWORD", "password");
+        String host = env("APOLLO_HOST", "localhost");
+        int port = Integer.parseInt(env("APOLLO_PORT", "61613"));
         String destination = arg(args, 0, "/topic/event");
 
         int messages = 10000;

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/perl/listener
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/perl/listener?rev=1418046&r1=1418045&r2=1418046&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/perl/listener
(original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/perl/listener
Thu Dec  6 19:56:58 2012
@@ -26,10 +26,10 @@ use Time::HiRes qw(time);
 
 our(%Option, $Conn, $Count, $Start, $Run);
 
-$Option{user} = $ENV{STOMP_USER} || "admin";
-$Option{password} = $ENV{STOMP_PASSWORD} || "password";
-$Option{host} = $ENV{STOMP_HOST} || "localhost";
-$Option{port} = $ENV{STOMP_PORT} || 61613;
+$Option{user} = $ENV{APOLLO_USER} || "admin";
+$Option{password} = $ENV{APOLLO_PASSWORD} || "password";
+$Option{host} = $ENV{APOLLO_HOST} || "localhost";
+$Option{port} = $ENV{APOLLO_PORT} || 61613;
 $Option{destination} = $ENV{STOMP_DESTINATION} || "/topic/event";
 
 sub callback ($$) {

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/perl/publisher
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/perl/publisher?rev=1418046&r1=1418045&r2=1418046&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/perl/publisher
(original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/perl/publisher
Thu Dec  6 19:56:58 2012
@@ -26,10 +26,10 @@ use Time::HiRes qw(time);
 
 our(%Option, $Conn, $Start);
 
-$Option{user} = $ENV{STOMP_USER} || "admin";
-$Option{password} = $ENV{STOMP_PASSWORD} || "password";
-$Option{host} = $ENV{STOMP_HOST} || "localhost";
-$Option{port} = $ENV{STOMP_PORT} || 61613;
+$Option{user} = $ENV{APOLLO_USER} || "admin";
+$Option{password} = $ENV{APOLLO_PASSWORD} || "password";
+$Option{host} = $ENV{APOLLO_HOST} || "localhost";
+$Option{port} = $ENV{APOLLO_PORT} || 61613;
 $Option{destination} = $ENV{STOMP_DESTINATION} || "/topic/event";
 $Option{count} = $ENV{STOMP_COUNT} || 10000;
 

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/php/listener.php
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/php/listener.php?rev=1418046&r1=1418045&r2=1418046&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/php/listener.php
(original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/php/listener.php
Thu Dec  6 19:56:58 2012
@@ -16,16 +16,16 @@
  * limitations under the License.
  */
 
-$user = getenv("STOMP_USER"); 
+$user = getenv("APOLLO_USER"); 
 if( !$user ) $user = "admin";
 
-$password = getenv("STOMP_PASSWORD");
+$password = getenv("APOLLO_PASSWORD");
 if( !$password ) $password = "password";
 
-$host = getenv("STOMP_HOST");
+$host = getenv("APOLLO_HOST");
 if( !$host ) $host = "localhost";
 
-$port = getenv("STOMP_PORT");
+$port = getenv("APOLLO_PORT");
 if( !$port ) $port = 61613;
 
 $destination  = '/topic/event';

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/php/publisher.php
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/php/publisher.php?rev=1418046&r1=1418045&r2=1418046&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/php/publisher.php
(original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/php/publisher.php
Thu Dec  6 19:56:58 2012
@@ -16,16 +16,16 @@
  * limitations under the License.
  */
 
-$user = getenv("STOMP_USER"); 
+$user = getenv("APOLLO_USER"); 
 if( !$user ) $user = "admin";
 
-$password = getenv("STOMP_PASSWORD");
+$password = getenv("APOLLO_PASSWORD");
 if( !$password ) $password = "password";
 
-$host = getenv("STOMP_HOST");
+$host = getenv("APOLLO_HOST");
 if( !$host ) $host = "localhost";
 
-$port = getenv("STOMP_PORT");
+$port = getenv("APOLLO_PORT");
 if( !$port ) $port = 61613;
 
 $destination  = '/topic/event';

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/stompest/async/listener.py
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/stompest/async/listener.py?rev=1418046&r1=1418045&r2=1418046&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/stompest/async/listener.py
(original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/stompest/async/listener.py
Thu Dec  6 19:56:58 2012
@@ -24,10 +24,10 @@ from twisted.internet import defer, reac
 from stompest.config import StompConfig
 from stompest.async import Stomp
 
-user = os.getenv('STOMP_USER') or 'admin'
-password = os.getenv('STOMP_PASSWORD') or 'password'
-host = os.getenv('STOMP_HOST') or 'localhost'
-port = int(os.getenv('STOMP_PORT') or 61613)
+user = os.getenv('APOLLO_USER') or 'admin'
+password = os.getenv('APOLLO_PASSWORD') or 'password'
+host = os.getenv('APOLLO_HOST') or 'localhost'
+port = int(os.getenv('APOLLO_PORT') or 61613)
 destination = sys.argv[1:2] or ['/topic/event']
 destination = destination[0]
 

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/stompest/async/publisher.py
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/stompest/async/publisher.py?rev=1418046&r1=1418045&r2=1418046&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/stompest/async/publisher.py
(original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/stompest/async/publisher.py
Thu Dec  6 19:56:58 2012
@@ -24,10 +24,10 @@ from twisted.internet import defer, reac
 from stompest.config import StompConfig
 from stompest.async import Stomp
 
-user = os.getenv('STOMP_USER') or 'admin'
-password = os.getenv('STOMP_PASSWORD') or 'password'
-host = os.getenv('STOMP_HOST') or 'localhost'
-port = int(os.getenv('STOMP_PORT') or 61613)
+user = os.getenv('APOLLO_USER') or 'admin'
+password = os.getenv('APOLLO_PASSWORD') or 'password'
+host = os.getenv('APOLLO_HOST') or 'localhost'
+port = int(os.getenv('APOLLO_PORT') or 61613)
 destination = sys.argv[1:2] or ['/topic/event']
 destination = destination[0]
 

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/stompest/sync/listener.py
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/stompest/sync/listener.py?rev=1418046&r1=1418045&r2=1418046&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/stompest/sync/listener.py
(original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/stompest/sync/listener.py
Thu Dec  6 19:56:58 2012
@@ -22,10 +22,10 @@ import time
 from stompest.config import StompConfig
 from stompest.sync import Stomp
 
-user = os.getenv('STOMP_USER') or 'admin'
-password = os.getenv('STOMP_PASSWORD') or 'password'
-host = os.getenv('STOMP_HOST') or 'localhost'
-port = int(os.getenv('STOMP_PORT') or 61613)
+user = os.getenv('APOLLO_USER') or 'admin'
+password = os.getenv('APOLLO_PASSWORD') or 'password'
+host = os.getenv('APOLLO_HOST') or 'localhost'
+port = int(os.getenv('APOLLO_PORT') or 61613)
 destination = sys.argv[1:2] or ['/topic/event']
 destination = destination[0]
 

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/stompest/sync/publisher.py
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/stompest/sync/publisher.py?rev=1418046&r1=1418045&r2=1418046&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/stompest/sync/publisher.py
(original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/stompest/sync/publisher.py
Thu Dec  6 19:56:58 2012
@@ -22,10 +22,10 @@ import time
 from stompest.config import StompConfig
 from stompest.sync import Stomp
 
-user = os.getenv('STOMP_USER') or 'admin'
-password = os.getenv('STOMP_PASSWORD') or 'password'
-host = os.getenv('STOMP_HOST') or 'localhost'
-port = int(os.getenv('STOMP_PORT') or 61613)
+user = os.getenv('APOLLO_USER') or 'admin'
+password = os.getenv('APOLLO_PASSWORD') or 'password'
+host = os.getenv('APOLLO_HOST') or 'localhost'
+port = int(os.getenv('APOLLO_PORT') or 61613)
 destination = sys.argv[1:2] or ['/topic/event']
 destination = destination[0]
 

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/stomppy/listener.py
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/stomppy/listener.py?rev=1418046&r1=1418045&r2=1418046&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/stomppy/listener.py
(original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/stomppy/listener.py
Thu Dec  6 19:56:58 2012
@@ -21,10 +21,10 @@ import sys
 import os
 import stomp
 
-user = os.getenv("STOMP_USER") or "admin"
-password = os.getenv("STOMP_PASSWORD") or "password"
-host = os.getenv("STOMP_HOST") or "localhost"
-port = os.getenv("STOMP_PORT") or 61613
+user = os.getenv("APOLLO_USER") or "admin"
+password = os.getenv("APOLLO_PASSWORD") or "password"
+host = os.getenv("APOLLO_HOST") or "localhost"
+port = os.getenv("APOLLO_PORT") or 61613
 destination = sys.argv[1:2] or ["/topic/event"]
 destination = destination[0]
 

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/stomppy/publisher.py
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/stomppy/publisher.py?rev=1418046&r1=1418045&r2=1418046&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/stomppy/publisher.py
(original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/python/stomppy/publisher.py
Thu Dec  6 19:56:58 2012
@@ -21,10 +21,10 @@ import sys
 import os
 import stomp
 
-user = os.getenv("STOMP_USER") or "admin"
-password = os.getenv("STOMP_PASSWORD") or "password"
-host = os.getenv("STOMP_HOST") or "localhost"
-port = os.getenv("STOMP_PORT") or 61613
+user = os.getenv("APOLLO_USER") or "admin"
+password = os.getenv("APOLLO_PASSWORD") or "password"
+host = os.getenv("APOLLO_HOST") or "localhost"
+port = os.getenv("APOLLO_PORT") or 61613
 destination = sys.argv[1:2] or ["/topic/event"]
 destination = destination[0]
 

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/catstomp.rb
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/catstomp.rb?rev=1418046&r1=1418045&r2=1418046&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/catstomp.rb
(original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/catstomp.rb
Thu Dec  6 19:56:58 2012
@@ -18,10 +18,10 @@
 require 'rubygems'
 require 'stomp'
 
-user = ENV["STOMP_USER"] || "admin"
-password = ENV["STOMP_PASSWORD"] || "password"
-host = ENV["STOMP_HOST"] || "localhost"
-port = ENV["STOMP_PORT"] || 61613
+user = ENV["APOLLO_USER"] || "admin"
+password = ENV["APOLLO_PASSWORD"] || "password"
+host = ENV["APOLLO_HOST"] || "localhost"
+port = ENV["APOLLO_PORT"] || 61613
 destination = $*[0] || "/topic/event"
 
 begin

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/listener.rb
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/listener.rb?rev=1418046&r1=1418045&r2=1418046&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/listener.rb
(original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/listener.rb
Thu Dec  6 19:56:58 2012
@@ -19,10 +19,10 @@
 require 'rubygems'
 require 'stomp'
 
-user = ENV["STOMP_USER"] || "admin"
-password = ENV["STOMP_PASSWORD"] || "password"
-host = ENV["STOMP_HOST"] || "localhost"
-port = ENV["STOMP_PORT"] || 61613
+user = ENV["APOLLO_USER"] || "admin"
+password = ENV["APOLLO_PASSWORD"] || "password"
+host = ENV["APOLLO_HOST"] || "localhost"
+port = ENV["APOLLO_PORT"] || 61613
 destination = $*[0] || "/topic/event"
 
 conn = Stomp::Connection.open user, password, host, port, false 

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/publisher.rb
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/publisher.rb?rev=1418046&r1=1418045&r2=1418046&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/publisher.rb
(original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/publisher.rb
Thu Dec  6 19:56:58 2012
@@ -22,10 +22,10 @@ require 'stomp'
 messages = 10000
 size = 256
 
-user = ENV["STOMP_USER"] || "admin"
-password = ENV["STOMP_PASSWORD"] || "password"
-host = ENV["STOMP_HOST"] || "localhost"
-port = ENV["STOMP_PORT"] || 61613
+user = ENV["APOLLO_USER"] || "admin"
+password = ENV["APOLLO_PASSWORD"] || "password"
+host = ENV["APOLLO_HOST"] || "localhost"
+port = ENV["APOLLO_PORT"] || 61613
 destination = $*[0] || "/topic/event"
 
 conn = Stomp::Connection.open user, password, host, port, false 

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/stompcat.rb
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/stompcat.rb?rev=1418046&r1=1418045&r2=1418046&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/stompcat.rb
(original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/stomp/ruby/stompcat.rb
Thu Dec  6 19:56:58 2012
@@ -19,10 +19,10 @@
 require 'rubygems'
 require 'stomp'
 
-user = ENV["STOMP_USER"] || "admin"
-password = ENV["STOMP_PASSWORD"] || "password"
-host = ENV["STOMP_HOST"] || "localhost"
-port = ENV["STOMP_PORT"] || 61613
+user = ENV["APOLLO_USER"] || "admin"
+password = ENV["APOLLO_PASSWORD"] || "password"
+host = ENV["APOLLO_HOST"] || "localhost"
+port = ENV["APOLLO_PORT"] || 61613
 destination = $*[0] || "/topic/event"
 
 begin



Mime
View raw message