NO-JIRA: update hello world example to use recommended api for content manipulation

Mirrors C++ example URL: http://svn.apache.org/r1693139

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

1 files changed, 56 insertions, 55 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
index 336970a3ba..200d7f0ef3 100644
--- 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
@@ -1,55 +1,56 @@
-/*

- *

- * 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();

-            }

-        }

-    }

-}

+/*
+ *
+ * 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);
+
+                Message message = new Message();
+                message.SetContentObject("Hello world!"); // all strings are utf-8 encoded
+                sender.Send(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();
+            }
+        }
+    }
+}