You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ch...@apache.org on 2010/11/30 22:24:44 UTC
svn commit: r1040778 -
/qpid/trunk/qpid/cpp/bindings/qpid/dotnet/examples/csharp.example.spout/csharp.example.spout.cs
Author: chug
Date: Tue Nov 30 21:24:44 2010
New Revision: 1040778
URL: http://svn.apache.org/viewvc?rev=1040778&view=rev
Log:
Ensure spout example waits for all messages to be sent before detaching session
see c++ spout fix r957513
Modified:
qpid/trunk/qpid/cpp/bindings/qpid/dotnet/examples/csharp.example.spout/csharp.example.spout.cs
Modified: qpid/trunk/qpid/cpp/bindings/qpid/dotnet/examples/csharp.example.spout/csharp.example.spout.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/bindings/qpid/dotnet/examples/csharp.example.spout/csharp.example.spout.cs?rev=1040778&r1=1040777&r2=1040778&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/bindings/qpid/dotnet/examples/csharp.example.spout/csharp.example.spout.cs (original)
+++ qpid/trunk/qpid/cpp/bindings/qpid/dotnet/examples/csharp.example.spout/csharp.example.spout.cs Tue Nov 30 21:24:44 2010
@@ -105,6 +105,7 @@ namespace Org.Apache.Qpid.Messaging.Exam
message.SetProperty("spout-id", spoutid);
sender.Send(message);
}
+ session.Sync();
connection.Close();
} catch (Exception e) {
Console.WriteLine("Exception {0}.", e);
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org