diff options
Diffstat (limited to 'qpid/dotnet/client-010/examples/request-response/example-request-response-Client')
4 files changed, 0 insertions, 329 deletions
diff --git a/qpid/dotnet/client-010/examples/request-response/example-request-response-Client/Properties/AssemblyInfo.cs b/qpid/dotnet/client-010/examples/request-response/example-request-response-Client/Properties/AssemblyInfo.cs deleted file mode 100644 index a438acaa1f..0000000000 --- a/qpid/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/qpid/dotnet/client-010/examples/request-response/example-request-response-Client/RequestResponseClient.cs b/qpid/dotnet/client-010/examples/request-response/example-request-response-Client/RequestResponseClient.cs deleted file mode 100644 index 170008c840..0000000000 --- a/qpid/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/qpid/dotnet/client-010/examples/request-response/example-request-response-Client/default.build b/qpid/dotnet/client-010/examples/request-response/example-request-response-Client/default.build deleted file mode 100644 index c3d9af9baf..0000000000 --- a/qpid/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/qpid/dotnet/client-010/examples/request-response/example-request-response-Client/example-request-response-Client.csproj b/qpid/dotnet/client-010/examples/request-response/example-request-response-Client/example-request-response-Client.csproj deleted file mode 100644 index 21dc6ceed4..0000000000 --- a/qpid/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> |