summaryrefslogtreecommitdiff
path: root/cpp/bindings/qpid/dotnet/examples/csharp.example.spout/csharp.example.spout.cs
diff options
context:
space:
mode:
authorCharles E. Rolke <chug@apache.org>2010-12-01 19:54:13 +0000
committerCharles E. Rolke <chug@apache.org>2010-12-01 19:54:13 +0000
commita3ec0c3d16162606321c7f89e4ef78bccd0a12a0 (patch)
tree32954a6a92d7a1d9a984020bbd55100d283619aa /cpp/bindings/qpid/dotnet/examples/csharp.example.spout/csharp.example.spout.cs
parente5ddc402681322fc0031b3d2bc39b1d75e8a1080 (diff)
downloadqpid-python-a3ec0c3d16162606321c7f89e4ef78bccd0a12a0.tar.gz
Bring QPID .NET Binding examples more in line with cpp examples.
1. Return 0/1 from main to indicate success/failure, where possible. 2. Call sender's session.Sync() after transmitting messages and not waiting for responses. 3. Add third arg connectionOptions as used in cpp examples. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1041141 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/bindings/qpid/dotnet/examples/csharp.example.spout/csharp.example.spout.cs')
-rw-r--r--cpp/bindings/qpid/dotnet/examples/csharp.example.spout/csharp.example.spout.cs6
1 files changed, 4 insertions, 2 deletions
diff --git a/cpp/bindings/qpid/dotnet/examples/csharp.example.spout/csharp.example.spout.cs b/cpp/bindings/qpid/dotnet/examples/csharp.example.spout/csharp.example.spout.cs
index 830e943705..531abadd4c 100644
--- a/cpp/bindings/qpid/dotnet/examples/csharp.example.spout/csharp.example.spout.cs
+++ b/cpp/bindings/qpid/dotnet/examples/csharp.example.spout/csharp.example.spout.cs
@@ -63,13 +63,13 @@ namespace Org.Apache.Qpid.Messaging.Examples {
}
}
- static void Main(string[] args) {
+ static int Main(string[] args) {
Options options = new Options(args);
Connection connection = null;
try
{
- connection = new Connection(options.Url);
+ connection = new Connection(options.Url, options.ConnectionOptions);
connection.Open();
Session session = connection.CreateSession();
Sender sender = session.CreateSender(options.Address);
@@ -107,11 +107,13 @@ namespace Org.Apache.Qpid.Messaging.Examples {
}
session.Sync();
connection.Close();
+ return 0;
} catch (Exception e) {
Console.WriteLine("Exception {0}.", e);
if (null != connection)
connection.Close();
}
+ return 1;
}
}
}