diff options
| author | Charles E. Rolke <chug@apache.org> | 2010-12-01 19:54:13 +0000 |
|---|---|---|
| committer | Charles E. Rolke <chug@apache.org> | 2010-12-01 19:54:13 +0000 |
| commit | a3ec0c3d16162606321c7f89e4ef78bccd0a12a0 (patch) | |
| tree | 32954a6a92d7a1d9a984020bbd55100d283619aa /cpp/bindings/qpid/dotnet/examples/csharp.example.server/csharp.example.server.cs | |
| parent | e5ddc402681322fc0031b3d2bc39b1d75e8a1080 (diff) | |
| download | qpid-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.server/csharp.example.server.cs')
| -rw-r--r-- | cpp/bindings/qpid/dotnet/examples/csharp.example.server/csharp.example.server.cs | 11 |
1 files changed, 8 insertions, 3 deletions
diff --git a/cpp/bindings/qpid/dotnet/examples/csharp.example.server/csharp.example.server.cs b/cpp/bindings/qpid/dotnet/examples/csharp.example.server/csharp.example.server.cs index 4ec56491ac..1d93649195 100644 --- a/cpp/bindings/qpid/dotnet/examples/csharp.example.server/csharp.example.server.cs +++ b/cpp/bindings/qpid/dotnet/examples/csharp.example.server/csharp.example.server.cs @@ -24,14 +24,18 @@ using Org.Apache.Qpid.Messaging; namespace Org.Apache.Qpid.Messaging.Examples {
class Server {
- static void Main(string[] args) {
- String url = "amqp:tcp:127.0.0.1:5672";
+ static int Main(string[] args) {
+ string url = "amqp:tcp:127.0.0.1:5672";
+ string connectionOptions = "";
if (args.Length > 0)
url = args[0];
+ // address args[1] is not used in this example
+ if (args.Length > 2)
+ connectionOptions = args[2];
try {
- Connection connection = new Connection(url);
+ Connection connection = new Connection(url, connectionOptions);
connection.Open();
Session session = connection.CreateSession();
Receiver receiver = session.CreateReceiver("service_queue; {create: always}");
@@ -56,6 +60,7 @@ namespace Org.Apache.Qpid.Messaging.Examples { } catch (Exception e) {
Console.WriteLine("Exception {0}.", e);
}
+ return 1;
}
}
}
|
