QPID-2589 - Patch from Chuck Rolke

More API cleanup and new examples (to match the examples for other languages)

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

4 files changed, 424 insertions, 0 deletions

diff --git a/cpp/bindings/qpid/dotnet/examples/csharp.example.spout/Options.cs b/cpp/bindings/qpid/dotnet/examples/csharp.example.spout/Options.cs
new file mode 100644
index 0000000000..be55c1e0d4
--- /dev/null
+++ b/cpp/bindings/qpid/dotnet/examples/csharp.example.spout/Options.cs
@@ -0,0 +1,189 @@
+/*

+* 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.

+*/

+

+namespace Org.Apache.Qpid.Messaging.Examples

+{

+    using System;

+    using System.Collections;

+    using System.Collections.Generic;

+    using System.Collections.ObjectModel;

+    using System.Diagnostics;

+    using System.IO;

+    using System.Text;

+    using System.Xml;

+

+    public class Options

+    {

+        private string url;

+        private string address;

+        private int timeout;

+        private int count;

+        private string id;

+        private string replyTo;

+        private Collection<string> properties;

+        private Collection<string> entries;

+        private string content;

+        private string connectionOptions;

+        private bool forever;

+

+        public Options(string[] args)

+        {

+            this.url = "amqp:tcp:127.0.0.1:5672";

+            this.address = "";

+            this.timeout = 0;

+            this.count = 1;

+            this.id = "";

+            this.replyTo = "";

+            properties = new Collection<string>();

+            entries = new Collection<string>();

+            this.content = "";

+            this.connectionOptions = "";

+            this.forever = false;

+            Parse(args);

+        }

+

+        private void Parse(string[] args)

+        {

+            int argCount = args.Length;

+            int current = 0;

+

+            while ((current + 1) < argCount)

+            {

+                string arg = args[current];

+                if (arg == "--broker")

+                {

+                    this.url = args[++current];

+                }

+                else if (arg == "--address")

+                {

+                    this.address = args[++current];

+                }

+                else if (arg == "--timeout")

+                {

+                    arg = args[++current];

+                    int i = int.Parse(arg);

+                    if (i >= 0)

+                    {

+                        this.timeout = i;

+                    }

+                }

+                else if (arg == "--count")

+                {

+                    arg = args[++current];

+                    int i = int.Parse(arg);

+                    if (i >= 0)

+                    {

+                        this.count = i;

+                    }

+                }

+                else if (arg == "--id")

+                {

+                    this.id = args[++current];

+                }

+                else if (arg == "--reply-to")

+                {

+                    this.replyTo = args[++current];

+                }

+                else if (arg == "--properties")

+                {

+                    this.properties.Add(args[++current]);

+                }

+                else if (arg == "--map")

+                {

+                    this.entries.Add(args[++current]);

+                }

+                else if (arg == "--content")

+                {

+                    this.content = args[++current];

+                }

+                else if (arg == "--connection-options")

+                {

+                    this.connectionOptions = args[++current];

+                }

+                else if (arg == "--forever")

+                {

+                    this.forever = true;

+                }

+                else

+                {

+                    throw new ArgumentException(String.Format("unknown argument \"{0}\"", arg));

+                }

+

+                current++;

+            }

+

+            if (current == argCount)

+            {

+                throw new ArgumentException("missing argument: address");

+            }

+

+            address = args[current];

+        }

+

+        public string Url

+        {

+            get { return this.url; }

+        }

+

+        public string Address

+        {

+            get { return this.address; }

+        }

+

+        public int Timeout

+        {

+            get { return this.timeout; }

+        }

+

+        public int Count

+        {

+            get { return this.count; }

+        }

+

+        public string Id

+        {

+            get { return this.id; }

+        }

+

+        public string ReplyTo

+        {

+            get { return this.replyTo; }

+        }

+

+        public Collection<string> Entries

+        {

+            get { return this.entries; }

+        }

+

+        public string Content

+        {

+            get { return content; }

+        }

+

+        public string ConnectionOptions

+        {

+            get { return this.connectionOptions; }

+        }

+

+        public bool Forever

+        {

+            get { return this.forever; }

+        }

+    }

+}

diff --git a/cpp/bindings/qpid/dotnet/examples/csharp.example.spout/Properties/AssemblyInfo.cs b/cpp/bindings/qpid/dotnet/examples/csharp.example.spout/Properties/AssemblyInfo.cs
new file mode 100644
index 0000000000..95433e4489
--- /dev/null
+++ b/cpp/bindings/qpid/dotnet/examples/csharp.example.spout/Properties/AssemblyInfo.cs
@@ -0,0 +1,36 @@
+using System.Reflection;

+using System.Runtime.CompilerServices;

+using System.Runtime.InteropServices;

+

+// General Information about an assembly is controlled through the following 

+// set of attributes. Change these attribute values to modify the information

+// associated with an assembly.

+[assembly: AssemblyTitle("csharp.direct.receiver")]

+[assembly: AssemblyDescription("")]

+[assembly: AssemblyConfiguration("")]

+[assembly: AssemblyCompany("")]

+[assembly: AssemblyProduct("csharp.direct.receiver")]

+[assembly: AssemblyCopyright("Copyright ?  2010")]

+[assembly: AssemblyTrademark("")]

+[assembly: AssemblyCulture("")]

+

+// Setting ComVisible to false makes the types in this assembly not visible 

+// to COM components.  If you need to access a type in this assembly from 

+// COM, set the ComVisible attribute to true on that type.

+[assembly: ComVisible(false)]

+

+// The following GUID is for the ID of the typelib if this project is exposed to COM

+[assembly: Guid("c60b17ab-a82c-4edf-ba95-1e88bd4c3e75")]

+

+// Version information for an assembly consists of the following four values:

+//

+//      Major Version

+//      Minor Version 

+//      Build Number

+//      Revision

+//

+// You can specify all the values or you can default the Build and Revision Numbers 

+// by using the '*' as shown below:

+// [assembly: AssemblyVersion("1.0.*")]

+[assembly: AssemblyVersion("1.0.0.0")]

+[assembly: AssemblyFileVersion("1.0.0.0")]

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
new file mode 100644
index 0000000000..7eeece3194
--- /dev/null
+++ b/cpp/bindings/qpid/dotnet/examples/csharp.example.spout/csharp.example.spout.cs
@@ -0,0 +1,117 @@
+/*

+ *

+ * 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 System.Diagnostics;

+using System.Collections;

+using System.Collections.Generic;

+using System.Collections.ObjectModel;

+using Org.Apache.Qpid.Messaging;

+

+namespace Org.Apache.Qpid.Messaging.Examples {

+    class Spout {

+        //

+        // Sample invocation: csharp.example.drain.exe --broker localhost:5672 --timeout 30 my-queue

+        // This pro

+        static bool NameVal(string In, out string nameOut, out string valueOut)

+        {

+            int pos = In.IndexOf("=");

+            if (-1 == pos) {

+                nameOut = In;

+                valueOut = "";

+                return false;

+            } else {

+                nameOut = In.Substring(0, pos);

+                if (pos + 1 < In.Length) {

+                    valueOut = In.Substring(pos + 1);

+                    return true;

+                } else {

+                    valueOut = "";

+                    return false;

+                }

+            }

+        }

+

+        static void SetEntries(Collection<string> entries, Dictionary<string, object> content)

+        {

+            foreach (String entry in entries)

+            {

+                string name = "";

+                string value = "";

+                if (NameVal(entry, out name, out value))

+                    content.Add(name, value);

+                else

+                    content.Add(name, "");

+            }

+        }

+

+        static void Main(string[] args) {

+            Options options = new Options(args);

+

+            Connection connection = null;

+            try

+            {

+                connection = new Connection(options.Url);

+                connection.Open();

+                Session session = connection.CreateSession();

+                Sender sender = session.CreateSender(options.Address);

+                Message message;

+                if (options.Entries.Count > 0)

+                {

+                    Dictionary<string, object> content = new Dictionary<string, object>();

+                    SetEntries(options.Entries, content);

+                    message = new Message(content);

+                }

+                else

+                {

+                    message = new Message(options.Content);

+                    message.SetContentType("text/plain");

+                }

+                Address replyToAddr = new Address(options.ReplyTo);

+

+                Stopwatch stopwatch = new Stopwatch();

+                TimeSpan timespan = new TimeSpan(0,0,options.Timeout);

+                stopwatch.Start();

+                for (int count = 0;

+                    (0 == options.Count || count < options.Count) &&

+                    (0 == options.Timeout || stopwatch.Elapsed <= timespan);

+                    count++) 

+                {

+                    if ("" != options.ReplyTo) message.SetReplyTo(replyToAddr);

+                    string id = options.Id ;

+                    if ("" == id) {

+                        Guid g = Guid.NewGuid();

+                        id = g.ToString();

+                    }

+                    string spoutid = id + ":" + count;

+                    message.SetProperty("spout-id", spoutid);

+                    sender.Send(message);

+                }

+                connection.Close();

+            } catch (Exception e) {

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

+                if (null != connection)

+                    connection.Close();

+            }

+        }

+    }

+}

+

diff --git a/cpp/bindings/qpid/dotnet/examples/csharp.example.spout/csharp.example.spout.csproj b/cpp/bindings/qpid/dotnet/examples/csharp.example.spout/csharp.example.spout.csproj
new file mode 100644
index 0000000000..15fc644c8c
--- /dev/null
+++ b/cpp/bindings/qpid/dotnet/examples/csharp.example.spout/csharp.example.spout.csproj
@@ -0,0 +1,82 @@
+<?xml version="1.0" encoding="utf-8"?>

+<Project ToolsVersion="3.5" DefaultTargets="Build" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">

+  <PropertyGroup>

+    <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration>

+    <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform>

+    <ProductVersion>9.0.21022</ProductVersion>

+    <SchemaVersion>2.0</SchemaVersion>

+    <ProjectGuid>{EB36626D-36C2-41B3-B65E-762BAF27F137}</ProjectGuid>

+    <OutputType>Exe</OutputType>

+    <AppDesignerFolder>Properties</AppDesignerFolder>

+    <RootNamespace>csharp.example.spout</RootNamespace>

+    <AssemblyName>csharp.example.spout</AssemblyName>

+    <TargetFrameworkVersion>v3.5</TargetFrameworkVersion>

+    <FileAlignment>512</FileAlignment>

+  </PropertyGroup>

+  <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' ">

+    <DebugSymbols>true</DebugSymbols>

+    <DebugType>full</DebugType>

+    <Optimize>false</Optimize>

+    <OutputPath>..\..\..\..\..\src\Debug\</OutputPath>

+    <DefineConstants>DEBUG;TRACE</DefineConstants>

+    <ErrorReport>prompt</ErrorReport>

+    <WarningLevel>4</WarningLevel>

+  </PropertyGroup>

+  <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' ">

+    <DebugType>pdbonly</DebugType>

+    <Optimize>true</Optimize>

+    <OutputPath>..\..\..\..\..\src\Release\</OutputPath>

+    <DefineConstants>TRACE</DefineConstants>

+    <ErrorReport>prompt</ErrorReport>

+    <WarningLevel>4</WarningLevel>

+  </PropertyGroup>

+  <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|x86' ">

+    <DebugSymbols>true</DebugSymbols>

+    <OutputPath>..\..\..\..\..\src\Debug\</OutputPath>

+    <DefineConstants>DEBUG;TRACE</DefineConstants>

+    <DebugType>full</DebugType>

+    <PlatformTarget>x86</PlatformTarget>

+    <ErrorReport>prompt</ErrorReport>

+  </PropertyGroup>

+  <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|x86' ">

+    <OutputPath>..\..\..\..\..\src\Release\</OutputPath>

+    <DefineConstants>TRACE</DefineConstants>

+    <Optimize>true</Optimize>

+    <DebugType>pdbonly</DebugType>

+    <PlatformTarget>x86</PlatformTarget>

+    <ErrorReport>prompt</ErrorReport>

+  </PropertyGroup>

+  <ItemGroup>

+    <Reference Include="System" />

+    <Reference Include="System.Core">

+      <RequiredTargetFramework>3.5</RequiredTargetFramework>

+    </Reference>

+    <Reference Include="System.Xml.Linq">

+      <RequiredTargetFramework>3.5</RequiredTargetFramework>

+    </Reference>

+    <Reference Include="System.Data.DataSetExtensions">

+      <RequiredTargetFramework>3.5</RequiredTargetFramework>

+    </Reference>

+    <Reference Include="System.Data" />

+    <Reference Include="System.Xml" />

+  </ItemGroup>

+  <ItemGroup>

+    <Compile Include="csharp.example.spout.cs" />

+    <Compile Include="Options.cs" />

+    <Compile Include="Properties\AssemblyInfo.cs" />

+  </ItemGroup>

+  <ItemGroup>

+    <ProjectReference Include="..\..\src\org.apache.qpid.messaging.vcproj">

+      <Project>{AA5A3B83-5F98-406D-A01C-5A921467A57D}</Project>

+      <Name>Org.Apache.Qpid.Messaging</Name>

+    </ProjectReference>

+  </ItemGroup>

+  <Import Project="$(MSBuildToolsPath)\Microsoft.CSharp.targets" />

+  <!-- To modify your build process, add your task inside one of the targets below and uncomment it. 

+       Other similar extension points exist, see Microsoft.Common.targets.

+  <Target Name="BeforeBuild">

+  </Target>

+  <Target Name="AfterBuild">

+  </Target>

+  -->

+</Project>