diff options
Diffstat (limited to 'wcf/samples/Integration/Util/Options.cs')
| -rw-r--r-- | wcf/samples/Integration/Util/Options.cs | 157 |
1 files changed, 0 insertions, 157 deletions
diff --git a/wcf/samples/Integration/Util/Options.cs b/wcf/samples/Integration/Util/Options.cs deleted file mode 100644 index a929f8f2de..0000000000 --- a/wcf/samples/Integration/Util/Options.cs +++ /dev/null @@ -1,157 +0,0 @@ -/*
-* 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; }
- }
- }
-}
|