summaryrefslogtreecommitdiff
path: root/wcf/samples/Integration/Util/Options.cs
diff options
context:
space:
mode:
authorRajith Muditha Attapattu <rajith@apache.org>2011-05-27 15:44:23 +0000
committerRajith Muditha Attapattu <rajith@apache.org>2011-05-27 15:44:23 +0000
commit66765100f4257159622cefe57bed50125a5ad017 (patch)
treea88ee23bb194eb91f0ebb2d9b23ff423e3ea8e37 /wcf/samples/Integration/Util/Options.cs
parent1aeaa7b16e5ce54f10c901d75c4d40f9f88b9db6 (diff)
parent88b98b2f4152ef59a671fad55a0d08338b6b78ca (diff)
downloadqpid-python-rajith_jms_client.tar.gz
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
Diffstat (limited to 'wcf/samples/Integration/Util/Options.cs')
-rw-r--r--wcf/samples/Integration/Util/Options.cs157
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; }
- }
- }
-}