1 files changed, 79 insertions, 0 deletions
diff --git a/qpid/cpp/bindings/qpid/dotnet/examples/csharp.direct.receiver/csharp.direct.receiver.cs b/qpid/cpp/bindings/qpid/dotnet/examples/csharp.direct.receiver/csharp.direct.receiver.cs
new file mode 100644
index 0000000000..592a05ab29
--- /dev/null
+++ b/qpid/cpp/bindings/qpid/dotnet/examples/csharp.direct.receiver/csharp.direct.receiver.cs
@@ -0,0 +1,79 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+
+using System;
+using Org.Apache.Qpid.Messaging;
+
+namespace CSharpDirect
+{
+    class Program
+    {
+        // Direct receiver example
+        //
+        // Receive 10 messages from localhost:5672, amq.direct/key
+        // Messages are assumed to be printable strings.
+        //
+        static int Main(string[] args)
+        {
+            String host = "localhost:5672";
+            String addr = "amq.direct/key";
+            Int32 nMsg = 10;
+
+            if (args.Length > 0)
+                host = args[0];
+            if (args.Length > 1)
+                addr = args[1];
+            if (args.Length > 2)
+                nMsg = Convert.ToInt32(args[2]);
+
+            Console.WriteLine("csharp.direct.receiver");
+            Console.WriteLine("host : {0}", host);
+            Console.WriteLine("addr : {0}", addr);
+            Console.WriteLine("nMsg : {0}", nMsg);
+            Console.WriteLine();
+
+            Connection connection = null;
+            try
+            {
+                connection = new Connection(host);
+                connection.Open();
+                if (!connection.IsOpen) {
+                    Console.WriteLine("Failed to open connection to host : {0}", host);
+                } else {
+                    Session session = connection.CreateSession();
+                    Receiver receiver = session.CreateReceiver(addr);
+                    Message message = new Message("");
+                    for (int i = 0; i < nMsg; i++) {
+                        Message msg2 = receiver.Fetch(DurationConstants.FORVER);
+                        Console.WriteLine("Rcvd msg {0} : {1}", i, msg2.GetContent());
+                    }
+                    connection.Close();
+                    return 0;
+                }
+            } catch (Exception e) {
+                Console.WriteLine("Exception {0}.", e);
+                if (null != connection)
+                    connection.Close();
+            }
+            return 1;
+        }
+    }
+}
+\ No newline at end of file