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"
