You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gs...@apache.org on 2010/06/24 13:34:19 UTC
svn commit: r957513 - /qpid/trunk/qpid/cpp/examples/messaging/spout.cpp
Author: gsim
Date: Thu Jun 24 11:34:18 2010
New Revision: 957513
URL: http://svn.apache.org/viewvc?rev=957513&view=rev
Log:
Ensure spout example waits for all messages to be sent before detaching session
Modified:
qpid/trunk/qpid/cpp/examples/messaging/spout.cpp
Modified: qpid/trunk/qpid/cpp/examples/messaging/spout.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/examples/messaging/spout.cpp?rev=957513&r1=957512&r2=957513&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/examples/messaging/spout.cpp (original)
+++ qpid/trunk/qpid/cpp/examples/messaging/spout.cpp Thu Jun 24 11:34:18 2010
@@ -161,6 +161,7 @@ int main(int argc, char** argv)
message.getProperties()["spout-id"] = spoutid.str();
sender.send(message);
}
+ session.sync();
connection.close();
return 0;
} catch(const std::exception& error) {
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org