1 files changed, 157 insertions, 0 deletions
diff --git a/qpid/wcf/samples/Integration/Util/Options.cs b/qpid/wcf/samples/Integration/Util/Options.cs
new file mode 100644
index 0000000000..a929f8f2de
--- /dev/null
+++ b/qpid/wcf/samples/Integration/Util/Options.cs
@@ -0,0 +1,157 @@
+/*
+* 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 Apache.Qpid.Samples.Integration
+{
+    using System;
+    using System.Collections;
+    using System.Collections.Generic;
+    using System.Diagnostics;
+    using System.IO;
+    using System.ServiceModel;
+    using System.ServiceModel.Channels;
+    using System.ServiceModel.Description;
+    using System.Text;
+    using System.Xml;
+
+    public class Options
+    {
+        private string broker;
+        private int port;
+        private int messageCount;
+        private EndpointAddress address;
+        private TimeSpan timeout;
+        private string content;
+
+        public Options(string[] args)
+        {
+            this.broker = "127.0.0.1";
+            this.port = 5672;
+            this.messageCount = 1;
+            this.timeout = TimeSpan.FromSeconds(0);
+            Parse(args);
+        }
+
+        private void Parse(string[] args)
+        {
+            int argCount = args.Length;
+            int current = 0;
+            bool typeSelected = false;
+
+            while ((current + 1) < argCount)
+            {
+                string arg = args[current];
+                if (arg == "--count")
+                {
+                    arg = args[++current];
+                    int i = Int32.Parse(arg);
+                    if (i >= 0)
+                    {
+                        this.messageCount = i;
+                    }
+                }
+                else if (arg == "--broker")
+                {
+                    this.broker = args[++current];
+                }
+                else if (arg == "--port")
+                {
+                    arg = args[++current];
+                    int i = int.Parse(arg);
+                    if (i > 0)
+                    {
+                        this.port = i;
+                    }
+                }
+                else if (arg == "--timeout")
+                {
+                    arg = args[++current];
+                    int i = int.Parse(arg);
+                    if (i > 0)
+                    {
+                        this.timeout = TimeSpan.FromSeconds(i);
+                    }
+                }
+
+                else if (arg == "--content")
+                {
+                    this.content = args[++current];
+                }
+
+                else
+                {
+                    throw new ArgumentException(String.Format("unknown argument \"{0}\"", arg));
+                }
+
+                current++;
+            }
+
+            if (current == argCount)
+            {
+                throw new ArgumentException("missing argument: address");
+            }
+
+            address = new EndpointAddress("amqp:" + args[current]);
+
+            if (timeout < TimeSpan.FromMilliseconds(100))
+            {
+                // WCF timeout of 0 really means no time for even a single message transfer
+                timeout = TimeSpan.FromMilliseconds(100);
+            }
+        }
+
+        public EndpointAddress Address
+        {
+            get { return this.address; }
+        }
+
+        public string Broker
+        {
+            get { return this.broker; }
+        }
+
+        public string Content
+        {
+            get
+            {
+                if (content == null)
+                {
+                    return String.Empty;
+                }
+                return content;
+            }
+        }
+
+
+        public int Count
+        {
+            get { return this.messageCount; }
+        }
+
+        public int Port
+        {
+            get { return this.port; }
+        }
+
+        public TimeSpan Timeout
+        {
+            get { return this.timeout; }
+        }
+    }
+}