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:[email protected]
