Creating a branch for experimenting with some ideas for JMS client.rajith_jms_client

git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/rajith_jms_client@1128369 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 55 insertions, 0 deletions

diff --git a/qpid/cpp/bindings/qpid/dotnet/examples/csharp.example.helloworld/csharp.example.helloworld.cs b/qpid/cpp/bindings/qpid/dotnet/examples/csharp.example.helloworld/csharp.example.helloworld.cs
new file mode 100644
index 0000000000..336970a3ba
--- /dev/null
+++ b/qpid/cpp/bindings/qpid/dotnet/examples/csharp.example.helloworld/csharp.example.helloworld.cs
@@ -0,0 +1,55 @@
+/*

+ *

+ * 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 Org.Apache.Qpid.Messaging {

+    class Program {

+        static void Main(string[] args) {

+            String broker = args.Length > 0 ? args[0] : "localhost:5672";

+            String address = args.Length > 1 ? args[1] : "amq.topic";

+

+            Connection connection = null;

+            try {

+                connection = new Connection(broker);

+                connection.Open();

+                Session session = connection.CreateSession();

+

+                Receiver receiver = session.CreateReceiver(address);

+                Sender sender = session.CreateSender(address);

+

+                sender.Send(new Message("Hello world!"));

+

+                Message message = new Message();

+                message = receiver.Fetch(DurationConstants.SECOND * 1);

+                Console.WriteLine("{0}", message.GetContent());

+                session.Acknowledge();

+

+                connection.Close();

+            } catch (Exception e) {

+                Console.WriteLine("Exception {0}.", e);

+                if (null != connection)

+                    connection.Close();

+            }

+        }

+    }

+}