diff options
| author | Clifford Jansen <cliffjansen@apache.org> | 2010-10-24 23:29:37 +0000 |
|---|---|---|
| committer | Clifford Jansen <cliffjansen@apache.org> | 2010-10-24 23:29:37 +0000 |
| commit | a12c4390e7cc013aff09a36e088dc25f5875a37f (patch) | |
| tree | 8247dc2f83ef66f797b16301fe2fb5a16cf04f46 /wcf/samples | |
| parent | 60a01928e4c58fe32c53b6a42a729833aec205cd (diff) | |
| download | qpid-python-a12c4390e7cc013aff09a36e088dc25f5875a37f.tar.gz | |
QPID-2646 patches
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1026915 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'wcf/samples')
| -rw-r--r-- | wcf/samples/Integration/Drain/Drain.cs | 146 | ||||
| -rw-r--r-- | wcf/samples/Integration/Drain/Drain.csproj | 80 | ||||
| -rw-r--r-- | wcf/samples/Integration/Integration.sln | 46 | ||||
| -rw-r--r-- | wcf/samples/Integration/Spout/Spout.cs | 109 | ||||
| -rw-r--r-- | wcf/samples/Integration/Spout/Spout.csproj | 81 | ||||
| -rw-r--r-- | wcf/samples/Integration/Util/Options.cs | 157 |
6 files changed, 619 insertions, 0 deletions
diff --git a/wcf/samples/Integration/Drain/Drain.cs b/wcf/samples/Integration/Drain/Drain.cs new file mode 100644 index 0000000000..7a88494458 --- /dev/null +++ b/wcf/samples/Integration/Drain/Drain.cs @@ -0,0 +1,146 @@ +/*
+* 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;
+ using Apache.Qpid.Channel;
+ using Apache.Qpid.AmqpTypes;
+
+ class Drain
+ {
+ // delimit multiple values
+ private static void Append(StringBuilder sb, string s)
+ {
+ if (sb.Length > 0)
+ {
+ sb.Append(", ");
+ }
+
+ sb.Append(s);
+ }
+
+ private static string MessagePropertiesAsString(AmqpProperties props)
+ {
+ StringBuilder sb = new StringBuilder();
+
+ if (props.PropertyMap != null)
+ {
+ foreach (KeyValuePair<string, AmqpType> kvp in props.PropertyMap)
+ {
+ string propval;
+ if (kvp.Value is AmqpString)
+ {
+ AmqpString amqps = (AmqpString)kvp.Value;
+ propval = amqps.Value;
+ }
+ else
+ {
+ propval = kvp.Value.ToString();
+ }
+
+ Append(sb, kvp.Key + ":" + propval);
+ }
+ }
+
+ return sb.ToString();
+ }
+
+ private static string MessageContentAsString(Message msg, AmqpProperties props)
+ {
+ // AmqpBinaryBinding provides message content as a single XML "Binary" element
+ XmlDictionaryReader reader = msg.GetReaderAtBodyContents();
+ while (!reader.HasValue)
+ {
+ reader.Read();
+ if (reader.EOF)
+ {
+ throw new InvalidDataException("empty reader for message");
+ }
+ }
+
+ byte[] rawdata = reader.ReadContentAsBase64();
+
+ string ct = props.ContentType;
+ if (ct != null)
+ {
+ if (ct.Equals("amqp/map"))
+ {
+ return "mapdata (coming soon)";
+ }
+ }
+
+ return Encoding.UTF8.GetString(rawdata);
+ }
+
+ static void Main(string[] args)
+ {
+ try
+ {
+ Options options = new Options(args);
+
+ AmqpBinaryBinding binding = new AmqpBinaryBinding();
+ binding.BrokerHost = options.Broker;
+ binding.BrokerPort = options.Port;
+ binding.TransferMode = TransferMode.Streamed;
+
+ IChannelFactory<IInputChannel> factory = binding.BuildChannelFactory<IInputChannel>();
+
+ factory.Open();
+ try
+ {
+ System.ServiceModel.EndpointAddress addr = options.Address;
+ IInputChannel receiver = factory.CreateChannel(addr);
+ receiver.Open();
+
+ TimeSpan timeout = options.Timeout;
+ System.ServiceModel.Channels.Message message;
+
+ while (receiver.TryReceive(timeout, out message))
+ {
+ AmqpProperties props = (AmqpProperties)message.Properties["AmqpProperties"];
+
+ Console.WriteLine("Message(properties=" +
+ MessagePropertiesAsString(props) +
+ ", content='" +
+ MessageContentAsString(message, props) +
+ "')");
+ }
+ }
+ finally
+ {
+ factory.Close();
+ }
+ }
+ catch (Exception e)
+ {
+ Console.WriteLine("Drain: " + e);
+ }
+ }
+ }
+}
diff --git a/wcf/samples/Integration/Drain/Drain.csproj b/wcf/samples/Integration/Drain/Drain.csproj new file mode 100644 index 0000000000..06c32f5064 --- /dev/null +++ b/wcf/samples/Integration/Drain/Drain.csproj @@ -0,0 +1,80 @@ +<?xml version="1.0" encoding="utf-8"?>
+<!--
+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.
+-->
+<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>{A67D9B60-34A5-462F-84A2-72C22F623749}</ProjectGuid>
+ <OutputType>Exe</OutputType>
+ <RootNamespace>Drain</RootNamespace>
+ <AssemblyName>Drain</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>bin\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>bin\Release\</OutputPath>
+ <DefineConstants>TRACE</DefineConstants>
+ <ErrorReport>prompt</ErrorReport>
+ <WarningLevel>4</WarningLevel>
+ </PropertyGroup>
+ <ItemGroup>
+ <Reference Include="Apache.Qpid.Channel, Version=1.0.0.0, Culture=neutral, PublicKeyToken=679e1f50b62dbace, processorArchitecture=MSIL">
+ <SpecificVersion>False</SpecificVersion>
+ <HintPath>..\..\..\src\Apache\Qpid\Channel\bin\Release\Apache.Qpid.Channel.dll</HintPath>
+ </Reference>
+ <Reference Include="Apache.Qpid.Interop, Version=1.0.3796.12140, Culture=neutral, PublicKeyToken=679e1f50b62dbace, processorArchitecture=AMD64">
+ <SpecificVersion>False</SpecificVersion>
+ <HintPath>..\..\..\src\Apache\Qpid\Channel\bin\Release\Apache.Qpid.Interop.dll</HintPath>
+ </Reference>
+ <Reference Include="System" />
+ <Reference Include="System.Runtime.Serialization">
+ <RequiredTargetFramework>3.0</RequiredTargetFramework>
+ </Reference>
+ <Reference Include="System.ServiceModel">
+ <RequiredTargetFramework>3.0</RequiredTargetFramework>
+ </Reference>
+ <Reference Include="System.Xml" />
+ </ItemGroup>
+ <ItemGroup>
+ <Compile Include="Drain.cs" />
+ <Compile Include="..\Util\Options.cs" />
+ </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>
diff --git a/wcf/samples/Integration/Integration.sln b/wcf/samples/Integration/Integration.sln new file mode 100644 index 0000000000..59b228e92a --- /dev/null +++ b/wcf/samples/Integration/Integration.sln @@ -0,0 +1,46 @@ +
+Microsoft Visual Studio Solution File, Format Version 10.00
+
+#
+# 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
+#
+# Visual Studio 2008
+
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Drain", "Drain\Drain.csproj", "{A67D9B60-34A5-462F-84A2-72C22F623749}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Spout", "Spout\Spout.csproj", "{347A531B-38DB-4848-9E4D-4E5E7F9C97E7}"
+EndProject
+Global
+ GlobalSection(SolutionConfigurationPlatforms) = preSolution
+ Debug|Any CPU = Debug|Any CPU
+ Release|Any CPU = Release|Any CPU
+ EndGlobalSection
+ GlobalSection(ProjectConfigurationPlatforms) = postSolution
+ {A67D9B60-34A5-462F-84A2-72C22F623749}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+ {A67D9B60-34A5-462F-84A2-72C22F623749}.Debug|Any CPU.Build.0 = Debug|Any CPU
+ {A67D9B60-34A5-462F-84A2-72C22F623749}.Release|Any CPU.ActiveCfg = Release|Any CPU
+ {A67D9B60-34A5-462F-84A2-72C22F623749}.Release|Any CPU.Build.0 = Release|Any CPU
+ {347A531B-38DB-4848-9E4D-4E5E7F9C97E7}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+ {347A531B-38DB-4848-9E4D-4E5E7F9C97E7}.Debug|Any CPU.Build.0 = Debug|Any CPU
+ {347A531B-38DB-4848-9E4D-4E5E7F9C97E7}.Release|Any CPU.ActiveCfg = Release|Any CPU
+ {347A531B-38DB-4848-9E4D-4E5E7F9C97E7}.Release|Any CPU.Build.0 = Release|Any CPU
+ EndGlobalSection
+ GlobalSection(SolutionProperties) = preSolution
+ HideSolutionNode = FALSE
+ EndGlobalSection
+EndGlobal
diff --git a/wcf/samples/Integration/Spout/Spout.cs b/wcf/samples/Integration/Spout/Spout.cs new file mode 100644 index 0000000000..651566fbd6 --- /dev/null +++ b/wcf/samples/Integration/Spout/Spout.cs @@ -0,0 +1,109 @@ +/*
+* 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;
+ using Apache.Qpid.Channel;
+ using Apache.Qpid.AmqpTypes;
+
+ class Spout
+ {
+ static void Main(string[] args)
+ {
+ try
+ {
+ Options options = new Options(args);
+
+ AmqpBinaryBinding binding = new AmqpBinaryBinding();
+ binding.BrokerHost = options.Broker;
+ binding.BrokerPort = options.Port;
+ binding.TransferMode = TransferMode.Streamed;
+
+ IChannelFactory<IOutputChannel> factory = binding.BuildChannelFactory<IOutputChannel>();
+
+ factory.Open();
+ try
+ {
+ System.ServiceModel.EndpointAddress addr = options.Address;
+ IOutputChannel sender = factory.CreateChannel(addr);
+ sender.Open();
+
+ MyRawBodyWriter.Initialize(options.Content);
+ DateTime end = DateTime.Now.Add(options.Timeout);
+ System.ServiceModel.Channels.Message message;
+
+ for (int count = 0; ((count < options.Count) || (options.Count == 0)) &&
+ ((options.Timeout == TimeSpan.Zero) || (end.CompareTo(DateTime.Now) > 0)); count++)
+ {
+ message = Message.CreateMessage(MessageVersion.None, "", new MyRawBodyWriter());
+ AmqpProperties props = new AmqpProperties();
+ props.ContentType = "text/plain";
+
+ string id = Guid.NewGuid().ToString() + ":" + count;
+ props.PropertyMap.Add("spout-id", new AmqpString(id));
+
+ message.Properties["AmqpProperties"] = props;
+ sender.Send(message);
+ }
+ }
+ finally
+ {
+ factory.Close();
+ }
+ }
+ catch (Exception e)
+ {
+ Console.WriteLine("Spout: " + e);
+ }
+ }
+
+
+ public class MyRawBodyWriter : BodyWriter
+ {
+ static byte[] body;
+
+ public MyRawBodyWriter()
+ : base(false)
+ {
+ }
+
+ public static void Initialize(String content)
+ {
+ body = Encoding.UTF8.GetBytes(content);
+ }
+
+ // invoked by the binary encoder when the message is written
+ protected override void OnWriteBodyContents(XmlDictionaryWriter writer)
+ {
+ writer.WriteStartElement("Binary");
+ writer.WriteBase64(body, 0, body.Length);
+ }
+ }
+ }
+}
diff --git a/wcf/samples/Integration/Spout/Spout.csproj b/wcf/samples/Integration/Spout/Spout.csproj new file mode 100644 index 0000000000..b104000ad2 --- /dev/null +++ b/wcf/samples/Integration/Spout/Spout.csproj @@ -0,0 +1,81 @@ +<?xml version="1.0" encoding="utf-8"?>
+<!--
+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.
+-->
+<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>{347A531B-38DB-4848-9E4D-4E5E7F9C97E7}</ProjectGuid>
+ <OutputType>Exe</OutputType>
+ <AppDesignerFolder>Properties</AppDesignerFolder>
+ <RootNamespace>Spout</RootNamespace>
+ <AssemblyName>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>bin\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>bin\Release\</OutputPath>
+ <DefineConstants>TRACE</DefineConstants>
+ <ErrorReport>prompt</ErrorReport>
+ <WarningLevel>4</WarningLevel>
+ </PropertyGroup>
+ <ItemGroup>
+ <Reference Include="Apache.Qpid.Channel, Version=1.0.0.0, Culture=neutral, PublicKeyToken=679e1f50b62dbace, processorArchitecture=MSIL">
+ <SpecificVersion>False</SpecificVersion>
+ <HintPath>..\..\..\src\Apache\Qpid\Channel\bin\Release\Apache.Qpid.Channel.dll</HintPath>
+ </Reference>
+ <Reference Include="Apache.Qpid.Interop, Version=1.0.3796.12140, Culture=neutral, PublicKeyToken=679e1f50b62dbace, processorArchitecture=AMD64">
+ <SpecificVersion>False</SpecificVersion>
+ <HintPath>..\..\..\src\Apache\Qpid\Channel\bin\Release\Apache.Qpid.Interop.dll</HintPath>
+ </Reference>
+ <Reference Include="System" />
+ <Reference Include="System.Runtime.Serialization">
+ <RequiredTargetFramework>3.0</RequiredTargetFramework>
+ </Reference>
+ <Reference Include="System.ServiceModel">
+ <RequiredTargetFramework>3.0</RequiredTargetFramework>
+ </Reference>
+ <Reference Include="System.Xml" />
+ </ItemGroup>
+ <ItemGroup>
+ <Compile Include="..\Util\Options.cs" />
+ <Compile Include="Spout.cs" />
+ </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>
diff --git a/wcf/samples/Integration/Util/Options.cs b/wcf/samples/Integration/Util/Options.cs new file mode 100644 index 0000000000..a929f8f2de --- /dev/null +++ b/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; }
+ }
+ }
+}
|