diff options
Diffstat (limited to 'dotnet/client-010/examples')
56 files changed, 0 insertions, 3217 deletions
diff --git a/dotnet/client-010/examples/direct/example-direct-Listener/Listener.cs b/dotnet/client-010/examples/direct/example-direct-Listener/Listener.cs deleted file mode 100644 index f20090526d..0000000000 --- a/dotnet/client-010/examples/direct/example-direct-Listener/Listener.cs +++ /dev/null @@ -1,117 +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. -*/ - -using System; -using System.Configuration; -using System.IO; -using System.Text; -using System.Threading; -using org.apache.qpid.client; -using org.apache.qpid.transport; - -namespace org.apache.qpid.example.direct -{ - /// <summary> - /// This program is one of three programs designed to be used - /// together. These programs use the "amq.direct" exchange. - /// - /// Producer: - /// - /// Publishes to a broker, specifying a routing key. - /// - /// Listener (this program): - /// - /// Reads from a queue on the broker using a message listener. - /// - /// </summary> - public class Listener - { - private static void Main(string[] args) - { - string host = ConfigurationManager.AppSettings["Host"]; - int port = int.Parse(ConfigurationManager.AppSettings["Port"]); - string virtualhost = ConfigurationManager.AppSettings["VirtualHost"]; - string username = ConfigurationManager.AppSettings["Username"]; - string password = ConfigurationManager.AppSettings["Password"]; - - Client connection = new Client(); - try - { - connection.Connect(host, port, virtualhost, username, password); - IClientSession session = connection.CreateSession(50000); - - //--------- Main body of program -------------------------------------------- - // Create a queue named "message_queue", and route all messages whose - // routing key is "routing_key" to this newly created queue. - - session.QueueDeclare("message_queue"); - session.ExchangeBind("message_queue", "amq.direct", "routing_key"); - - lock (session) - { - // Create a listener and subscribe it to the queue named "message_queue" - IMessageListener listener = new MessageListener(session); - session.AttachMessageListener(listener, "message_queue"); - session.MessageSubscribe("message_queue"); - // Receive messages until all messages are received - Monitor.Wait(session); - } - - //--------------------------------------------------------------------------- - - connection.Close(); - } - catch (Exception e) - { - Console.WriteLine("Error: \n" + e.StackTrace); - } - } - } - - public class MessageListener : IMessageListener - { - private readonly IClientSession _session; - private readonly RangeSet _range = new RangeSet(); - public MessageListener(IClientSession session) - { - _session = session; - } - - public void MessageTransfer(IMessage m) - { - BinaryReader reader = new BinaryReader(m.Body, Encoding.UTF8); - byte[] body = new byte[m.Body.Length - m.Body.Position]; - reader.Read(body, 0, body.Length); - ASCIIEncoding enc = new ASCIIEncoding(); - string message = enc.GetString(body); - Console.WriteLine("Message: " + message); - // Add this message to the list of message to be acknowledged - _range.Add(m.Id); - if( message.Equals("That's all, folks!") ) - { - // Acknowledge all the received messages - _session.MessageAccept(_range); - lock(_session) - { - Monitor.Pulse(_session); - } - } - } - } -} diff --git a/dotnet/client-010/examples/direct/example-direct-Listener/Properties/AssemblyInfo.cs b/dotnet/client-010/examples/direct/example-direct-Listener/Properties/AssemblyInfo.cs deleted file mode 100644 index 2fab6a538a..0000000000 --- a/dotnet/client-010/examples/direct/example-direct-Listener/Properties/AssemblyInfo.cs +++ /dev/null @@ -1,54 +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. - * - */ - -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("example-direct-Listener")] -[assembly: AssemblyDescription("Built from svn revision number: ")] -[assembly: AssemblyConfiguration("")] -[assembly: AssemblyCompany("Apache Software Foundation")] -[assembly: AssemblyProduct("example-direct-Listener")] -[assembly: AssemblyCopyright("Apache Software Foundation")] -[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("6a24bfe4-4714-4d2a-acf4-96cf9a678a06")] - -// Version information for an assembly consists of the following four values: -// -// Major Version -// Minor Version -// Build Number -// Revision -// -[assembly: AssemblyVersion("0.5.0.0")] -[assembly: AssemblyFileVersion("1.0.0.0")] diff --git a/dotnet/client-010/examples/direct/example-direct-Listener/default.build b/dotnet/client-010/examples/direct/example-direct-Listener/default.build deleted file mode 100644 index f5db519af7..0000000000 --- a/dotnet/client-010/examples/direct/example-direct-Listener/default.build +++ /dev/null @@ -1,48 +0,0 @@ -<?xml version="1.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. - ---> - -<project name="example-direct-Listener" default="build"> - <!-- - Properties that come from master build file - - build.dir: root directory for build - - build.debug: true if building debug release - - build.defines: variables to define during build - --> - - <target name="build"> - <csc target="exe" - define="${build.defines}" - debug="${build.debug}" - output="${build.dir}/${project::get-name()}.exe"> - - <sources> - <include name="**/*.cs" /> - </sources> - <references> - <include name="${build.dir}/log4net.dll" /> - <include name="${build.dir}/qpid.client.dll" /> - <include name="System.Configuration.dll" /> - </references> - </csc> - </target> -</project> - diff --git a/dotnet/client-010/examples/direct/example-direct-Listener/example-direct-Listener.csproj b/dotnet/client-010/examples/direct/example-direct-Listener/example-direct-Listener.csproj deleted file mode 100644 index ac026b397d..0000000000 --- a/dotnet/client-010/examples/direct/example-direct-Listener/example-direct-Listener.csproj +++ /dev/null @@ -1,85 +0,0 @@ -<?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 DefaultTargets="Build" xmlns="http://schemas.microsoft.com/developer/msbuild/2003" ToolsVersion="3.5"> - <PropertyGroup> - <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration> - <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform> - <ProductVersion>9.0.30729</ProductVersion> - <SchemaVersion>2.0</SchemaVersion> - <ProjectGuid>{AE65B1B9-8779-4CB1-91AF-E7F6C7A736D7}</ProjectGuid> - <OutputType>Exe</OutputType> - <AppDesignerFolder>Properties</AppDesignerFolder> - <RootNamespace>example_direct_Listener</RootNamespace> - <AssemblyName>example-direct-Listener</AssemblyName> - <FileUpgradeFlags> - </FileUpgradeFlags> - <OldToolsVersion>2.0</OldToolsVersion> - <UpgradeBackupLocation> - </UpgradeBackupLocation> - </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="System" /> - <Reference Include="System.configuration" /> - <Reference Include="System.Data" /> - <Reference Include="System.Xml" /> - </ItemGroup> - <ItemGroup> - <Compile Include="Listener.cs" /> - <Compile Include="Properties\AssemblyInfo.cs" /> - </ItemGroup> - <ItemGroup> - <ProjectReference Include="..\..\..\client\Client.csproj"> - <Project>{B911FFD7-754F-4735-A188-218D5065BE79}</Project> - <Name>Client</Name> - </ProjectReference> - </ItemGroup> - <ItemGroup> - <None Include="..\..\..\App.config"> - <Link>App.config</Link> - </None> - </ItemGroup> - <Import Project="$(MSBuildBinPath)\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/dotnet/client-010/examples/direct/example-direct-producer/Producer.cs b/dotnet/client-010/examples/direct/example-direct-producer/Producer.cs deleted file mode 100644 index f62667bf98..0000000000 --- a/dotnet/client-010/examples/direct/example-direct-producer/Producer.cs +++ /dev/null @@ -1,92 +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. -*/ - -using System; -using System.Configuration; -using System.Text; -using org.apache.qpid.client; - -namespace org.apache.qpid.example.direct -{ - /// <summary> - /// This program is one of three programs designed to be used - /// together. These programs use the "amq.direct" exchange. - /// - /// Producer (this program): - /// - /// Publishes to a broker, specifying a routing key. - /// - /// Listener: - /// - /// Reads from a queue on the broker using a message listener. - /// - /// </summary> - class Producer - { - static void Main(string[] args) - { - string host = ConfigurationManager.AppSettings["Host"]; - int port = int.Parse(ConfigurationManager.AppSettings["Port"]); - string virtualhost = ConfigurationManager.AppSettings["VirtualHost"]; - string username = ConfigurationManager.AppSettings["Username"]; - string password = ConfigurationManager.AppSettings["Password"]; - - Client connection = new Client(); - try - { - connection.Connect(host, port, virtualhost, username, password); - IClientSession session = connection.CreateSession(50000); - - //--------- Main body of program -------------------------------------------- - - IMessage message = new Message(); - - // The routing key is a message property. We will use the same - // routing key for each message, so we'll set this property - // just once. (In most simple cases, there is no need to set - // other message properties.) - - message.DeliveryProperties.SetRoutingKey("routing_key"); - - // Asynchronous transfer sends messages as quickly as - // possible without waiting for confirmation. - for (int i = 0; i < 10; i++) - { - message.ClearData(); - message.AppendData(Encoding.UTF8.GetBytes("Message " + i)); - session.MessageTransfer("amq.direct", message); - } - - // And send a syncrhonous final message to indicate termination. - message.ClearData(); - message.AppendData(Encoding.UTF8.GetBytes("That's all, folks!")); - session.MessageTransfer("amq.direct", "routing_key", message); - session.Sync(); - - //----------------------------------------------------------------------------- - - connection.Close(); - } - catch (Exception e) - { - Console.WriteLine("Error: \n" + e.StackTrace); - } - } - } -} diff --git a/dotnet/client-010/examples/direct/example-direct-producer/Properties/AssemblyInfo.cs b/dotnet/client-010/examples/direct/example-direct-producer/Properties/AssemblyInfo.cs deleted file mode 100644 index 84590e67c1..0000000000 --- a/dotnet/client-010/examples/direct/example-direct-producer/Properties/AssemblyInfo.cs +++ /dev/null @@ -1,54 +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. - * - */ - -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("example-direct-producer")] -[assembly: AssemblyDescription("Built from svn revision number: ")] -[assembly: AssemblyConfiguration("")] -[assembly: AssemblyCompany("Apache Software Foundation")] -[assembly: AssemblyProduct("example-direct-producer")] -[assembly: AssemblyCopyright("Apache Software Foundation")] -[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("006144c2-5e45-4543-8e16-c09cd4309ed7")] - -// Version information for an assembly consists of the following four values: -// -// Major Version -// Minor Version -// Build Number -// Revision -// -[assembly: AssemblyVersion("0.5.0.0")] -[assembly: AssemblyFileVersion("1.0.0.0")] diff --git a/dotnet/client-010/examples/direct/example-direct-producer/default.build b/dotnet/client-010/examples/direct/example-direct-producer/default.build deleted file mode 100644 index c4e78444c7..0000000000 --- a/dotnet/client-010/examples/direct/example-direct-producer/default.build +++ /dev/null @@ -1,48 +0,0 @@ -<?xml version="1.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. - ---> - -<project name="example-direct-Producer" default="build"> - <!-- - Properties that come from master build file - - build.dir: root directory for build - - build.debug: true if building debug release - - build.defines: variables to define during build - --> - - <target name="build"> - <csc target="exe" - define="${build.defines}" - debug="${build.debug}" - output="${build.dir}/${project::get-name()}.exe"> - - <sources> - <include name="**/*.cs" /> - </sources> - <references> - <include name="${build.dir}/log4net.dll" /> - <include name="${build.dir}/qpid.client.dll" /> - <include name="System.Configuration.dll" /> - </references> - </csc> - </target> -</project> - diff --git a/dotnet/client-010/examples/direct/example-direct-producer/example-direct-producer.csproj b/dotnet/client-010/examples/direct/example-direct-producer/example-direct-producer.csproj deleted file mode 100644 index 10d9d96aea..0000000000 --- a/dotnet/client-010/examples/direct/example-direct-producer/example-direct-producer.csproj +++ /dev/null @@ -1,85 +0,0 @@ -<?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 DefaultTargets="Build" xmlns="http://schemas.microsoft.com/developer/msbuild/2003" ToolsVersion="3.5"> - <PropertyGroup> - <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration> - <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform> - <ProductVersion>9.0.30729</ProductVersion> - <SchemaVersion>2.0</SchemaVersion> - <ProjectGuid>{96FCB250-8142-40EE-9BDD-CA839EE21021}</ProjectGuid> - <OutputType>Exe</OutputType> - <AppDesignerFolder>Properties</AppDesignerFolder> - <RootNamespace>example_direct_producer</RootNamespace> - <AssemblyName>example-direct-producer</AssemblyName> - <FileUpgradeFlags> - </FileUpgradeFlags> - <OldToolsVersion>2.0</OldToolsVersion> - <UpgradeBackupLocation> - </UpgradeBackupLocation> - </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="System" /> - <Reference Include="System.configuration" /> - <Reference Include="System.Data" /> - <Reference Include="System.Xml" /> - </ItemGroup> - <ItemGroup> - <Compile Include="Producer.cs" /> - <Compile Include="Properties\AssemblyInfo.cs" /> - </ItemGroup> - <ItemGroup> - <ProjectReference Include="..\..\..\client\Client.csproj"> - <Project>{B911FFD7-754F-4735-A188-218D5065BE79}</Project> - <Name>Client</Name> - </ProjectReference> - </ItemGroup> - <ItemGroup> - <None Include="..\..\..\App.config"> - <Link>App.config</Link> - </None> - </ItemGroup> - <Import Project="$(MSBuildBinPath)\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/dotnet/client-010/examples/direct/verify b/dotnet/client-010/examples/direct/verify deleted file mode 100644 index 7da08480a2..0000000000 --- a/dotnet/client-010/examples/direct/verify +++ /dev/null @@ -1,37 +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. -## -## -# - -# See https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid/bin/verify -cpp=$CPP/direct - -direct_listener_dotnet() -{ -mono $DOTNET_EXAMPLES/example-direct-Listener.exe localhost 5672 -} - -direct_producer_dotnet() -{ -mono $DOTNET_EXAMPLES/example-direct-Producer.exe localhost 5672 -} - -clients $cpp/declare_queues direct_producer_dotnet direct_listener_dotnet -outputs $cpp/declare_queues.out ./direct_producer_dotnet.out ./direct_listener_dotnet.out diff --git a/dotnet/client-010/examples/direct/verify.in b/dotnet/client-010/examples/direct/verify.in deleted file mode 100644 index f57d931663..0000000000 --- a/dotnet/client-010/examples/direct/verify.in +++ /dev/null @@ -1,14 +0,0 @@ -==== declare_queues.out -==== direct_producer_dotnet.out -==== direct_listener_dotnet.out -Message: Message 0 -Message: Message 1 -Message: Message 2 -Message: Message 3 -Message: Message 4 -Message: Message 5 -Message: Message 6 -Message: Message 7 -Message: Message 8 -Message: Message 9 -Message: That's all, folks! diff --git a/dotnet/client-010/examples/direct/verify_cpp_dotnet b/dotnet/client-010/examples/direct/verify_cpp_dotnet deleted file mode 100644 index 648c8b6bc1..0000000000 --- a/dotnet/client-010/examples/direct/verify_cpp_dotnet +++ /dev/null @@ -1,29 +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. -# - -# See https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid/bin/verify -cpp=$CPP/direct - -direct_listener_dotnet() -{ -mono $DOTNET_EXAMPLES/example-direct-Listener.exe localhost 5672 -} - -clients $cpp/declare_queues $cpp/direct_producer direct_listener_dotnet -outputs $cpp/declare_queues.out $cpp/direct_producer.out ./direct_listener_dotnet.out diff --git a/dotnet/client-010/examples/direct/verify_cpp_dotnet.in b/dotnet/client-010/examples/direct/verify_cpp_dotnet.in deleted file mode 100644 index b3543cefe5..0000000000 --- a/dotnet/client-010/examples/direct/verify_cpp_dotnet.in +++ /dev/null @@ -1,14 +0,0 @@ -==== declare_queues.out -==== direct_producer.out -==== direct_listener_dotnet.out -Message: Message 0 -Message: Message 1 -Message: Message 2 -Message: Message 3 -Message: Message 4 -Message: Message 5 -Message: Message 6 -Message: Message 7 -Message: Message 8 -Message: Message 9 -Message: That's all, folks! diff --git a/dotnet/client-010/examples/direct/verify_dotnet_cpp b/dotnet/client-010/examples/direct/verify_dotnet_cpp deleted file mode 100644 index 5093da6088..0000000000 --- a/dotnet/client-010/examples/direct/verify_dotnet_cpp +++ /dev/null @@ -1,29 +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. -# - -# See https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid/bin/verify -cpp=$CPP/direct - -direct_producer_dotnet() -{ -mono $DOTNET_EXAMPLES/example-direct-Producer.exe localhost 5672 -} - -clients $cpp/declare_queues direct_producer_dotnet $cpp/listener -outputs $cpp/declare_queues.out ./direct_producer_dotnet.out $cpp/listener.out diff --git a/dotnet/client-010/examples/direct/verify_dotnet_cpp.in b/dotnet/client-010/examples/direct/verify_dotnet_cpp.in deleted file mode 100644 index fcb6cd66de..0000000000 --- a/dotnet/client-010/examples/direct/verify_dotnet_cpp.in +++ /dev/null @@ -1,15 +0,0 @@ -==== declare_queues.out -==== direct_producer_dotnet.out -==== listener.out -Message: Message 0 -Message: Message 1 -Message: Message 2 -Message: Message 3 -Message: Message 4 -Message: Message 5 -Message: Message 6 -Message: Message 7 -Message: Message 8 -Message: Message 9 -Message: That's all, folks! -Shutting down listener for message_queue diff --git a/dotnet/client-010/examples/fanout/example-fanout-Listener/Listener.cs b/dotnet/client-010/examples/fanout/example-fanout-Listener/Listener.cs deleted file mode 100644 index b1967b59be..0000000000 --- a/dotnet/client-010/examples/fanout/example-fanout-Listener/Listener.cs +++ /dev/null @@ -1,126 +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. -*/ - -using System; -using System.Configuration; -using System.IO; -using System.Text; -using System.Threading; -using org.apache.qpid.client; -using org.apache.qpid.transport; - -namespace org.apache.qpid.example.fanout -{ - /// <summary> - /// This program is one of two programs designed to be used - /// together. - /// - /// Producer (this program): - /// - /// Publishes to a broker, specifying a routing key. - /// - /// Listener: - /// - /// Reads from a queue on the broker using a message listener. - /// - /// </summary> - public class Listener - { - private static void Main(string[] args) - { - string host = ConfigurationManager.AppSettings["Host"]; - int port = int.Parse(ConfigurationManager.AppSettings["Port"]); - string virtualhost = ConfigurationManager.AppSettings["VirtualHost"]; - string username = ConfigurationManager.AppSettings["Username"]; - string password = ConfigurationManager.AppSettings["Password"]; - - Client connection = new Client(); - try - { - connection.Connect(host, port, virtualhost, username, password); - IClientSession session = connection.CreateSession(50000); - - //--------- Main body of program -------------------------------------------- - // Each client creates its own private queue, using the - // session id to guarantee a unique name. It then routes - // all messages from the fanout exchange to its own queue - // by binding to the queue. - // - // The binding specifies a binding key, but for a fanout - // exchange, the binding key is optional and is not used - // for routing decisions. It can be useful for tracking - // messages and routing in logs. - - string myQueue = session.Name; - session.QueueDeclare(myQueue, Option.EXCLUSIVE, Option.AUTO_DELETE); - session.ExchangeBind(myQueue, "amq.fanout", "my-key"); - - lock (session) - { - Console.WriteLine("Listening"); - // Create a listener and subscribe it to my queue. - IMessageListener listener = new MessageListener(session); - session.AttachMessageListener(listener, myQueue); - session.MessageSubscribe(myQueue); - // Receive messages until all messages are received - Monitor.Wait(session); - } - - //--------------------------------------------------------------------------- - - connection.Close(); - } - catch (Exception e) - { - Console.WriteLine("Error: \n" + e.StackTrace); - } - } - } - - public class MessageListener : IMessageListener - { - private readonly IClientSession _session; - private readonly RangeSet _range = new RangeSet(); - public MessageListener(IClientSession session) - { - _session = session; - } - - public void MessageTransfer(IMessage m) - { - BinaryReader reader = new BinaryReader(m.Body, Encoding.UTF8); - byte[] body = new byte[m.Body.Length - m.Body.Position]; - reader.Read(body, 0, body.Length); - ASCIIEncoding enc = new ASCIIEncoding(); - string message = enc.GetString(body); - Console.WriteLine("Message: " + message); - // Add this message to the list of message to be acknowledged - _range.Add(m.Id); - if (message.Equals("That's all, folks!")) - { - // Acknowledge all the received messages - _session.MessageAccept(_range); - lock (_session) - { - Monitor.Pulse(_session); - } - } - } - } -} diff --git a/dotnet/client-010/examples/fanout/example-fanout-Listener/Properties/AssemblyInfo.cs b/dotnet/client-010/examples/fanout/example-fanout-Listener/Properties/AssemblyInfo.cs deleted file mode 100644 index 45ff62073e..0000000000 --- a/dotnet/client-010/examples/fanout/example-fanout-Listener/Properties/AssemblyInfo.cs +++ /dev/null @@ -1,54 +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. - * - */ - -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("example-fanout-Listener")] -[assembly: AssemblyDescription("Built from svn revision number: ")] -[assembly: AssemblyConfiguration("")] -[assembly: AssemblyCompany("Apache Software Foundation")] -[assembly: AssemblyProduct("example-fanout-Listener")] -[assembly: AssemblyCopyright("Apache Software Foundation")] -[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("68686ef9-aa0a-4334-9c52-d7e6fc507bec")] - -// Version information for an assembly consists of the following four values: -// -// Major Version -// Minor Version -// Build Number -// Revision -// -[assembly: AssemblyVersion("0.5.0.0")] -[assembly: AssemblyFileVersion("1.0.0.0")] diff --git a/dotnet/client-010/examples/fanout/example-fanout-Listener/default.build b/dotnet/client-010/examples/fanout/example-fanout-Listener/default.build deleted file mode 100644 index dde36daf17..0000000000 --- a/dotnet/client-010/examples/fanout/example-fanout-Listener/default.build +++ /dev/null @@ -1,48 +0,0 @@ -<?xml version="1.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. - ---> - -<project name="example-fanout-Listener" default="build"> - <!-- - Properties that come from master build file - - build.dir: root directory for build - - build.debug: true if building debug release - - build.defines: variables to define during build - --> - - <target name="build"> - <csc target="exe" - define="${build.defines}" - debug="${build.debug}" - output="${build.dir}/${project::get-name()}.exe"> - - <sources> - <include name="**/*.cs" /> - </sources> - <references> - <include name="${build.dir}/log4net.dll" /> - <include name="${build.dir}/qpid.client.dll" /> - <include name="System.Configuration.dll" /> - </references> - </csc> - </target> -</project> - diff --git a/dotnet/client-010/examples/fanout/example-fanout-Listener/example-fanout-Listener.csproj b/dotnet/client-010/examples/fanout/example-fanout-Listener/example-fanout-Listener.csproj deleted file mode 100644 index 3bd0b3d0d0..0000000000 --- a/dotnet/client-010/examples/fanout/example-fanout-Listener/example-fanout-Listener.csproj +++ /dev/null @@ -1,85 +0,0 @@ -<?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 DefaultTargets="Build" xmlns="http://schemas.microsoft.com/developer/msbuild/2003" ToolsVersion="3.5"> - <PropertyGroup> - <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration> - <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform> - <ProductVersion>9.0.30729</ProductVersion> - <SchemaVersion>2.0</SchemaVersion> - <ProjectGuid>{18A0792B-DC3A-4EC5-93D6-DB8A111D8F15}</ProjectGuid> - <OutputType>Exe</OutputType> - <AppDesignerFolder>Properties</AppDesignerFolder> - <RootNamespace>example_fanout_Listener</RootNamespace> - <AssemblyName>example-fanout-Listener</AssemblyName> - <FileUpgradeFlags> - </FileUpgradeFlags> - <OldToolsVersion>2.0</OldToolsVersion> - <UpgradeBackupLocation> - </UpgradeBackupLocation> - </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="System" /> - <Reference Include="System.configuration" /> - <Reference Include="System.Data" /> - <Reference Include="System.Xml" /> - </ItemGroup> - <ItemGroup> - <Compile Include="Listener.cs" /> - <Compile Include="Properties\AssemblyInfo.cs" /> - </ItemGroup> - <ItemGroup> - <ProjectReference Include="..\..\..\client\Client.csproj"> - <Project>{B911FFD7-754F-4735-A188-218D5065BE79}</Project> - <Name>Client</Name> - </ProjectReference> - </ItemGroup> - <ItemGroup> - <None Include="..\..\..\App.config"> - <Link>App.config</Link> - </None> - </ItemGroup> - <Import Project="$(MSBuildBinPath)\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/dotnet/client-010/examples/fanout/example-fanout-Producer/Producer.cs b/dotnet/client-010/examples/fanout/example-fanout-Producer/Producer.cs deleted file mode 100644 index a781358a7e..0000000000 --- a/dotnet/client-010/examples/fanout/example-fanout-Producer/Producer.cs +++ /dev/null @@ -1,89 +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. -*/ - -using System; -using System.Configuration; -using System.Text; -using org.apache.qpid.client; - -namespace org.apache.qpid.example.fanout -{ - /// <summary> - /// This program is one of two programs designed to be used - /// together. These programs do not specify the exchange type - the - /// default exchange type is the direct exchange. - /// - /// - /// Producer (this program): - /// - /// Publishes to a broker, specifying a routing key. - /// - /// Listener: - /// - /// Reads from a queue on the broker using a message listener. - /// - /// </summary> - class Producer - { - static void Main(string[] args) - { - string host = ConfigurationManager.AppSettings["Host"]; - int port = int.Parse(ConfigurationManager.AppSettings["Port"]); - string virtualhost = ConfigurationManager.AppSettings["VirtualHost"]; - string username = ConfigurationManager.AppSettings["Username"]; - string password = ConfigurationManager.AppSettings["Password"]; - - Client connection = new Client(); - try - { - connection.Connect(host, port, virtualhost, username, password); - IClientSession session = connection.CreateSession(50000); - - //--------- Main body of program -------------------------------------------- - - // Unlike topic exchanges and direct exchanges, a fanout - // exchange need not set a routing key. - IMessage message = new Message(); - - // Asynchronous transfer sends messages as quickly as - // possible without waiting for confirmation. - for (int i = 0; i < 10; i++) - { - message.ClearData(); - message.AppendData(Encoding.UTF8.GetBytes("Message " + i)); - session.MessageTransfer("amq.fanout", message); - } - - // And send a syncrhonous final message to indicate termination. - message.ClearData(); - message.AppendData(Encoding.UTF8.GetBytes("That's all, folks!")); - session.MessageTransfer("amq.fanout", message); - session.Sync(); - - //----------------------------------------------------------------------------- - - connection.Close(); - } - catch (Exception e) - { - Console.WriteLine("Error: \n" + e.StackTrace); - } - } - } -} diff --git a/dotnet/client-010/examples/fanout/example-fanout-Producer/Properties/AssemblyInfo.cs b/dotnet/client-010/examples/fanout/example-fanout-Producer/Properties/AssemblyInfo.cs deleted file mode 100644 index c19bb5b949..0000000000 --- a/dotnet/client-010/examples/fanout/example-fanout-Producer/Properties/AssemblyInfo.cs +++ /dev/null @@ -1,54 +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. - * - */ - -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("example-fanout-Producer")] -[assembly: AssemblyDescription("Built from svn revision number: ")] -[assembly: AssemblyConfiguration("")] -[assembly: AssemblyCompany("Apache Software Foundation")] -[assembly: AssemblyProduct("example-fanout-Producer")] -[assembly: AssemblyCopyright("Apache Software Foundation")] -[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("01c0ba10-2f23-409b-9adc-bc514a13131a")] - -// Version information for an assembly consists of the following four values: -// -// Major Version -// Minor Version -// Build Number -// Revision -// -[assembly: AssemblyVersion("0.5.0.0")] -[assembly: AssemblyFileVersion("1.0.0.0")] diff --git a/dotnet/client-010/examples/fanout/example-fanout-Producer/default.build b/dotnet/client-010/examples/fanout/example-fanout-Producer/default.build deleted file mode 100644 index c4d39e41da..0000000000 --- a/dotnet/client-010/examples/fanout/example-fanout-Producer/default.build +++ /dev/null @@ -1,48 +0,0 @@ -<?xml version="1.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. - ---> - -<project name="example-fanout-Producer" default="build"> - <!-- - Properties that come from master build file - - build.dir: root directory for build - - build.debug: true if building debug release - - build.defines: variables to define during build - --> - - <target name="build"> - <csc target="exe" - define="${build.defines}" - debug="${build.debug}" - output="${build.dir}/${project::get-name()}.exe"> - - <sources> - <include name="**/*.cs" /> - </sources> - <references> - <include name="${build.dir}/log4net.dll" /> - <include name="${build.dir}/qpid.client.dll" /> - <include name="System.Configuration.dll" /> - </references> - </csc> - </target> -</project> - diff --git a/dotnet/client-010/examples/fanout/example-fanout-Producer/example-fanout-Producer.csproj b/dotnet/client-010/examples/fanout/example-fanout-Producer/example-fanout-Producer.csproj deleted file mode 100644 index 8b04dd8199..0000000000 --- a/dotnet/client-010/examples/fanout/example-fanout-Producer/example-fanout-Producer.csproj +++ /dev/null @@ -1,85 +0,0 @@ -<?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 DefaultTargets="Build" xmlns="http://schemas.microsoft.com/developer/msbuild/2003" ToolsVersion="3.5"> - <PropertyGroup> - <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration> - <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform> - <ProductVersion>9.0.30729</ProductVersion> - <SchemaVersion>2.0</SchemaVersion> - <ProjectGuid>{4513BF94-D54A-42FE-8506-FE2CD57B2C51}</ProjectGuid> - <OutputType>Exe</OutputType> - <AppDesignerFolder>Properties</AppDesignerFolder> - <RootNamespace>example_fanout_Producer</RootNamespace> - <AssemblyName>example-fanout-Producer</AssemblyName> - <FileUpgradeFlags> - </FileUpgradeFlags> - <OldToolsVersion>2.0</OldToolsVersion> - <UpgradeBackupLocation> - </UpgradeBackupLocation> - </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="System" /> - <Reference Include="System.configuration" /> - <Reference Include="System.Data" /> - <Reference Include="System.Xml" /> - </ItemGroup> - <ItemGroup> - <Compile Include="Producer.cs" /> - <Compile Include="Properties\AssemblyInfo.cs" /> - </ItemGroup> - <ItemGroup> - <ProjectReference Include="..\..\..\client\Client.csproj"> - <Project>{B911FFD7-754F-4735-A188-218D5065BE79}</Project> - <Name>Client</Name> - </ProjectReference> - </ItemGroup> - <ItemGroup> - <None Include="..\..\..\App.config"> - <Link>App.config</Link> - </None> - </ItemGroup> - <Import Project="$(MSBuildBinPath)\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/dotnet/client-010/examples/fanout/verify b/dotnet/client-010/examples/fanout/verify deleted file mode 100644 index 51b7327243..0000000000 --- a/dotnet/client-010/examples/fanout/verify +++ /dev/null @@ -1,36 +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. -# -# - -# See https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid/bin/verify - -fanout_listener_dotnet() -{ -mono $DOTNET_EXAMPLES/example-fanout-Listener.exe localhost 5672 -} - -fanout_producer_dotnet() -{ -mono $DOTNET_EXAMPLES/example-fanout-Producer.exe localhost 5672 -} - -background "Listening" fanout_listener_dotnet -clients fanout_producer_dotnet -outputs ./fanout_listener_dotnet.out ./fanout_producer_dotnet.out diff --git a/dotnet/client-010/examples/fanout/verify.in b/dotnet/client-010/examples/fanout/verify.in deleted file mode 100644 index 37a4a4aaa8..0000000000 --- a/dotnet/client-010/examples/fanout/verify.in +++ /dev/null @@ -1,14 +0,0 @@ -==== fanout_listener_dotnet.out -Listening -Message: Message 0 -Message: Message 1 -Message: Message 2 -Message: Message 3 -Message: Message 4 -Message: Message 5 -Message: Message 6 -Message: Message 7 -Message: Message 8 -Message: Message 9 -Message: That's all, folks! -==== fanout_producer_dotnet.out diff --git a/dotnet/client-010/examples/fanout/verify_cpp_dotnet b/dotnet/client-010/examples/fanout/verify_cpp_dotnet deleted file mode 100644 index 5716d3119b..0000000000 --- a/dotnet/client-010/examples/fanout/verify_cpp_dotnet +++ /dev/null @@ -1,30 +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. -# - -# See https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid/bin/verify -cpp=$CPP/fanout - -fanout_listener_dotnet() -{ -mono $DOTNET_EXAMPLES/example-fanout-Listener.exe localhost 5672 -} - -background "Listening" fanout_listener_dotnet -clients $cpp/fanout_producer -outputs $cpp/fanout_producer.out "./fanout_listener_dotnet.out | remove_uuid" diff --git a/dotnet/client-010/examples/fanout/verify_cpp_dotnet.in b/dotnet/client-010/examples/fanout/verify_cpp_dotnet.in deleted file mode 100644 index 0a72d8fd3c..0000000000 --- a/dotnet/client-010/examples/fanout/verify_cpp_dotnet.in +++ /dev/null @@ -1,14 +0,0 @@ -==== fanout_producer.out -==== fanout_listener_dotnet.out | remove_uuid -Listening -Message: Message 0 -Message: Message 1 -Message: Message 2 -Message: Message 3 -Message: Message 4 -Message: Message 5 -Message: Message 6 -Message: Message 7 -Message: Message 8 -Message: Message 9 -Message: That's all, folks! diff --git a/dotnet/client-010/examples/fanout/verify_dotnet_cpp b/dotnet/client-010/examples/fanout/verify_dotnet_cpp deleted file mode 100644 index c755d1da41..0000000000 --- a/dotnet/client-010/examples/fanout/verify_dotnet_cpp +++ /dev/null @@ -1,31 +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. -# - -# See https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid/bin/verify -cpp=$CPP/fanout - -fanout_producer_dotnet() -{ -mono $DOTNET_EXAMPLES/example-fanout-Producer.exe localhost 5672 -} - - -background "Listening" $cpp/listener -clients fanout_producer_dotnet -outputs ./fanout_producer_dotnet.out "$cpp/listener.out | remove_uuid" diff --git a/dotnet/client-010/examples/fanout/verify_dotnet_cpp.in b/dotnet/client-010/examples/fanout/verify_dotnet_cpp.in deleted file mode 100644 index 588559938f..0000000000 --- a/dotnet/client-010/examples/fanout/verify_dotnet_cpp.in +++ /dev/null @@ -1,15 +0,0 @@ -==== fanout_producer_dotnet.out -==== listener.out | remove_uuid -Listening -Message: Message 0 -Message: Message 1 -Message: Message 2 -Message: Message 3 -Message: Message 4 -Message: Message 5 -Message: Message 6 -Message: Message 7 -Message: Message 8 -Message: Message 9 -Message: That's all, folks! -Shutting down listener for diff --git a/dotnet/client-010/examples/pub-sub/example-pub-sub-Listener/Listener.cs b/dotnet/client-010/examples/pub-sub/example-pub-sub-Listener/Listener.cs deleted file mode 100644 index aeaf3f043b..0000000000 --- a/dotnet/client-010/examples/pub-sub/example-pub-sub-Listener/Listener.cs +++ /dev/null @@ -1,143 +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. -*/ - -using System; -using System.Configuration; -using System.IO; -using System.Text; -using System.Threading; -using org.apache.qpid.client; -using org.apache.qpid.transport; - -namespace org.apache.qpid.example.pubsub -{ - /// <summary> - /// This program is one of two programs designed to be used - /// together. These programs use the topic exchange. - /// - /// Publisher: - /// - /// Publishes to a broker, specifying a routing key. - /// - /// Listener (this program): - /// - /// Reads from a queue on the broker using a message listener. - /// - /// </summary> - internal class Listener - { - public static int _count = 4; - - private static void Main(string[] args) - { - string host = ConfigurationManager.AppSettings["Host"]; - int port = int.Parse(ConfigurationManager.AppSettings["Port"]); - string virtualhost = ConfigurationManager.AppSettings["VirtualHost"]; - string username = ConfigurationManager.AppSettings["Username"]; - string password = ConfigurationManager.AppSettings["Password"]; - - Client connection = new Client(); - try - { - connection.Connect(host, port, virtualhost, username, password); - IClientSession session = connection.CreateSession(50000); - - //--------- Main body of program -------------------------------------------- - - lock (session) - { - Console.WriteLine("Listening for messages ..."); - // Create a listener - prepareQueue("usa", "usa.#", session); - prepareQueue("europe", "europe.#", session); - prepareQueue("news", "#.news", session); - prepareQueue("weather", "#.weather", session); - while (_count > 0) - { - Monitor.Wait(session); - } - } - - //--------------------------------------------------------------------------- - - connection.Close(); - } - catch (Exception e) - { - Console.WriteLine("Error: \n" + e.StackTrace); - } - } - - private static void prepareQueue(string queue, string routing_key, IClientSession session) - { - // Create a unique queue name for this consumer by concatenating - // the queue name parameter with the Session ID. - Console.WriteLine("Declaring queue: " + queue); - session.QueueDeclare(queue, Option.EXCLUSIVE, Option.AUTO_DELETE); - - // Route messages to the new queue if they match the routing key. - // Also route any messages to with the "control" routing key to - // this queue so we know when it's time to stop. A publisher sends - // a message with the content "That's all, Folks!", using the - // "control" routing key, when it is finished. - - session.ExchangeBind(queue, "amq.topic", routing_key); - session.ExchangeBind(queue, "amq.topic", "control"); - - // subscribe the listener to the queue - IMessageListener listener = new MessageListener(session); - session.AttachMessageListener(listener, queue); - session.MessageSubscribe(queue); - } - } - - public class MessageListener : IMessageListener - { - private readonly IClientSession _session; - private readonly RangeSet _range = new RangeSet(); - - public MessageListener(IClientSession session) - { - _session = session; - } - - public void MessageTransfer(IMessage m) - { - BinaryReader reader = new BinaryReader(m.Body, Encoding.UTF8); - byte[] body = new byte[m.Body.Length - m.Body.Position]; - reader.Read(body, 0, body.Length); - ASCIIEncoding enc = new ASCIIEncoding(); - string message = enc.GetString(body); - Console.WriteLine("Message: " + message + " from " + m.Destination); - // Add this message to the list of message to be acknowledged - _range.Add(m.Id); - if (message.Equals("That's all, folks!")) - { - Console.WriteLine("Shutting down listener for " + m.DeliveryProperties.GetRoutingKey()); - Listener._count--; - // Acknowledge all the received messages - _session.MessageAccept(_range); - lock (_session) - { - Monitor.Pulse(_session); - } - } - } - } -} diff --git a/dotnet/client-010/examples/pub-sub/example-pub-sub-Listener/Properties/AssemblyInfo.cs b/dotnet/client-010/examples/pub-sub/example-pub-sub-Listener/Properties/AssemblyInfo.cs deleted file mode 100644 index ef791c6738..0000000000 --- a/dotnet/client-010/examples/pub-sub/example-pub-sub-Listener/Properties/AssemblyInfo.cs +++ /dev/null @@ -1,54 +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. - * - */ - -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("example-pub-sub-Listener")] -[assembly: AssemblyDescription("Built from svn revision number: ")] -[assembly: AssemblyConfiguration("")] -[assembly: AssemblyCompany("Apache Software Foundation")] -[assembly: AssemblyProduct("example-pub-sub-Listener")] -[assembly: AssemblyCopyright("Apache Software Foundation")] -[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("74ab02ae-95d1-4bad-a7cf-9964005b9b05")] - -// Version information for an assembly consists of the following four values: -// -// Major Version -// Minor Version -// Build Number -// Revision -// -[assembly: AssemblyVersion("0.5.0.0")] -[assembly: AssemblyFileVersion("1.0.0.0")] diff --git a/dotnet/client-010/examples/pub-sub/example-pub-sub-Listener/default.build b/dotnet/client-010/examples/pub-sub/example-pub-sub-Listener/default.build deleted file mode 100644 index fe2d9bf4ba..0000000000 --- a/dotnet/client-010/examples/pub-sub/example-pub-sub-Listener/default.build +++ /dev/null @@ -1,48 +0,0 @@ -<?xml version="1.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. - ---> - -<project name="example-pub-sub-Listener" default="build"> - <!-- - Properties that come from master build file - - build.dir: root directory for build - - build.debug: true if building debug release - - build.defines: variables to define during build - --> - - <target name="build"> - <csc target="exe" - define="${build.defines}" - debug="${build.debug}" - output="${build.dir}/${project::get-name()}.exe"> - - <sources> - <include name="**/*.cs" /> - </sources> - <references> - <include name="${build.dir}/log4net.dll" /> - <include name="${build.dir}/qpid.client.dll" /> - <include name="System.Configuration.dll" /> - </references> - </csc> - </target> -</project> - diff --git a/dotnet/client-010/examples/pub-sub/example-pub-sub-Listener/example-pub-sub-Listener.csproj b/dotnet/client-010/examples/pub-sub/example-pub-sub-Listener/example-pub-sub-Listener.csproj deleted file mode 100644 index 851faa7f21..0000000000 --- a/dotnet/client-010/examples/pub-sub/example-pub-sub-Listener/example-pub-sub-Listener.csproj +++ /dev/null @@ -1,85 +0,0 @@ -<?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 DefaultTargets="Build" xmlns="http://schemas.microsoft.com/developer/msbuild/2003" ToolsVersion="3.5"> - <PropertyGroup> - <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration> - <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform> - <ProductVersion>9.0.30729</ProductVersion> - <SchemaVersion>2.0</SchemaVersion> - <ProjectGuid>{2BCDC2CC-5BDA-4CC7-944D-2899AD8A53C7}</ProjectGuid> - <OutputType>Exe</OutputType> - <AppDesignerFolder>Properties</AppDesignerFolder> - <RootNamespace>example_pub_sub_Listener</RootNamespace> - <AssemblyName>example-pub-sub-Listener</AssemblyName> - <FileUpgradeFlags> - </FileUpgradeFlags> - <OldToolsVersion>2.0</OldToolsVersion> - <UpgradeBackupLocation> - </UpgradeBackupLocation> - </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="System" /> - <Reference Include="System.configuration" /> - <Reference Include="System.Data" /> - <Reference Include="System.Xml" /> - </ItemGroup> - <ItemGroup> - <Compile Include="Listener.cs" /> - <Compile Include="Properties\AssemblyInfo.cs" /> - </ItemGroup> - <ItemGroup> - <ProjectReference Include="..\..\..\client\Client.csproj"> - <Project>{B911FFD7-754F-4735-A188-218D5065BE79}</Project> - <Name>Client</Name> - </ProjectReference> - </ItemGroup> - <ItemGroup> - <None Include="..\..\..\App.config"> - <Link>App.config</Link> - </None> - </ItemGroup> - <Import Project="$(MSBuildBinPath)\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/dotnet/client-010/examples/pub-sub/example-pub-sub-Publisher/Properties/AssemblyInfo.cs b/dotnet/client-010/examples/pub-sub/example-pub-sub-Publisher/Properties/AssemblyInfo.cs deleted file mode 100644 index b6d7f3c818..0000000000 --- a/dotnet/client-010/examples/pub-sub/example-pub-sub-Publisher/Properties/AssemblyInfo.cs +++ /dev/null @@ -1,54 +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. - * - */ - -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("example-pub-sub-Publisher")] -[assembly: AssemblyDescription("Built from svn revision number: ")] -[assembly: AssemblyConfiguration("")] -[assembly: AssemblyCompany("Apache Software Foundation")] -[assembly: AssemblyProduct("example-pub-sub-Publisher")] -[assembly: AssemblyCopyright("Apache Software Foundation")] -[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("f6d282a0-9dc5-46cf-a4cd-44ae402d667f")] - -// Version information for an assembly consists of the following four values: -// -// Major Version -// Minor Version -// Build Number -// Revision -// -[assembly: AssemblyVersion("0.5.0.0")] -[assembly: AssemblyFileVersion("1.0.0.0")] diff --git a/dotnet/client-010/examples/pub-sub/example-pub-sub-Publisher/Publisher.cs b/dotnet/client-010/examples/pub-sub/example-pub-sub-Publisher/Publisher.cs deleted file mode 100644 index c87985d288..0000000000 --- a/dotnet/client-010/examples/pub-sub/example-pub-sub-Publisher/Publisher.cs +++ /dev/null @@ -1,98 +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. -*/ - -using System; -using System.Configuration; -using System.Text; -using org.apache.qpid.client; - -namespace org.apache.qpid.example.pubsub -{ - /// <summary> - /// This program is one of two programs designed to be used - /// together. These programs use the topic exchange. - /// - /// Publisher (this program): - /// - /// Publishes to a broker, specifying a routing key. - /// - /// Listener: - /// - /// Reads from a queue on the broker using a message listener. - /// - /// </summary> - internal class Publisher - { - private static void Main(string[] args) - { - string host = ConfigurationManager.AppSettings["Host"]; - int port = int.Parse(ConfigurationManager.AppSettings["Port"]); - string virtualhost = ConfigurationManager.AppSettings["VirtualHost"]; - string username = ConfigurationManager.AppSettings["Username"]; - string password = ConfigurationManager.AppSettings["Password"]; - - Client connection = new Client(); - try - { - connection.Connect(host, port, virtualhost, username, password); - IClientSession session = connection.CreateSession(50000); - - //--------- Main body of program -------------------------------------------- - - publishMessages(session, "usa.news"); - publishMessages(session, "usa.weather"); - publishMessages(session, "europe.news"); - publishMessages(session, "europe.weather"); - - noMoreMessages(session); - - //----------------------------------------------------------------------------- - - connection.Close(); - } - catch (Exception e) - { - Console.WriteLine("Error: \n" + e.StackTrace); - } - } - - private static void publishMessages(IClientSession session, string routing_key) - { - IMessage message = new Message(); - // Asynchronous transfer sends messages as quickly as - // possible without waiting for confirmation. - for (int i = 0; i < 10; i++) - { - message.ClearData(); - message.AppendData(Encoding.UTF8.GetBytes("Message " + i)); - session.MessageTransfer("amq.topic", routing_key, message); - } - } - - private static void noMoreMessages(IClientSession session) - { - IMessage message = new Message(); - // And send a syncrhonous final message to indicate termination. - message.ClearData(); - message.AppendData(Encoding.UTF8.GetBytes("That's all, folks!")); - session.MessageTransfer("amq.topic", "control", message); - session.Sync(); - } - } -} diff --git a/dotnet/client-010/examples/pub-sub/example-pub-sub-Publisher/default.build b/dotnet/client-010/examples/pub-sub/example-pub-sub-Publisher/default.build deleted file mode 100644 index 3f270afe9e..0000000000 --- a/dotnet/client-010/examples/pub-sub/example-pub-sub-Publisher/default.build +++ /dev/null @@ -1,48 +0,0 @@ -<?xml version="1.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. - ---> - -<project name="example-pub-sub-Publisher" default="build"> - <!-- - Properties that come from master build file - - build.dir: root directory for build - - build.debug: true if building debug release - - build.defines: variables to define during build - --> - - <target name="build"> - <csc target="exe" - define="${build.defines}" - debug="${build.debug}" - output="${build.dir}/${project::get-name()}.exe"> - - <sources> - <include name="**/*.cs" /> - </sources> - <references> - <include name="${build.dir}/log4net.dll" /> - <include name="${build.dir}/qpid.client.dll" /> - <include name="System.Configuration.dll" /> - </references> - </csc> - </target> -</project> - diff --git a/dotnet/client-010/examples/pub-sub/example-pub-sub-Publisher/example-pub-sub-Publisher.csproj b/dotnet/client-010/examples/pub-sub/example-pub-sub-Publisher/example-pub-sub-Publisher.csproj deleted file mode 100644 index a9dee76a36..0000000000 --- a/dotnet/client-010/examples/pub-sub/example-pub-sub-Publisher/example-pub-sub-Publisher.csproj +++ /dev/null @@ -1,85 +0,0 @@ -<?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 DefaultTargets="Build" xmlns="http://schemas.microsoft.com/developer/msbuild/2003" ToolsVersion="3.5"> - <PropertyGroup> - <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration> - <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform> - <ProductVersion>9.0.30729</ProductVersion> - <SchemaVersion>2.0</SchemaVersion> - <ProjectGuid>{F8857634-A134-44E7-A953-F2B22688C599}</ProjectGuid> - <OutputType>Exe</OutputType> - <AppDesignerFolder>Properties</AppDesignerFolder> - <RootNamespace>example_pub_sub_Publisher</RootNamespace> - <AssemblyName>example-pub-sub-Publisher</AssemblyName> - <FileUpgradeFlags> - </FileUpgradeFlags> - <OldToolsVersion>2.0</OldToolsVersion> - <UpgradeBackupLocation> - </UpgradeBackupLocation> - </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="System" /> - <Reference Include="System.configuration" /> - <Reference Include="System.Data" /> - <Reference Include="System.Xml" /> - </ItemGroup> - <ItemGroup> - <Compile Include="Publisher.cs" /> - <Compile Include="Properties\AssemblyInfo.cs" /> - </ItemGroup> - <ItemGroup> - <ProjectReference Include="..\..\..\client\Client.csproj"> - <Project>{B911FFD7-754F-4735-A188-218D5065BE79}</Project> - <Name>Client</Name> - </ProjectReference> - </ItemGroup> - <ItemGroup> - <None Include="..\..\..\App.config"> - <Link>App.config</Link> - </None> - </ItemGroup> - <Import Project="$(MSBuildBinPath)\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/dotnet/client-010/examples/pub-sub/verify b/dotnet/client-010/examples/pub-sub/verify deleted file mode 100644 index 45d80c4866..0000000000 --- a/dotnet/client-010/examples/pub-sub/verify +++ /dev/null @@ -1,36 +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. -# -# - -# See https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid/bin/verify - -pubsub_listener_dotnet() -{ -mono $DOTNET_EXAMPLES/example-pub-sub-Listener.exe localhost 5672 -} - -pubsub_producer_dotnet() -{ -mono $DOTNET_EXAMPLES/example-pub-sub-Publisher.exe localhost 5672 -} - -background "Listening for messages ..." pubsub_listener_dotnet -clients pubsub_producer_dotnet -outputs pubsub_producer_dotnet.out "pubsub_listener_dotnet.out | remove_uuid | sort" diff --git a/dotnet/client-010/examples/pub-sub/verify.in b/dotnet/client-010/examples/pub-sub/verify.in deleted file mode 100644 index 6a5adc4d89..0000000000 --- a/dotnet/client-010/examples/pub-sub/verify.in +++ /dev/null @@ -1,95 +0,0 @@ -==== pubsub_producer_dotnet.out -==== pubsub_listener_dotnet.out | remove_uuid | sort -Declaring queue: europe -Declaring queue: news -Declaring queue: usa -Declaring queue: weather -Listening for messages ... -Message: Message 0 from europe -Message: Message 0 from europe -Message: Message 0 from news -Message: Message 0 from news -Message: Message 0 from usa -Message: Message 0 from usa -Message: Message 0 from weather -Message: Message 0 from weather -Message: Message 1 from europe -Message: Message 1 from europe -Message: Message 1 from news -Message: Message 1 from news -Message: Message 1 from usa -Message: Message 1 from usa -Message: Message 1 from weather -Message: Message 1 from weather -Message: Message 2 from europe -Message: Message 2 from europe -Message: Message 2 from news -Message: Message 2 from news -Message: Message 2 from usa -Message: Message 2 from usa -Message: Message 2 from weather -Message: Message 2 from weather -Message: Message 3 from europe -Message: Message 3 from europe -Message: Message 3 from news -Message: Message 3 from news -Message: Message 3 from usa -Message: Message 3 from usa -Message: Message 3 from weather -Message: Message 3 from weather -Message: Message 4 from europe -Message: Message 4 from europe -Message: Message 4 from news -Message: Message 4 from news -Message: Message 4 from usa -Message: Message 4 from usa -Message: Message 4 from weather -Message: Message 4 from weather -Message: Message 5 from europe -Message: Message 5 from europe -Message: Message 5 from news -Message: Message 5 from news -Message: Message 5 from usa -Message: Message 5 from usa -Message: Message 5 from weather -Message: Message 5 from weather -Message: Message 6 from europe -Message: Message 6 from europe -Message: Message 6 from news -Message: Message 6 from news -Message: Message 6 from usa -Message: Message 6 from usa -Message: Message 6 from weather -Message: Message 6 from weather -Message: Message 7 from europe -Message: Message 7 from europe -Message: Message 7 from news -Message: Message 7 from news -Message: Message 7 from usa -Message: Message 7 from usa -Message: Message 7 from weather -Message: Message 7 from weather -Message: Message 8 from europe -Message: Message 8 from europe -Message: Message 8 from news -Message: Message 8 from news -Message: Message 8 from usa -Message: Message 8 from usa -Message: Message 8 from weather -Message: Message 8 from weather -Message: Message 9 from europe -Message: Message 9 from europe -Message: Message 9 from news -Message: Message 9 from news -Message: Message 9 from usa -Message: Message 9 from usa -Message: Message 9 from weather -Message: Message 9 from weather -Message: That's all, folks! from europe -Message: That's all, folks! from news -Message: That's all, folks! from usa -Message: That's all, folks! from weather -Shutting down listener for control -Shutting down listener for control -Shutting down listener for control -Shutting down listener for control diff --git a/dotnet/client-010/examples/pub-sub/verify_cpp_dotnet b/dotnet/client-010/examples/pub-sub/verify_cpp_dotnet deleted file mode 100644 index 39d92cbb8b..0000000000 --- a/dotnet/client-010/examples/pub-sub/verify_cpp_dotnet +++ /dev/null @@ -1,31 +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. -# - -# See https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid/bin/verify -cpp=$CPP/pub-sub - -pubsub_listener_dotnet() -{ -mono $DOTNET_EXAMPLES/example-pub-sub-Listener.exe localhost 5672 -} - - -background "Listening for messages ..." pubsub_listener_dotnet -clients $cpp/topic_publisher -outputs $cpp/topic_publisher.out "pubsub_listener_dotnet.out | remove_uuid | sort" diff --git a/dotnet/client-010/examples/pub-sub/verify_cpp_dotnet.in b/dotnet/client-010/examples/pub-sub/verify_cpp_dotnet.in deleted file mode 100644 index 4e058f7645..0000000000 --- a/dotnet/client-010/examples/pub-sub/verify_cpp_dotnet.in +++ /dev/null @@ -1,55 +0,0 @@ -==== topic_publisher.out -==== pubsub_listener_dotnet.out | remove_uuid | sort -Declaring queue: europe -Declaring queue: news -Declaring queue: usa -Declaring queue: weather -Listening for messages ... -Message: Message 0 from europe -Message: Message 0 from europe -Message: Message 0 from news -Message: Message 0 from news -Message: Message 0 from usa -Message: Message 0 from usa -Message: Message 0 from weather -Message: Message 0 from weather -Message: Message 1 from europe -Message: Message 1 from europe -Message: Message 1 from news -Message: Message 1 from news -Message: Message 1 from usa -Message: Message 1 from usa -Message: Message 1 from weather -Message: Message 1 from weather -Message: Message 2 from europe -Message: Message 2 from europe -Message: Message 2 from news -Message: Message 2 from news -Message: Message 2 from usa -Message: Message 2 from usa -Message: Message 2 from weather -Message: Message 2 from weather -Message: Message 3 from europe -Message: Message 3 from europe -Message: Message 3 from news -Message: Message 3 from news -Message: Message 3 from usa -Message: Message 3 from usa -Message: Message 3 from weather -Message: Message 3 from weather -Message: Message 4 from europe -Message: Message 4 from europe -Message: Message 4 from news -Message: Message 4 from news -Message: Message 4 from usa -Message: Message 4 from usa -Message: Message 4 from weather -Message: Message 4 from weather -Message: That's all, folks! from europe -Message: That's all, folks! from news -Message: That's all, folks! from usa -Message: That's all, folks! from weather -Shutting down listener for control -Shutting down listener for control -Shutting down listener for control -Shutting down listener for control diff --git a/dotnet/client-010/examples/pub-sub/verify_dotnet_cpp b/dotnet/client-010/examples/pub-sub/verify_dotnet_cpp deleted file mode 100644 index bf99e422a1..0000000000 --- a/dotnet/client-010/examples/pub-sub/verify_dotnet_cpp +++ /dev/null @@ -1,30 +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. -# - -# See https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid/bin/verify -cpp=$CPP/pub-sub - -pubsub_producer_dotnet() -{ -mono $DOTNET_EXAMPLES/example-pub-sub-Publisher.exe localhost 5672 -} - -background "Listening" $cpp/topic_listener -clients pubsub_producer_dotnet -outputs pubsub_producer_dotnet.out "$cpp/topic_listener.out | remove_uuid | sort" diff --git a/dotnet/client-010/examples/pub-sub/verify_dotnet_cpp.in b/dotnet/client-010/examples/pub-sub/verify_dotnet_cpp.in deleted file mode 100644 index 64ac27846d..0000000000 --- a/dotnet/client-010/examples/pub-sub/verify_dotnet_cpp.in +++ /dev/null @@ -1,99 +0,0 @@ -==== pubsub_producer_dotnet.out -==== topic_listener.out | remove_uuid | sort -Declaring queue: europe -Declaring queue: news -Declaring queue: usa -Declaring queue: weather -Listening for messages ... -Message: Message 0 from europe -Message: Message 0 from europe -Message: Message 0 from news -Message: Message 0 from news -Message: Message 0 from usa -Message: Message 0 from usa -Message: Message 0 from weather -Message: Message 0 from weather -Message: Message 1 from europe -Message: Message 1 from europe -Message: Message 1 from news -Message: Message 1 from news -Message: Message 1 from usa -Message: Message 1 from usa -Message: Message 1 from weather -Message: Message 1 from weather -Message: Message 2 from europe -Message: Message 2 from europe -Message: Message 2 from news -Message: Message 2 from news -Message: Message 2 from usa -Message: Message 2 from usa -Message: Message 2 from weather -Message: Message 2 from weather -Message: Message 3 from europe -Message: Message 3 from europe -Message: Message 3 from news -Message: Message 3 from news -Message: Message 3 from usa -Message: Message 3 from usa -Message: Message 3 from weather -Message: Message 3 from weather -Message: Message 4 from europe -Message: Message 4 from europe -Message: Message 4 from news -Message: Message 4 from news -Message: Message 4 from usa -Message: Message 4 from usa -Message: Message 4 from weather -Message: Message 4 from weather -Message: Message 5 from europe -Message: Message 5 from europe -Message: Message 5 from news -Message: Message 5 from news -Message: Message 5 from usa -Message: Message 5 from usa -Message: Message 5 from weather -Message: Message 5 from weather -Message: Message 6 from europe -Message: Message 6 from europe -Message: Message 6 from news -Message: Message 6 from news -Message: Message 6 from usa -Message: Message 6 from usa -Message: Message 6 from weather -Message: Message 6 from weather -Message: Message 7 from europe -Message: Message 7 from europe -Message: Message 7 from news -Message: Message 7 from news -Message: Message 7 from usa -Message: Message 7 from usa -Message: Message 7 from weather -Message: Message 7 from weather -Message: Message 8 from europe -Message: Message 8 from europe -Message: Message 8 from news -Message: Message 8 from news -Message: Message 8 from usa -Message: Message 8 from usa -Message: Message 8 from weather -Message: Message 8 from weather -Message: Message 9 from europe -Message: Message 9 from europe -Message: Message 9 from news -Message: Message 9 from news -Message: Message 9 from usa -Message: Message 9 from usa -Message: Message 9 from weather -Message: Message 9 from weather -Message: That's all, folks! from europe -Message: That's all, folks! from news -Message: That's all, folks! from usa -Message: That's all, folks! from weather -Shutting down listener for europe -Shutting down listener for news -Shutting down listener for usa -Shutting down listener for weather -Subscribing to queue europe -Subscribing to queue news -Subscribing to queue usa -Subscribing to queue weather diff --git a/dotnet/client-010/examples/request-response/example-request-response-Client/Properties/AssemblyInfo.cs b/dotnet/client-010/examples/request-response/example-request-response-Client/Properties/AssemblyInfo.cs deleted file mode 100644 index a438acaa1f..0000000000 --- a/dotnet/client-010/examples/request-response/example-request-response-Client/Properties/AssemblyInfo.cs +++ /dev/null @@ -1,54 +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. - * - */ - -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("example-request-response-Client")] -[assembly: AssemblyDescription("Built from svn revision number: ")] -[assembly: AssemblyConfiguration("")] -[assembly: AssemblyCompany("Apache Software Foundation")] -[assembly: AssemblyProduct("example-request-response-Client")] -[assembly: AssemblyCopyright("Apache Software Foundation")] -[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("08bf6aed-bf79-4d16-9a28-6363d5322cdd")] - -// Version information for an assembly consists of the following four values: -// -// Major Version -// Minor Version -// Build Number -// Revision -// -[assembly: AssemblyVersion("0.5.0.0")] -[assembly: AssemblyFileVersion("1.0.0.0")] diff --git a/dotnet/client-010/examples/request-response/example-request-response-Client/RequestResponseClient.cs b/dotnet/client-010/examples/request-response/example-request-response-Client/RequestResponseClient.cs deleted file mode 100644 index 170008c840..0000000000 --- a/dotnet/client-010/examples/request-response/example-request-response-Client/RequestResponseClient.cs +++ /dev/null @@ -1,142 +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. -*/ - -using System; -using System.Configuration; -using System.IO; -using System.Text; -using System.Threading; -using org.apache.qpid.client; -using org.apache.qpid.transport; - -namespace org.apache.qpid.example.requestresponse -{ - /// <summary> - /// This program is one of two programs that illustrate the - /// request/response pattern. - /// - /// Client (this program): - /// Make requests of a service, print the response. - /// - /// Server: - /// Accept requests, set the letters to uppercase in each message, and - /// return it as a response. - /// - /// </summary> - internal class RequestResponseClient - { - private static void Main(string[] args) - { - string host = ConfigurationManager.AppSettings["Host"]; - int port = int.Parse(ConfigurationManager.AppSettings["Port"]); - string virtualhost = ConfigurationManager.AppSettings["VirtualHost"]; - string username = ConfigurationManager.AppSettings["Username"]; - string password = ConfigurationManager.AppSettings["Password"]; - - Client connection = new Client(); - try - { - connection.Connect(host, port, virtualhost, username, password); - IClientSession session = connection.CreateSession(50000); - IMessage request = new Message(); - - //--------- Main body of program -------------------------------------------- - // Create a response queue so the server can send us responses - // to our requests. Use the client's session ID as the name - // of the response queue. - string response_queue = "client" + session.GetName(); - // Use the name of the response queue as the routing key - session.QueueDeclare(response_queue); - session.ExchangeBind(response_queue, "amq.direct", response_queue); - - // Each client sends the name of their own response queue so - // the service knows where to route messages. - request.DeliveryProperties.SetRoutingKey("request"); - request.MessageProperties.SetReplyTo(new ReplyTo("amq.direct", response_queue)); - - lock (session) - { - // Create a listener for the response queue and listen for response messages. - Console.WriteLine("Activating response queue listener for: " + response_queue); - IMessageListener listener = new ClientMessageListener(session); - session.AttachMessageListener(listener, response_queue); - session.MessageSubscribe(response_queue); - - // Now send some requests ... - string[] strs = { - "Twas brillig, and the slithy toves", - "Did gire and gymble in the wabe.", - "All mimsy were the borogroves,", - "And the mome raths outgrabe.", - "That's all, folks!" - }; - foreach (string s in strs) - { - request.ClearData(); - request.AppendData(Encoding.UTF8.GetBytes(s)); - session.MessageTransfer("amq.direct", request); - } - Console.WriteLine("Waiting for all responses to arrive ..."); - Monitor.Wait(session); - } - //--------------------------------------------------------------------------- - - connection.Close(); - } - catch (Exception e) - { - Console.WriteLine("Error: \n" + e.StackTrace); - } - } - } - - public class ClientMessageListener : IMessageListener - { - private readonly IClientSession _session; - private readonly RangeSet _range = new RangeSet(); - private int _counter; - public ClientMessageListener(IClientSession session) - { - _session = session; - } - - public void MessageTransfer(IMessage m) - { - _counter++; - BinaryReader reader = new BinaryReader(m.Body, Encoding.UTF8); - byte[] body = new byte[m.Body.Length - m.Body.Position]; - reader.Read(body, 0, body.Length); - ASCIIEncoding enc = new ASCIIEncoding(); - string message = enc.GetString(body); - Console.WriteLine("Response: " + message); - // Add this message to the list of message to be acknowledged - _range.Add(m.Id); - if (_counter == 4) - { - Console.WriteLine("Shutting down listener for " + m.DeliveryProperties.GetRoutingKey()); - // Acknowledge all the received messages - _session.MessageAccept(_range); - lock (_session) - { - Monitor.Pulse(_session); - } - } - } - } -} diff --git a/dotnet/client-010/examples/request-response/example-request-response-Client/default.build b/dotnet/client-010/examples/request-response/example-request-response-Client/default.build deleted file mode 100644 index c3d9af9baf..0000000000 --- a/dotnet/client-010/examples/request-response/example-request-response-Client/default.build +++ /dev/null @@ -1,48 +0,0 @@ -<?xml version="1.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. - ---> - -<project name="example-request-response-Client" default="build"> - <!-- - Properties that come from master build file - - build.dir: root directory for build - - build.debug: true if building debug release - - build.defines: variables to define during build - --> - - <target name="build"> - <csc target="exe" - define="${build.defines}" - debug="${build.debug}" - output="${build.dir}/${project::get-name()}.exe"> - - <sources> - <include name="**/*.cs" /> - </sources> - <references> - <include name="${build.dir}/log4net.dll" /> - <include name="${build.dir}/qpid.client.dll" /> - <include name="System.Configuration.dll" /> - </references> - </csc> - </target> -</project> - diff --git a/dotnet/client-010/examples/request-response/example-request-response-Client/example-request-response-Client.csproj b/dotnet/client-010/examples/request-response/example-request-response-Client/example-request-response-Client.csproj deleted file mode 100644 index 21dc6ceed4..0000000000 --- a/dotnet/client-010/examples/request-response/example-request-response-Client/example-request-response-Client.csproj +++ /dev/null @@ -1,85 +0,0 @@ -<?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 DefaultTargets="Build" xmlns="http://schemas.microsoft.com/developer/msbuild/2003" ToolsVersion="3.5"> - <PropertyGroup> - <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration> - <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform> - <ProductVersion>9.0.30729</ProductVersion> - <SchemaVersion>2.0</SchemaVersion> - <ProjectGuid>{1BC63815-4029-4039-9207-35E7E06ECC99}</ProjectGuid> - <OutputType>Exe</OutputType> - <AppDesignerFolder>Properties</AppDesignerFolder> - <RootNamespace>example_request_response_Client</RootNamespace> - <AssemblyName>example-request-response-Client</AssemblyName> - <FileUpgradeFlags> - </FileUpgradeFlags> - <OldToolsVersion>2.0</OldToolsVersion> - <UpgradeBackupLocation> - </UpgradeBackupLocation> - </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="System" /> - <Reference Include="System.configuration" /> - <Reference Include="System.Data" /> - <Reference Include="System.Xml" /> - </ItemGroup> - <ItemGroup> - <Compile Include="RequestResponseClient.cs" /> - <Compile Include="Properties\AssemblyInfo.cs" /> - </ItemGroup> - <ItemGroup> - <ProjectReference Include="..\..\..\client\Client.csproj"> - <Project>{B911FFD7-754F-4735-A188-218D5065BE79}</Project> - <Name>Client</Name> - </ProjectReference> - </ItemGroup> - <ItemGroup> - <None Include="..\..\..\App.config"> - <Link>App.config</Link> - </None> - </ItemGroup> - <Import Project="$(MSBuildBinPath)\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/dotnet/client-010/examples/request-response/example-request-response-Server/Properties/AssemblyInfo.cs b/dotnet/client-010/examples/request-response/example-request-response-Server/Properties/AssemblyInfo.cs deleted file mode 100644 index ba702a28cc..0000000000 --- a/dotnet/client-010/examples/request-response/example-request-response-Server/Properties/AssemblyInfo.cs +++ /dev/null @@ -1,54 +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. - * - */ - -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("example-request-response-Server")] -[assembly: AssemblyDescription("Built from svn revision number: ")] -[assembly: AssemblyConfiguration("")] -[assembly: AssemblyCompany("Apache Software Foundation")] -[assembly: AssemblyProduct("example-request-response-Server")] -[assembly: AssemblyCopyright("Apache Software Foundation")] -[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("ef3456e2-7c19-47aa-8dd6-aeaa88c5c4ad")] - -// Version information for an assembly consists of the following four values: -// -// Major Version -// Minor Version -// Build Number -// Revision -// -[assembly: AssemblyVersion("0.5.0.0")] -[assembly: AssemblyFileVersion("1.0.0.0")] diff --git a/dotnet/client-010/examples/request-response/example-request-response-Server/Server.cs b/dotnet/client-010/examples/request-response/example-request-response-Server/Server.cs deleted file mode 100644 index ea87627dbf..0000000000 --- a/dotnet/client-010/examples/request-response/example-request-response-Server/Server.cs +++ /dev/null @@ -1,141 +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. -*/ - -using System; -using System.Configuration; -using System.IO; -using System.Text; -using System.Threading; -using org.apache.qpid.client; -using org.apache.qpid.transport; - -namespace org.apache.qpid.example.requestresponse -{ - /// <summary> - /// This program is one of two programs that illustrate the - /// request/response pattern. - /// - /// Client: - /// Make requests of a service, print the response. - /// - /// Server (this program): - /// Accept requests, set the letters to uppercase in each message, and - /// return it as a response. - /// - /// </summary> - class Server - { - static void Main(string[] args) - { - string host = ConfigurationManager.AppSettings["Host"]; - int port = int.Parse(ConfigurationManager.AppSettings["Port"]); - string virtualhost = ConfigurationManager.AppSettings["VirtualHost"]; - string username = ConfigurationManager.AppSettings["Username"]; - string password = ConfigurationManager.AppSettings["Password"]; - - Client connection = new Client(); - try - { - connection.Connect(host, port, virtualhost, username, password); - IClientSession session = connection.CreateSession(50000); - - //--------- Main body of program -------------------------------------------- - // Create a request queue for clients to use when making - // requests. - const string request_queue = "request"; - // Use the name of the request queue as the routing key - session.QueueDeclare(request_queue); - session.ExchangeBind(request_queue, "amq.direct", request_queue); - - lock (session) - { - // Create a listener and subscribe it to the request_queue - IMessageListener listener = new MessageListener(session); - session.AttachMessageListener(listener, request_queue); - session.MessageSubscribe(request_queue); - // Receive messages until all messages are received - Console.WriteLine("Waiting for requests"); - Monitor.Wait(session); - } - - //--------------------------------------------------------------------------- - - connection.Close(); - } - catch (Exception e) - { - Console.WriteLine("Error: \n" + e.StackTrace); - } - } - } - - public class MessageListener : IMessageListener - { - private readonly IClientSession _session; - private readonly RangeSet _range = new RangeSet(); - public MessageListener(IClientSession session) - { - _session = session; - } - - public void MessageTransfer(IMessage request) - { - IMessage response = new Message(); - - // Get routing key for response from the request's replyTo property - string routingKey; - if( request.MessageProperties.HasReplyTo() ) - { - routingKey = request.MessageProperties.GetReplyTo().GetRoutingKey(); - } - else - { - Console.WriteLine("Error: \n No routing key for request " + request); - return; - } - - BinaryReader reader = new BinaryReader(request.Body, Encoding.UTF8); - byte[] body = new byte[request.Body.Length - request.Body.Position]; - reader.Read(body, 0, body.Length); - ASCIIEncoding enc = new ASCIIEncoding(); - string message = enc.GetString(body); - Console.WriteLine("Request: " + message); - - // Transform message content to upper case - string responseBody = message.ToUpper(); - - // Send it back to the user - response.ClearData(); - response.AppendData(Encoding.UTF8.GetBytes(responseBody)); - _session.MessageTransfer("amq.direct", routingKey, response); - - // Add this message to the list of message to be acknowledged - _range.Add(request.Id); - if (message.Equals("That's all, folks!")) - { - // Acknowledge all the received messages - _session.MessageAccept(_range); - lock (_session) - { - Monitor.Pulse(_session); - } - } - } - } -} diff --git a/dotnet/client-010/examples/request-response/example-request-response-Server/default.build b/dotnet/client-010/examples/request-response/example-request-response-Server/default.build deleted file mode 100644 index a3e4691d10..0000000000 --- a/dotnet/client-010/examples/request-response/example-request-response-Server/default.build +++ /dev/null @@ -1,48 +0,0 @@ -<?xml version="1.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. - ---> - -<project name="example-request-response-Server" default="build"> - <!-- - Properties that come from master build file - - build.dir: root directory for build - - build.debug: true if building debug release - - build.defines: variables to define during build - --> - - <target name="build"> - <csc target="exe" - define="${build.defines}" - debug="${build.debug}" - output="${build.dir}/${project::get-name()}.exe"> - - <sources> - <include name="**/*.cs" /> - </sources> - <references> - <include name="${build.dir}/log4net.dll" /> - <include name="${build.dir}/qpid.client.dll" /> - <include name="System.Configuration.dll" /> - </references> - </csc> - </target> -</project> - diff --git a/dotnet/client-010/examples/request-response/example-request-response-Server/example-request-response-Server.csproj b/dotnet/client-010/examples/request-response/example-request-response-Server/example-request-response-Server.csproj deleted file mode 100644 index 3eb2a3c035..0000000000 --- a/dotnet/client-010/examples/request-response/example-request-response-Server/example-request-response-Server.csproj +++ /dev/null @@ -1,85 +0,0 @@ -<?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 DefaultTargets="Build" xmlns="http://schemas.microsoft.com/developer/msbuild/2003" ToolsVersion="3.5"> - <PropertyGroup> - <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration> - <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform> - <ProductVersion>9.0.30729</ProductVersion> - <SchemaVersion>2.0</SchemaVersion> - <ProjectGuid>{922FBA9C-E483-4AEF-ABE8-AC87421E829B}</ProjectGuid> - <OutputType>Exe</OutputType> - <AppDesignerFolder>Properties</AppDesignerFolder> - <RootNamespace>example_request_response_Server</RootNamespace> - <AssemblyName>example-request-response-Server</AssemblyName> - <FileUpgradeFlags> - </FileUpgradeFlags> - <OldToolsVersion>2.0</OldToolsVersion> - <UpgradeBackupLocation> - </UpgradeBackupLocation> - </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="System" /> - <Reference Include="System.configuration" /> - <Reference Include="System.Data" /> - <Reference Include="System.Xml" /> - </ItemGroup> - <ItemGroup> - <Compile Include="Server.cs" /> - <Compile Include="Properties\AssemblyInfo.cs" /> - </ItemGroup> - <ItemGroup> - <ProjectReference Include="..\..\..\client\Client.csproj"> - <Project>{B911FFD7-754F-4735-A188-218D5065BE79}</Project> - <Name>Client</Name> - </ProjectReference> - </ItemGroup> - <ItemGroup> - <None Include="..\..\..\App.config"> - <Link>App.config</Link> - </None> - </ItemGroup> - <Import Project="$(MSBuildBinPath)\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/dotnet/client-010/examples/request-response/verify b/dotnet/client-010/examples/request-response/verify deleted file mode 100644 index fa69461f68..0000000000 --- a/dotnet/client-010/examples/request-response/verify +++ /dev/null @@ -1,36 +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. -# -# - -# See https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid/bin/verify - -server_dotnet() -{ -mono $DOTNET_EXAMPLES/example-request-response-Server.exe localhost 5672 -} - -client_dotnet() -{ -mono $DOTNET_EXAMPLES/example-request-response-Client.exe localhost 5672 -} - -background "Waiting for requests" server_dotnet -clients client_dotnet -outputs ./server_dotnet.out ./client_dotnet.out diff --git a/dotnet/client-010/examples/request-response/verify.in b/dotnet/client-010/examples/request-response/verify.in deleted file mode 100644 index 5357591289..0000000000 --- a/dotnet/client-010/examples/request-response/verify.in +++ /dev/null @@ -1,16 +0,0 @@ -==== server_dotnet.out -Waiting for requests -Request: Twas brillig, and the slithy toves -Request: Did gire and gymble in the wabe. -Request: All mimsy were the borogroves, -Request: And the mome raths outgrabe. -Request: That's all, folks! -==== client_dotnet.out -Activating response queue listener for: clientSystem.Byte[] -Waiting for all responses to arrive ... -Response: TWAS BRILLIG, AND THE SLITHY TOVES -Response: DID GIRE AND GYMBLE IN THE WABE. -Response: ALL MIMSY WERE THE BOROGROVES, -Response: AND THE MOME RATHS OUTGRABE. -Shutting down listener for clientSystem.Byte[] -Response: THAT'S ALL, FOLKS! diff --git a/dotnet/client-010/examples/request-response/verify_cpp_dotnet b/dotnet/client-010/examples/request-response/verify_cpp_dotnet deleted file mode 100644 index 791f48fe60..0000000000 --- a/dotnet/client-010/examples/request-response/verify_cpp_dotnet +++ /dev/null @@ -1,31 +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. -# - -# See https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid/bin/verify -cpp=$CPP/request-response - -client_dotnet() -{ -mono $DOTNET_EXAMPLES/example-request-response-Client.exe localhost 5672 -} - -background "Waiting" $cpp/server -clients client_dotnet -kill %% -outputs ./client_dotnet.out "$cpp/server.out | remove_uuid" diff --git a/dotnet/client-010/examples/request-response/verify_cpp_dotnet.in b/dotnet/client-010/examples/request-response/verify_cpp_dotnet.in deleted file mode 100644 index 0f4b5341b2..0000000000 --- a/dotnet/client-010/examples/request-response/verify_cpp_dotnet.in +++ /dev/null @@ -1,17 +0,0 @@ -==== client_dotnet.out -Activating response queue listener for: clientSystem.Byte[] -Waiting for all responses to arrive ... -Response: TWAS BRILLIG, AND THE SLITHY TOVES -Response: DID GIRE AND GYMBLE IN THE WABE. -Response: ALL MIMSY WERE THE BOROGROVES, -Response: AND THE MOME RATHS OUTGRABE. -Shutting down listener for clientSystem.Byte[] -Response: THAT'S ALL, FOLKS! -==== server.out | remove_uuid -Activating request queue listener for: request -Waiting for requests -Request: Twas brillig, and the slithy toves (clientSystem.Byte[]) -Request: Did gire and gymble in the wabe. (clientSystem.Byte[]) -Request: All mimsy were the borogroves, (clientSystem.Byte[]) -Request: And the mome raths outgrabe. (clientSystem.Byte[]) -Request: That's all, folks! (clientSystem.Byte[]) diff --git a/dotnet/client-010/examples/request-response/verify_dotnet_cpp b/dotnet/client-010/examples/request-response/verify_dotnet_cpp deleted file mode 100644 index 95905c43c9..0000000000 --- a/dotnet/client-010/examples/request-response/verify_dotnet_cpp +++ /dev/null @@ -1,31 +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. -# - -# See https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid/bin/verify -cpp=$CPP/request-response - -server_dotnet() -{ -mono $DOTNET_EXAMPLES/example-request-response-Server.exe localhost 5672 -} - -background "Waiting for requests" server_dotnet -clients $cpp/client -kill %% -outputs "$cpp/client.out | remove_uuid" ./server_dotnet.out diff --git a/dotnet/client-010/examples/request-response/verify_dotnet_cpp.in b/dotnet/client-010/examples/request-response/verify_dotnet_cpp.in deleted file mode 100644 index 849fad39c6..0000000000 --- a/dotnet/client-010/examples/request-response/verify_dotnet_cpp.in +++ /dev/null @@ -1,18 +0,0 @@ -==== client.out | remove_uuid -Activating response queue listener for: client -Request: Twas brillig, and the slithy toves -Request: Did gire and gymble in the wabe. -Request: All mimsy were the borogroves, -Request: And the mome raths outgrabe. -Waiting for all responses to arrive ... -Response: TWAS BRILLIG, AND THE SLITHY TOVES -Response: DID GIRE AND GYMBLE IN THE WABE. -Response: ALL MIMSY WERE THE BOROGROVES, -Response: AND THE MOME RATHS OUTGRABE. -Shutting down listener for client -==== server_dotnet.out -Waiting for requests -Request: Twas brillig, and the slithy toves -Request: Did gire and gymble in the wabe. -Request: All mimsy were the borogroves, -Request: And the mome raths outgrabe. |