summaryrefslogtreecommitdiff
path: root/cpp/examples/failover
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2008-10-22 13:09:33 +0000
committerAlan Conway <aconway@apache.org>2008-10-22 13:09:33 +0000
commit4c0c417d63b96e910925a343d63bde5481ba5698 (patch)
tree871d4ca75a1b174254237d5902b4b6127f0203fc /cpp/examples/failover
parent6785c87631086d7c3720e8a1b54228207f68b283 (diff)
downloadqpid-python-4c0c417d63b96e910925a343d63bde5481ba5698.tar.gz
QPID-1382 from Mick Goulish: Improvement to Client-Side Cluster Failover code
Also: Fix missing DispatchHandle.h include in sys/PollableQueue.h Added ignore properties for failover example binaries & Makefile. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@707065 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/examples/failover')
-rw-r--r--cpp/examples/failover/direct_producer.cpp6
-rw-r--r--cpp/examples/failover/listener.cpp2
2 files changed, 6 insertions, 2 deletions
diff --git a/cpp/examples/failover/direct_producer.cpp b/cpp/examples/failover/direct_producer.cpp
index 513971197e..2a0104a994 100644
--- a/cpp/examples/failover/direct_producer.cpp
+++ b/cpp/examples/failover/direct_producer.cpp
@@ -60,6 +60,8 @@ main ( int argc, char ** argv)
if ( count > 1000 )
report = !(sent % 1000);
+ report = false;
+
if ( report )
{
std::cout << "sending message "
@@ -71,7 +73,7 @@ main ( int argc, char ** argv)
message_data << sent;
message.setData(message_data.str());
- /* MICK FIXME
+ /* FIXME mgoulish 21 oct 08
session.messageTransfer ( arg::content=message,
arg::destination="amq.direct"
); */
@@ -85,7 +87,7 @@ main ( int argc, char ** argv)
}
message.setData ( "That's all, folks!" );
- /* FIXME mgoulish 16 Oct 08
+ /* FIXME mgoulish 21 oct 08
session.messageTransfer ( arg::content=message,
arg::destination="amq.direct"
);
diff --git a/cpp/examples/failover/listener.cpp b/cpp/examples/failover/listener.cpp
index d8cb78c9ce..82913a521a 100644
--- a/cpp/examples/failover/listener.cpp
+++ b/cpp/examples/failover/listener.cpp
@@ -64,8 +64,10 @@ Listener::Listener ( FailoverSubscriptionManager & s ) :
void
Listener::received ( Message & message )
{
+ /*
if(! (count%1000))
std::cerr << "\t\tListener received: " << message.getData() << std::endl;
+ * */
++ count;