activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r1088770 - in /activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples: cpp/ csharp/ApolloExamples/Listener/ java/src/main/java/example/ perl/ php/ python/ ruby/
Date Mon, 04 Apr 2011 20:13:22 GMT
Author: chirino
Date: Mon Apr  4 20:13:21 2011
New Revision: 1088770

URL: http://svn.apache.org/viewvc?rev=1088770&view=rev
Log:
Fixes AMQ-3265 : Added a "Waiting for messages..." console message to all the listener examples.

Modified:
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/cpp/Listener.cpp
    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/java/src/main/java/example/Listener.java
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/perl/listener
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/php/listener.php
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/python/listener.py
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/ruby/listener.rb

Modified: 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/cpp/Listener.cpp?rev=1088770&r1=1088769&r2=1088770&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/cpp/Listener.cpp
(original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/cpp/Listener.cpp
Mon Apr  4 20:13:21 2011
@@ -87,6 +87,7 @@ int main(int argc AMQCPP_UNUSED, char* a
         long long start = System::currentTimeMillis();
         long long count = 0;
 
+        std::cout << "Waiting for messages..." << std::endl;
         while(true) {
 
             std::auto_ptr<Message> message(consumer->receive());

Modified: 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/csharp/ApolloExamples/Listener/Listener.cs?rev=1088770&r1=1088769&r2=1088770&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/Listener/Listener.cs
(original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/csharp/ApolloExamples/Listener/Listener.cs
Mon Apr  4 20:13:21 2011
@@ -46,6 +46,7 @@ namespace Apollo.Example
 	        DateTime start = DateTime.Now;
 	        long count = 0;
 	        
+			Console.WriteLine("Waiting for messages...");
 			while (true) 
 			{
 	            IMessage msg = consumer.Receive();

Modified: 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/java/src/main/java/example/Listener.java?rev=1088770&r1=1088769&r2=1088770&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/java/src/main/java/example/Listener.java
(original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/java/src/main/java/example/Listener.java
Mon Apr  4 20:13:21 2011
@@ -42,6 +42,7 @@ class Listener {
         MessageConsumer consumer = session.createConsumer(dest);
         long start = System.currentTimeMillis();
         long count = 0;
+        System.out.println("Waiting for messages...");
         while(true) {
             Message msg = consumer.receive();
             if( msg instanceof  TextMessage ) {

Modified: 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/perl/listener?rev=1088770&r1=1088769&r2=1088770&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/perl/listener (original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/perl/listener Mon
Apr  4 20:13:21 2011
@@ -54,7 +54,7 @@ $Conn->subscribe(
     id          => 0,
     ack         => "auto",
 );
-printf("subscribed to %s\n", $Option{destination});
+printf("Waiting for messages...\n");
 $Count = 0;
 $Run = 1;
 $Conn->wait_for_frames() while $Run;

Modified: 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/php/listener.php?rev=1088770&r1=1088769&r2=1088770&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/php/listener.php
(original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/php/listener.php
Mon Apr  4 20:13:21 2011
@@ -43,6 +43,7 @@ try {
   
   $start = now();
   $count = 0;
+  echo "Waiting for messages...\n";
   while(true) {
     $frame = $stomp->readFrame();
     if( $frame ) {

Modified: 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/python/listener.py?rev=1088770&r1=1088769&r2=1088770&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/python/listener.py
(original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/python/listener.py
Mon Apr  4 20:13:21 2011
@@ -58,3 +58,4 @@ conn.set_listener('', MyListener(conn))
 conn.start()
 conn.connect(login=user,passcode=password)
 conn.subscribe(destination=destination, ack='auto')
+print("Waiting for messages...")

Modified: 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/ruby/listener.rb?rev=1088770&r1=1088769&r2=1088770&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/ruby/listener.rb
(original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/ruby/listener.rb
Mon Apr  4 20:13:21 2011
@@ -30,6 +30,7 @@ count = 0
 
 conn.subscribe destination, { :ack =>"auto" }
 start = Time.now
+$stdout.print "Waiting for messages...\n"
 while true 
 	msg = conn.receive
 	if msg.command == "MESSAGE" 



Mime
View raw message