diff --git a/.gitignore b/.gitignore index 7b68c3a874..a4a96a78d8 100644 --- a/.gitignore +++ b/.gitignore @@ -87,4 +87,4 @@ Backup*/ UpgradeLog*.XML UpgradeLog*.htm -projects/client/Unit/TestResult.xml +projects/client/Unit*/TestResult.xml diff --git a/Local.props.example b/Local.props.example index b240569cd2..a6849c68c0 100644 --- a/Local.props.example +++ b/Local.props.example @@ -4,14 +4,17 @@ v4.0 0.0.0.0 false - + - + mono --debug + + true + true @@ -19,4 +22,3 @@ - diff --git a/RabbitMQ.Client.nuspec b/RabbitMQ.Client.nuspec index a2f8d9e8b8..6f191bb507 100644 --- a/RabbitMQ.Client.nuspec +++ b/RabbitMQ.Client.nuspec @@ -19,7 +19,12 @@ + + + + + diff --git a/RabbitMQDotNetClient.sln b/RabbitMQDotNetClient.sln index b874d77fa1..91b22a470d 100644 --- a/RabbitMQDotNetClient.sln +++ b/RabbitMQDotNetClient.sln @@ -1,7 +1,7 @@  Microsoft Visual Studio Solution File, Format Version 12.00 # Visual Studio 2013 -VisualStudioVersion = 12.0.21005.1 +VisualStudioVersion = 12.0.31101.0 MinimumVisualStudioVersion = 10.0.40219.1 Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "projects", "projects", "{068D7DC3-8E6E-4951-B9E3-272C641BF0DE}" EndProject @@ -17,6 +17,8 @@ Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "wcf", "wcf", "{EA42A7EF-7CE EndProject Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "ConfigDemo", "ConfigDemo", "{20E34D9F-EE72-4B55-B6FE-1D0DBE5B74CD}" EndProject +Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "WinRT", "WinRT", "{5B87326D-1C2C-45A2-AD9E-4BD005A1629D}" +EndProject Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "RabbitMQ.Client.ApigenBootstrap", "projects\client\ApigenBootstrap\RabbitMQ.Client.ApigenBootstrap.csproj", "{CC8F4572-6730-4C4D-A0BB-15151E2A26AE}" EndProject Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "RabbitMQ.Client.Apigen", "projects\client\Apigen\RabbitMQ.Client.Apigen.csproj", "{9E8B8DC5-3837-46E9-90D7-8391CC62AB45}" @@ -64,6 +66,15 @@ Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "RabbitMQ.Client.Examples.Pe EndProject Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "RabbitMQ.Client.Examples.Subscriber", "projects\examples\client\Subscriber\RabbitMQ.Client.Examples.Subscriber.csproj", "{F6DF1899-A038-4DBF-86D0-0DE64F2422EC}" EndProject +Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "RabbitMQ.Client.WinRT", "projects\client\RabbitMQ.Client.WinRT\RabbitMQ.Client.WinRT.csproj", "{61D29F90-5B1C-4748-89FC-9FD2937F09C6}" + ProjectSection(ProjectDependencies) = postProject + {9E8B8DC5-3837-46E9-90D7-8391CC62AB45} = {9E8B8DC5-3837-46E9-90D7-8391CC62AB45} + EndProjectSection +EndProject +Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "RabbitMQ.Client.Examples.WinRT.Subscriber", "projects\examples\WinRT\Subscriber\RabbitMQ.Client.Examples.WinRT.Subscriber.csproj", "{6F01C132-7938-4001-8B70-D84EBAA662CC}" +EndProject +Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "RabbitMQ.Client.Unit.WinRT", "projects\client\Unit.WinRT\RabbitMQ.Client.Unit.WinRT.csproj", "{897505A9-8373-4F41-8DE8-221BF06D877D}" +EndProject Global GlobalSection(SolutionConfigurationPlatforms) = preSolution Debug|Any CPU = Debug|Any CPU @@ -202,6 +213,26 @@ Global {F6DF1899-A038-4DBF-86D0-0DE64F2422EC}.DebugNoTest|Any CPU.Build.0 = Debug|Any CPU {F6DF1899-A038-4DBF-86D0-0DE64F2422EC}.Release|Any CPU.ActiveCfg = Release|Any CPU {F6DF1899-A038-4DBF-86D0-0DE64F2422EC}.Release|Any CPU.Build.0 = Release|Any CPU + {61D29F90-5B1C-4748-89FC-9FD2937F09C6}.Debug|Any CPU.ActiveCfg = Debug|Any CPU + {61D29F90-5B1C-4748-89FC-9FD2937F09C6}.Debug|Any CPU.Build.0 = Debug|Any CPU + {61D29F90-5B1C-4748-89FC-9FD2937F09C6}.DebugNoTest|Any CPU.ActiveCfg = Debug|Any CPU + {61D29F90-5B1C-4748-89FC-9FD2937F09C6}.DebugNoTest|Any CPU.Build.0 = Debug|Any CPU + {61D29F90-5B1C-4748-89FC-9FD2937F09C6}.Release|Any CPU.ActiveCfg = Release|Any CPU + {61D29F90-5B1C-4748-89FC-9FD2937F09C6}.Release|Any CPU.Build.0 = Release|Any CPU + {6F01C132-7938-4001-8B70-D84EBAA662CC}.Debug|Any CPU.ActiveCfg = Debug|Any CPU + {6F01C132-7938-4001-8B70-D84EBAA662CC}.Debug|Any CPU.Build.0 = Debug|Any CPU + {6F01C132-7938-4001-8B70-D84EBAA662CC}.Debug|Any CPU.Deploy.0 = Debug|Any CPU + {6F01C132-7938-4001-8B70-D84EBAA662CC}.DebugNoTest|Any CPU.ActiveCfg = Debug|Any CPU + {6F01C132-7938-4001-8B70-D84EBAA662CC}.DebugNoTest|Any CPU.Build.0 = Debug|Any CPU + {6F01C132-7938-4001-8B70-D84EBAA662CC}.DebugNoTest|Any CPU.Deploy.0 = Debug|Any CPU + {6F01C132-7938-4001-8B70-D84EBAA662CC}.Release|Any CPU.ActiveCfg = Release|Any CPU + {6F01C132-7938-4001-8B70-D84EBAA662CC}.Release|Any CPU.Build.0 = Release|Any CPU + {6F01C132-7938-4001-8B70-D84EBAA662CC}.Release|Any CPU.Deploy.0 = Release|Any CPU + {897505A9-8373-4F41-8DE8-221BF06D877D}.Debug|Any CPU.ActiveCfg = Debug|Any CPU + {897505A9-8373-4F41-8DE8-221BF06D877D}.Debug|Any CPU.Build.0 = Debug|Any CPU + {897505A9-8373-4F41-8DE8-221BF06D877D}.DebugNoTest|Any CPU.ActiveCfg = Debug|Any CPU + {897505A9-8373-4F41-8DE8-221BF06D877D}.Release|Any CPU.ActiveCfg = Release|Any CPU + {897505A9-8373-4F41-8DE8-221BF06D877D}.Release|Any CPU.Build.0 = Release|Any CPU EndGlobalSection GlobalSection(SolutionProperties) = preSolution HideSolutionNode = FALSE @@ -210,13 +241,15 @@ Global {ECCBAEE2-24C9-4C95-A88C-03B68E866F0F} = {068D7DC3-8E6E-4951-B9E3-272C641BF0DE} {9093855F-C802-407D-B127-CADD8F92FCD8} = {068D7DC3-8E6E-4951-B9E3-272C641BF0DE} {23B4D18E-E5D3-4BF8-A488-021B96A5DD72} = {068D7DC3-8E6E-4951-B9E3-272C641BF0DE} + {78D13AD2-B1AC-442C-95C8-958D643FC40B} = {23B4D18E-E5D3-4BF8-A488-021B96A5DD72} + {EA42A7EF-7CE6-4EDA-98EA-6675C7EF7F69} = {23B4D18E-E5D3-4BF8-A488-021B96A5DD72} + {20E34D9F-EE72-4B55-B6FE-1D0DBE5B74CD} = {EA42A7EF-7CE6-4EDA-98EA-6675C7EF7F69} + {5B87326D-1C2C-45A2-AD9E-4BD005A1629D} = {23B4D18E-E5D3-4BF8-A488-021B96A5DD72} {CC8F4572-6730-4C4D-A0BB-15151E2A26AE} = {ECCBAEE2-24C9-4C95-A88C-03B68E866F0F} {9E8B8DC5-3837-46E9-90D7-8391CC62AB45} = {ECCBAEE2-24C9-4C95-A88C-03B68E866F0F} {71713FDD-D5EC-40B2-A924-76F80AD57E12} = {ECCBAEE2-24C9-4C95-A88C-03B68E866F0F} {DC9022AA-DC30-4871-AD28-3F166E05DBB5} = {ECCBAEE2-24C9-4C95-A88C-03B68E866F0F} {5117232B-EE07-46F8-8AF5-2B636F1DBF56} = {9093855F-C802-407D-B127-CADD8F92FCD8} - {78D13AD2-B1AC-442C-95C8-958D643FC40B} = {23B4D18E-E5D3-4BF8-A488-021B96A5DD72} - {EA42A7EF-7CE6-4EDA-98EA-6675C7EF7F69} = {23B4D18E-E5D3-4BF8-A488-021B96A5DD72} {F03945AD-08C5-4531-805C-5B0BA110E9CF} = {78D13AD2-B1AC-442C-95C8-958D643FC40B} {95E9B6BE-FCA4-4C59-AFAB-1D974D972981} = {78D13AD2-B1AC-442C-95C8-958D643FC40B} {7B63B8B6-6D7B-4A97-B842-F92106300EF5} = {78D13AD2-B1AC-442C-95C8-958D643FC40B} @@ -226,14 +259,16 @@ Global {A626CC84-04E9-4614-A389-FCE3122BE6BC} = {78D13AD2-B1AC-442C-95C8-958D643FC40B} {23680866-F877-4E06-B999-FDFD0B6A8CF6} = {78D13AD2-B1AC-442C-95C8-958D643FC40B} {6BF8B993-1722-446E-89B3-7BAC6066BECC} = {78D13AD2-B1AC-442C-95C8-958D643FC40B} + {201B37E1-9BFC-4A01-9760-30C5BB19CFE3} = {20E34D9F-EE72-4B55-B6FE-1D0DBE5B74CD} + {8D0DEB29-349C-4617-B61E-B22DE144BD22} = {20E34D9F-EE72-4B55-B6FE-1D0DBE5B74CD} + {034B2E6C-78F4-4205-A73A-5D74E83B5F26} = {20E34D9F-EE72-4B55-B6FE-1D0DBE5B74CD} + {39CA1299-1F9E-452E-AA00-4BF874944B1E} = {EA42A7EF-7CE6-4EDA-98EA-6675C7EF7F69} {44D14FF0-1015-4AAA-ABCA-BF611879816C} = {78D13AD2-B1AC-442C-95C8-958D643FC40B} {8BCE15DB-C92F-4FA4-AE57-9CA73DE91EB2} = {78D13AD2-B1AC-442C-95C8-958D643FC40B} {6ED176D6-B789-4673-8300-CB671962FE00} = {78D13AD2-B1AC-442C-95C8-958D643FC40B} {F6DF1899-A038-4DBF-86D0-0DE64F2422EC} = {78D13AD2-B1AC-442C-95C8-958D643FC40B} - {20E34D9F-EE72-4B55-B6FE-1D0DBE5B74CD} = {EA42A7EF-7CE6-4EDA-98EA-6675C7EF7F69} - {39CA1299-1F9E-452E-AA00-4BF874944B1E} = {EA42A7EF-7CE6-4EDA-98EA-6675C7EF7F69} - {201B37E1-9BFC-4A01-9760-30C5BB19CFE3} = {20E34D9F-EE72-4B55-B6FE-1D0DBE5B74CD} - {8D0DEB29-349C-4617-B61E-B22DE144BD22} = {20E34D9F-EE72-4B55-B6FE-1D0DBE5B74CD} - {034B2E6C-78F4-4205-A73A-5D74E83B5F26} = {20E34D9F-EE72-4B55-B6FE-1D0DBE5B74CD} + {61D29F90-5B1C-4748-89FC-9FD2937F09C6} = {ECCBAEE2-24C9-4C95-A88C-03B68E866F0F} + {6F01C132-7938-4001-8B70-D84EBAA662CC} = {5B87326D-1C2C-45A2-AD9E-4BD005A1629D} + {897505A9-8373-4F41-8DE8-221BF06D877D} = {ECCBAEE2-24C9-4C95-A88C-03B68E866F0F} EndGlobalSection EndGlobal diff --git a/RabbitMQDotNetClient.sln.DotSettings b/RabbitMQDotNetClient.sln.DotSettings index c418d2b7c4..3ca61f6169 100644 --- a/RabbitMQDotNetClient.sln.DotSettings +++ b/RabbitMQDotNetClient.sln.DotSettings @@ -100,6 +100,167 @@ CHOP_ALWAYS True True + <Patterns xmlns="urn:schemas-jetbrains-com:member-reordering-patterns"> + <TypePattern DisplayName="COM interfaces or structs"> + <TypePattern.Match> + <Or> + <And> + <Kind Is="Interface" /> + <Or> + <HasAttribute Name="System.Runtime.InteropServices.InterfaceTypeAttribute" /> + <HasAttribute Name="System.Runtime.InteropServices.ComImport" /> + </Or> + </And> + <HasAttribute Name="System.Runtime.InteropServices.StructLayoutAttribute" /> + </Or> + </TypePattern.Match> + </TypePattern> + + <TypePattern DisplayName="NUnit Test Fixtures" RemoveRegions="All"> + <TypePattern.Match> + <And> + <Kind Is="Class" /> + <HasAttribute Name="NUnit.Framework.TestFixtureAttribute" Inherited="true" /> + <HasAttribute Name="NUnit.Framework.TestCaseFixtureAttribute" Inherited="true" /> + </And> + </TypePattern.Match> + + <Entry DisplayName="Setup/Teardown Methods"> + <Entry.Match> + <And> + <Kind Is="Method" /> + <Or> + <HasAttribute Name="NUnit.Framework.SetUpAttribute" Inherited="true" /> + <HasAttribute Name="NUnit.Framework.TearDownAttribute" Inherited="true" /> + <HasAttribute Name="NUnit.Framework.FixtureSetUpAttribute" Inherited="true" /> + <HasAttribute Name="NUnit.Framework.FixtureTearDownAttribute" Inherited="true" /> + </Or> + </And> + </Entry.Match> + </Entry> + + <Entry DisplayName="All other members" /> + + <Entry DisplayName="Test Methods" Priority="100"> + <Entry.Match> + <And> + <Kind Is="Method" /> + <HasAttribute Name="NUnit.Framework.TestAttribute" Inherited="false" /> + </And> + </Entry.Match> + + <Entry.SortBy> + <Name /> + </Entry.SortBy> + </Entry> + </TypePattern> + + <TypePattern DisplayName="Default Pattern"> + <Entry DisplayName="Public Delegates" Priority="100"> + <Entry.Match> + <And> + <Access Is="Public" /> + <Kind Is="Delegate" /> + </And> + </Entry.Match> + + <Entry.SortBy> + <Name /> + </Entry.SortBy> + </Entry> + + <Entry DisplayName="Public Enums" Priority="100"> + <Entry.Match> + <And> + <Access Is="Public" /> + <Kind Is="Enum" /> + </And> + </Entry.Match> + + <Entry.SortBy> + <Name /> + </Entry.SortBy> + </Entry> + + <Entry DisplayName="Static Fields and Constants"> + <Entry.Match> + <Or> + <Kind Is="Constant" /> + <And> + <Kind Is="Field" /> + <Static /> + </And> + </Or> + </Entry.Match> + + <Entry.SortBy> + <Kind> + <Kind.Order> + <DeclarationKind>Constant</DeclarationKind> + <DeclarationKind>Field</DeclarationKind> + </Kind.Order> + </Kind> + </Entry.SortBy> + </Entry> + + <Entry DisplayName="Fields"> + <Entry.Match> + <And> + <Kind Is="Field" /> + <Not> + <Static /> + </Not> + </And> + </Entry.Match> + + <Entry.SortBy> + <Readonly /> + <Name /> + </Entry.SortBy> + </Entry> + + <Entry DisplayName="Constructors"> + <Entry.Match> + <Kind Is="Constructor" /> + </Entry.Match> + + <Entry.SortBy> + <Static/> + </Entry.SortBy> + </Entry> + + <Entry DisplayName="Properties, Indexers"> + <Entry.Match> + <Or> + <Kind Is="Property" /> + <Kind Is="Indexer" /> + </Or> + </Entry.Match> + </Entry> + + <Entry DisplayName="Interface Implementations" Priority="100"> + <Entry.Match> + <And> + <Kind Is="Member" /> + <ImplementsInterface /> + </And> + </Entry.Match> + + <Entry.SortBy> + <ImplementsInterface Immediate="true" /> + </Entry.SortBy> + </Entry> + + <Entry DisplayName="All other members" /> + + <Entry DisplayName="Nested Types"> + <Entry.Match> + <Kind Is="Type" /> + </Entry.Match> + </Entry> + </TypePattern> +</Patterns> + <?xml version="1.0" encoding="utf-8" ?> <!-- @@ -396,5 +557,8 @@ II.2.12 <HandlesEvent /> <Policy Inspect="True" Prefix="" Suffix="" Style="aaBb" /> <Policy Inspect="True" Prefix="" Suffix="" Style="aaBb" /> $object$_On$event$ + True + True True + True True \ No newline at end of file diff --git a/projects/client/RabbitMQ.Client.WinRT/RabbitMQ.Client.WinRT.csproj b/projects/client/RabbitMQ.Client.WinRT/RabbitMQ.Client.WinRT.csproj new file mode 100644 index 0000000000..3bb85ef3eb --- /dev/null +++ b/projects/client/RabbitMQ.Client.WinRT/RabbitMQ.Client.WinRT.csproj @@ -0,0 +1,160 @@ + + + + + + $(MSBuildProjectDirectory)\..\..\..\lib\MSBuild.Community.Tasks\ + + + + + ..\..\..\gensrc\$(MSBuildProjectName)\ + + + + + + + ..\..\..\docs\specs\ + amqp0-9-1.stripped.xml + amqp0-9.stripped.xml + $(SpecsDir)$(AmqpSpec0_9_1BaseName) + autogenerated-api-0-9-1.cs + $(GensrcDir)$(AutogeneratedApi0_9_1BaseName) + ..\Apigen\build\bin\rabbitmq-dotnet-apigen.exe + + + + specs\$(AmqpSpec0_9_1BaseName) + + + src\gensrc\$(AutogeneratedApi0_9_1BaseName) + + + false + + + + + + + + + + + 4.5 + AssemblyInfo.cs + src\tokenized\$(AssemblyInfoBaseName).in + $(GensrcDir)$(AssemblyInfoBaseName) + + + + + properties\$(AssemblyInfoBaseName) + + + false + + + $(PropAssemblyVersion) + false + + + + + + + + + + + + + Debug + AnyCPU + 9.0.21022 + 2.0 + {61D29F90-5B1C-4748-89FC-9FD2937F09C6} + Library + properties + RabbitMQ.Client + RabbitMQ.Client + en-US + 512 + {BC8A1FFA-BEE3-4634-8014-F334798102B3};{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC} + + + true + full + false + build\bin\ + DEBUG;TRACE;NETFX_CORE + none + 4 + build\bin\RabbitMQ.Client.xml + 1591 + Auto + false + false + true + + + pdbonly + true + build\bin\ + TRACE;NETFX_CORE + none + 4 + build\bin\RabbitMQ.Client.xml + 1591 + true + false + true + $(PropKeyfile) + true + + + + src\client\%(RecursiveDir)%(Filename)%(Extension) + + + src\util\%(RecursiveDir)%(Filename)%(Extension) + + + + + + + + + + + + + + + <_DisabledWarnings>$(NoWarn) + + + + + + + + + + + + + + + + + 11.0 + + + + + + + diff --git a/projects/client/RabbitMQ.Client.WinRT/src/client/impl/SocketFrameHandler.cs b/projects/client/RabbitMQ.Client.WinRT/src/client/impl/SocketFrameHandler.cs new file mode 100644 index 0000000000..27df47bc71 --- /dev/null +++ b/projects/client/RabbitMQ.Client.WinRT/src/client/impl/SocketFrameHandler.cs @@ -0,0 +1,242 @@ +// This source code is dual-licensed under the Apache License, version +// 2.0, and the Mozilla Public License, version 1.1. +// +// The APL v2.0: +// +//--------------------------------------------------------------------------- +// Copyright (C) 2007-2014 GoPivotal, Inc. +// +// Licensed 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. +//--------------------------------------------------------------------------- +// +// The MPL v1.1: +// +//--------------------------------------------------------------------------- +// The contents of this file are subject to the Mozilla Public License +// Version 1.1 (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.mozilla.org/MPL/ +// +// Software distributed under the License is distributed on an "AS IS" +// basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See +// the License for the specific language governing rights and +// limitations under the License. +// +// The Original Code is RabbitMQ. +// +// The Initial Developer of the Original Code is GoPivotal, Inc. +// Copyright (c) 2007-2014 GoPivotal, Inc. All rights reserved. +//--------------------------------------------------------------------------- + +using System; +using System.IO; +using System.Text; + +using System.Threading; + +using Windows.Foundation; +using Windows.Networking; +using Windows.Networking.Sockets; + +using RabbitMQ.Util; +using RabbitMQ.Client.Exceptions; + +namespace RabbitMQ.Client.Impl +{ + /// + /// Implement for WinRT. The significant + /// difference is that TcpClient is not available and the new + /// needs to be used. + /// + public class SocketFrameHandler : IFrameHandler + { + // Timeout in seconds to wait for a clean socket close. + public const int SOCKET_CLOSING_TIMEOUT = 1; + + public StreamSocket m_socket; + private CancellationTokenSource cts; + public NetworkBinaryReader m_reader; + public NetworkBinaryWriter m_writer; + private bool _closed = false; + private readonly object _semaphore = new object(); + + private int? defaultTimeout; + + public SocketFrameHandler(AmqpTcpEndpoint endpoint, + Func socketFactory, + int timeout) + { + Endpoint = endpoint; + + m_socket = socketFactory(); + Connect(m_socket, endpoint, timeout); + + if (endpoint.Ssl.Enabled) + { + IAsyncAction ar = null; + try + { + cts = new CancellationTokenSource(); + if (this.defaultTimeout.HasValue) + cts.CancelAfter(this.defaultTimeout.Value); + + ar = this.m_socket.UpgradeToSslAsync( + SocketProtectionLevel.Ssl, new HostName(endpoint.Ssl.ServerName)); + ar.AsTask(cts.Token).Wait(); + ar.GetResults(); + } + catch (Exception) + { + Close(); + throw; + } + finally + { + if (ar != null) + ar.Close(); + } + } + m_reader = new NetworkBinaryReader(m_socket.InputStream.AsStreamForRead()); + m_writer = new NetworkBinaryWriter(m_socket.OutputStream.AsStreamForWrite()); + } + + public AmqpTcpEndpoint Endpoint { get; set; } + + public int LocalPort + { + get + { + // the port string may be empty, so TryParse will set to 0; + int port; + Int32.TryParse(m_socket.Information.LocalPort, out port); + return port; + } + } + public int RemotePort + { + get + { + // the port string may be empty, so TryParse will set to 0; + int port; + Int32.TryParse(m_socket.Information.RemotePort, out port); + return port; + } + } + + public int Timeout + { + set + { + defaultTimeout = value; + if (cts != null && cts.Token.CanBeCanceled) + { + cts.CancelAfter(value); + } + } + } + + public void Close() + { + lock (_semaphore) + { + if (!_closed) + { + // TODO: Figure out the equivalent for LingerState + //m_socket.LingerState = new LingerOption(true, SOCKET_CLOSING_TIMEOUT); + m_socket.Dispose(); + _closed = true; + } + } + } + + public Frame ReadFrame() + { + lock (m_reader) + { + return Frame.ReadFrom(m_reader); + } + } + + public void SendHeader() + { + lock (m_writer) + { + m_writer.Write(Encoding.UTF8.GetBytes("AMQP")); + if (Endpoint.Protocol.Revision != 0) + { + m_writer.Write((byte)0); + m_writer.Write((byte)Endpoint.Protocol.MajorVersion); + m_writer.Write((byte)Endpoint.Protocol.MinorVersion); + m_writer.Write((byte)Endpoint.Protocol.Revision); + } + else + { + m_writer.Write((byte)1); + m_writer.Write((byte)1); + m_writer.Write((byte)Endpoint.Protocol.MajorVersion); + m_writer.Write((byte)Endpoint.Protocol.MinorVersion); + } + m_writer.Flush(); + } + } + + public void WriteFrame(Frame frame) + { + lock (m_writer) + { + frame.WriteTo(m_writer); + m_writer.Flush(); + } + } + + private void Connect(StreamSocket socket, AmqpTcpEndpoint endpoint, int timeout) + { + IAsyncAction ar = null; + try + { + cts = new CancellationTokenSource(); + if (this.defaultTimeout.HasValue) + cts.CancelAfter(this.defaultTimeout.Value); + + ar = socket.ConnectAsync(new HostName(endpoint.HostName), endpoint.Port.ToString(), SocketProtectionLevel.PlainSocket); + if (!ar.AsTask(cts.Token).Wait(timeout)) + { + socket.Dispose(); + throw new TimeoutException("Connection to " + endpoint + " timed out"); + } + ar.GetResults(); + } + catch (ArgumentException e) + { + throw new ConnectFailureException("Connection failed", e); + } + catch (Exception e) + { + // If this is an unknown status it means that the error is fatal and retry will likely fail. + if (SocketError.GetStatus(e.HResult) == SocketErrorStatus.Unknown) + { + throw; + } + + throw new ConnectFailureException("Connection failed", e); + } + finally + { + if (ar != null) + { + ar.Close(); + } + } + } + } +} diff --git a/projects/client/RabbitMQ.Client.WinRT/src/tokenized/AssemblyInfo.cs.in b/projects/client/RabbitMQ.Client.WinRT/src/tokenized/AssemblyInfo.cs.in new file mode 100644 index 0000000000..49939dd39f --- /dev/null +++ b/projects/client/RabbitMQ.Client.WinRT/src/tokenized/AssemblyInfo.cs.in @@ -0,0 +1,55 @@ +// This source code is dual-licensed under the Apache License, version +// 2.0, and the Mozilla Public License, version 1.1. +// +// The APL v2.0: +// +//--------------------------------------------------------------------------- +// Copyright (C) 2007-2014 GoPivotal, Inc. +// +// Licensed 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. +//--------------------------------------------------------------------------- +// +// The MPL v1.1: +// +//--------------------------------------------------------------------------- +// The contents of this file are subject to the Mozilla Public License +// Version 1.1 (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.mozilla.org/MPL/ +// +// Software distributed under the License is distributed on an "AS IS" +// basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See +// the License for the specific language governing rights and +// limitations under the License. +// +// The Original Code is RabbitMQ. +// +// The Initial Developer of the Original Code is GoPivotal, Inc. +// Copyright (c) 2007-2014 GoPivotal, Inc. All rights reserved. +//--------------------------------------------------------------------------- + +using System.Reflection; +using System.Runtime.CompilerServices; +using System.Runtime.InteropServices; + +[assembly: AssemblyTitle("RabbitMQ Client Library for .Net")] +[assembly: AssemblyDescription("Open Source Enterprise Messaging")] +[assembly: AssemblyConfiguration("")] +[assembly: AssemblyCompany("GoPivotal, Inc.")] +[assembly: AssemblyProduct("RabbitMQ")] +[assembly: AssemblyCopyright("Copyright © 2007-2014 GoPivotal, Inc.")] +[assembly: AssemblyTrademark("")] +[assembly: AssemblyCulture("")] + +[assembly: AssemblyVersion("${PropAssemblyVersion}")] + diff --git a/projects/client/RabbitMQ.Client.WinRT/src/util/ICloneable.cs b/projects/client/RabbitMQ.Client.WinRT/src/util/ICloneable.cs new file mode 100644 index 0000000000..d88ff298bb --- /dev/null +++ b/projects/client/RabbitMQ.Client.WinRT/src/util/ICloneable.cs @@ -0,0 +1,49 @@ +// This source code is dual-licensed under the Apache License, version +// 2.0, and the Mozilla Public License, version 1.1. +// +// The APL v2.0: +// +//--------------------------------------------------------------------------- +// Copyright (C) 2007-2014 GoPivotal, Inc. +// +// Licensed 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. +//--------------------------------------------------------------------------- +// +// The MPL v1.1: +// +//--------------------------------------------------------------------------- +// The contents of this file are subject to the Mozilla Public License +// Version 1.1 (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.mozilla.org/MPL/ +// +// Software distributed under the License is distributed on an "AS IS" +// basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See +// the License for the specific language governing rights and +// limitations under the License. +// +// The Original Code is RabbitMQ. +// +// The Initial Developer of the Original Code is GoPivotal, Inc. +// Copyright (c) 2013-2014 GoPivotal, Inc. All rights reserved. +//--------------------------------------------------------------------------- + +namespace System +{ +#if (NETFX_CORE) + public interface ICloneable + { + object Clone(); + } +#endif +} \ No newline at end of file diff --git a/projects/client/RabbitMQ.Client.WinRT/src/util/MetroEventSource.cs b/projects/client/RabbitMQ.Client.WinRT/src/util/MetroEventSource.cs new file mode 100644 index 0000000000..803cb16ea3 --- /dev/null +++ b/projects/client/RabbitMQ.Client.WinRT/src/util/MetroEventSource.cs @@ -0,0 +1,79 @@ +// This source code is dual-licensed under the Apache License, version +// 2.0, and the Mozilla Public License, version 1.1. +// +// The APL v2.0: +// +//--------------------------------------------------------------------------- +// Copyright (C) 2007-2014 GoPivotal, Inc. +// +// Licensed 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. +//--------------------------------------------------------------------------- +// +// The MPL v1.1: +// +//--------------------------------------------------------------------------- +// The contents of this file are subject to the Mozilla Public License +// Version 1.1 (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.mozilla.org/MPL/ +// +// Software distributed under the License is distributed on an "AS IS" +// basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See +// the License for the specific language governing rights and +// limitations under the License. +// +// The Original Code is RabbitMQ. +// +// The Initial Developer of the Original Code is GoPivotal, Inc. +// Copyright (c) 2013-2014 GoPivotal, Inc. All rights reserved. +//--------------------------------------------------------------------------- + +using System.Diagnostics.Tracing; + +namespace RabbitMQ.Util +{ + public class MetroEventSource : EventSource + { + public static MetroEventSource Log = new MetroEventSource(); + + [Event(1, Level = EventLevel.Verbose)] + public void Debug(string message) + { + this.WriteEvent(1, message); + } + + [Event(2, Level = EventLevel.Informational)] + public void Info(string message) + { + this.WriteEvent(2, message); + } + + [Event(3, Level = EventLevel.Warning)] + public void Warn(string message) + { + this.WriteEvent(3, message); + } + + [Event(4, Level = EventLevel.Error)] + public void Error(string message) + { + this.WriteEvent(4, message); + } + + [Event(5, Level = EventLevel.Critical)] + public void Critical(string message) + { + this.WriteEvent(5, message); + } + } +} \ No newline at end of file diff --git a/projects/client/RabbitMQ.Client.WinRT/src/util/SerializableAttribute.cs b/projects/client/RabbitMQ.Client.WinRT/src/util/SerializableAttribute.cs new file mode 100644 index 0000000000..68bcf22a62 --- /dev/null +++ b/projects/client/RabbitMQ.Client.WinRT/src/util/SerializableAttribute.cs @@ -0,0 +1,48 @@ +// This source code is dual-licensed under the Apache License, version +// 2.0, and the Mozilla Public License, version 1.1. +// +// The APL v2.0: +// +//--------------------------------------------------------------------------- +// Copyright (C) 2007-2014 GoPivotal, Inc. +// +// Licensed 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. +//--------------------------------------------------------------------------- +// +// The MPL v1.1: +// +//--------------------------------------------------------------------------- +// The contents of this file are subject to the Mozilla Public License +// Version 1.1 (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.mozilla.org/MPL/ +// +// Software distributed under the License is distributed on an "AS IS" +// basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See +// the License for the specific language governing rights and +// limitations under the License. +// +// The Original Code is RabbitMQ. +// +// The Initial Developer of the Original Code is GoPivotal, Inc. +// Copyright (c) 2013-2014 GoPivotal, Inc. All rights reserved. +//--------------------------------------------------------------------------- + +namespace System +{ +#if (NETFX_CORE) + internal class SerializableAttribute : Attribute + { + } +#endif +} \ No newline at end of file diff --git a/projects/client/RabbitMQ.Client.WinRT/src/util/SortedList.cs b/projects/client/RabbitMQ.Client.WinRT/src/util/SortedList.cs new file mode 100644 index 0000000000..bd969c4cbf --- /dev/null +++ b/projects/client/RabbitMQ.Client.WinRT/src/util/SortedList.cs @@ -0,0 +1,1304 @@ +// +// System.Collections.Generic.SortedList.cs +// +// Author: +// Sergey Chaban (serge@wildwestsoftware.com) +// Duncan Mak (duncan@ximian.com) +// Herve Poussineau (hpoussineau@fr.st +// Zoltan Varga (vargaz@gmail.com) +// + +// +// Copyright (C) 2004 Novell, Inc (http://www.novell.com) +// +// Permission is hereby granted, free of charge, to any person obtaining +// a copy of this software and associated documentation files (the +// "Software"), to deal in the Software without restriction, including +// without limitation the rights to use, copy, modify, merge, publish, +// distribute, sublicense, and/or sell copies of the Software, and to +// permit persons to whom the Software is furnished to do so, subject to +// the following conditions: +// +// The above copyright notice and this permission notice shall be +// included in all copies or substantial portions of the Software. +// +// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, +// EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF +// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND +// NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE +// LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION +// OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION +// WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. +// + + +using System; +using System.Collections; +using System.Collections.Generic; +using System.Diagnostics; + +namespace RabbitMQ.Util +{ + /// + /// Represents a collection of associated keys and values + /// that are sorted by the keys and are accessible by key + /// and by index. + /// + [DebuggerDisplay("Count={Count}")] + internal class SortedList : IDictionary, + IDictionary, + ICollection, + ICollection>, + IEnumerable>, + IEnumerable + { + + private readonly static int INITIAL_SIZE = 16; + + private enum EnumeratorMode : int { KEY_MODE = 0, VALUE_MODE, ENTRY_MODE } + + private int inUse; + private int modificationCount; + private KeyValuePair[] table; + private IComparer comparer; + private int defaultCapacity; + + // + // Constructors + // + public SortedList() + : this(INITIAL_SIZE, null) + { + } + + public SortedList(int capacity) + : this(capacity, null) + { + } + + public SortedList(int capacity, IComparer comparer) + { + if (capacity < 0) + throw new ArgumentOutOfRangeException("initialCapacity"); + + if (capacity == 0) + defaultCapacity = 0; + else + defaultCapacity = INITIAL_SIZE; + Init(comparer, capacity, true); + } + + public SortedList(IComparer comparer) + : this(INITIAL_SIZE, comparer) + { + } + + public SortedList(IDictionary dictionary) + : this(dictionary, null) + { + } + + public SortedList(IDictionary dictionary, IComparer comparer) + { + if (dictionary == null) + throw new ArgumentNullException("dictionary"); + + Init(comparer, dictionary.Count, true); + + foreach (KeyValuePair kvp in dictionary) + Add(kvp.Key, kvp.Value); + } + + // + // Properties + // + + // ICollection + + public int Count + { + get + { + return inUse; + } + } + + bool ICollection.IsSynchronized + { + get + { + return false; + } + } + + Object ICollection.SyncRoot + { + get + { + return this; + } + } + + // IDictionary + + bool IDictionary.IsFixedSize + { + get + { + return false; + } + } + + bool IDictionary.IsReadOnly + { + get + { + return false; + } + } + + public TValue this[TKey key] + { + get + { + if (key == null) + throw new ArgumentNullException("key"); + + int i = Find(key); + + if (i >= 0) + return table[i].Value; + else + throw new KeyNotFoundException(); + } + set + { + if (key == null) + throw new ArgumentNullException("key"); + + PutImpl(key, value, true); + } + } + + object IDictionary.this[object key] + { + get + { + if (!(key is TKey)) + return null; + else + return this[(TKey)key]; + } + + set + { + this[ToKey(key)] = ToValue(value); + } + } + + public int Capacity + { + get + { + return table.Length; + } + + set + { + int current = this.table.Length; + + if (inUse > value) + { + throw new ArgumentOutOfRangeException("capacity too small"); + } + else if (value == 0) + { + // return to default size + KeyValuePair[] newTable = new KeyValuePair[defaultCapacity]; + Array.Copy(table, newTable, inUse); + this.table = newTable; + } + else if (value > inUse) + { + KeyValuePair[] newTable = new KeyValuePair[value]; + Array.Copy(table, newTable, inUse); + this.table = newTable; + } + else if (value > current) + { + KeyValuePair[] newTable = new KeyValuePair[value]; + Array.Copy(table, newTable, current); + this.table = newTable; + } + } + } + + public IList Keys + { + get + { + return new ListKeys(this); + } + } + + public IList Values + { + get + { + return new ListValues(this); + } + } + + ICollection IDictionary.Keys + { + get + { + return new ListKeys(this); + } + } + + ICollection IDictionary.Values + { + get + { + return new ListValues(this); + } + } + + ICollection IDictionary.Keys + { + get + { + return Keys; + } + } + + ICollection IDictionary.Values + { + get + { + return Values; + } + } + + public IComparer Comparer + { + get + { + return comparer; + } + } + + bool ICollection>.IsReadOnly + { + get + { + return false; + } + } + + // + // Public instance methods. + // + + public void Add(TKey key, TValue value) + { + if (key == null) + throw new ArgumentNullException("key"); + + PutImpl(key, value, false); + } + + public bool ContainsKey(TKey key) + { + if (key == null) + throw new ArgumentNullException("key"); + + return (Find(key) >= 0); + } + + public IEnumerator> GetEnumerator() + { + for (int i = 0; i < inUse; i++) + { + KeyValuePair current = this.table[i]; + + yield return new KeyValuePair(current.Key, current.Value); + } + } + + public bool Remove(TKey key) + { + if (key == null) + throw new ArgumentNullException("key"); + + int i = IndexOfKey(key); + if (i >= 0) + { + RemoveAt(i); + return true; + } + else + return false; + } + + // ICollection> + + void ICollection>.Clear() + { + defaultCapacity = INITIAL_SIZE; + this.table = new KeyValuePair[defaultCapacity]; + inUse = 0; + modificationCount++; + } + + public void Clear() + { + defaultCapacity = INITIAL_SIZE; + this.table = new KeyValuePair[defaultCapacity]; + inUse = 0; + modificationCount++; + } + + void ICollection>.CopyTo(KeyValuePair[] array, int arrayIndex) + { + if (Count == 0) + return; + + if (null == array) + throw new ArgumentNullException(); + + if (arrayIndex < 0) + throw new ArgumentOutOfRangeException(); + + if (arrayIndex >= array.Length) + throw new ArgumentNullException("arrayIndex is greater than or equal to array.Length"); + if (Count > (array.Length - arrayIndex)) + throw new ArgumentNullException("Not enough space in array from arrayIndex to end of array"); + + int i = arrayIndex; + foreach (KeyValuePair pair in this) + array[i++] = pair; + } + + void ICollection>.Add(KeyValuePair keyValuePair) + { + Add(keyValuePair.Key, keyValuePair.Value); + } + + bool ICollection>.Contains(KeyValuePair keyValuePair) + { + int i = Find(keyValuePair.Key); + + if (i >= 0) + return Comparer>.Default.Compare(table[i], keyValuePair) == 0; + else + return false; + } + + bool ICollection>.Remove(KeyValuePair keyValuePair) + { + int i = Find(keyValuePair.Key); + + if (i >= 0 && (Comparer>.Default.Compare(table[i], keyValuePair) == 0)) + { + RemoveAt(i); + return true; + } + else + return false; + } + + // IEnumerable> + + IEnumerator> IEnumerable>.GetEnumerator() + { + for (int i = 0; i < inUse; i++) + { + KeyValuePair current = this.table[i]; + + yield return new KeyValuePair(current.Key, current.Value); + } + } + + // IEnumerable + + IEnumerator IEnumerable.GetEnumerator() + { + return GetEnumerator(); + } + + // IDictionary + + void IDictionary.Add(object key, object value) + { + PutImpl(ToKey(key), ToValue(value), false); + } + + bool IDictionary.Contains(object key) + { + if (null == key) + throw new ArgumentNullException(); + if (!(key is TKey)) + return false; + + return (Find((TKey)key) >= 0); + } + + IDictionaryEnumerator IDictionary.GetEnumerator() + { + return new Enumerator(this, EnumeratorMode.ENTRY_MODE); + } + + void IDictionary.Remove(object key) + { + if (null == key) + throw new ArgumentNullException("key"); + if (!(key is TKey)) + return; + int i = IndexOfKey((TKey)key); + if (i >= 0) RemoveAt(i); + } + + // ICollection + + void ICollection.CopyTo(Array array, int arrayIndex) + { + if (Count == 0) + return; + + if (null == array) + throw new ArgumentNullException(); + + if (arrayIndex < 0) + throw new ArgumentOutOfRangeException(); + + if (array.Rank > 1) + throw new ArgumentException("array is multi-dimensional"); + if (arrayIndex >= array.Length) + throw new ArgumentNullException("arrayIndex is greater than or equal to array.Length"); + if (Count > (array.Length - arrayIndex)) + throw new ArgumentNullException("Not enough space in array from arrayIndex to end of array"); + + IEnumerator> it = GetEnumerator(); + int i = arrayIndex; + + while (it.MoveNext()) + { + array.SetValue(it.Current, i++); + } + } + + // + // SortedList + // + + public void RemoveAt(int index) + { + KeyValuePair[] table = this.table; + int cnt = Count; + if (index >= 0 && index < cnt) + { + if (index != cnt - 1) + { + Array.Copy(table, index + 1, table, index, cnt - 1 - index); + } + else + { + table[index] = default(KeyValuePair); + } + --inUse; + ++modificationCount; + } + else + { + throw new ArgumentOutOfRangeException("index out of range"); + } + } + + public int IndexOfKey(TKey key) + { + if (key == null) + throw new ArgumentNullException("key"); + + int indx = 0; + try + { + indx = Find(key); + } + catch (Exception) + { + throw new InvalidOperationException(); + } + + return (indx | (indx >> 31)); + } + + public int IndexOfValue(TValue value) + { + if (inUse == 0) + return -1; + + for (int i = 0; i < inUse; i++) + { + KeyValuePair current = this.table[i]; + + if (Equals(value, current.Value)) + return i; + } + + return -1; + } + + public bool ContainsValue(TValue value) + { + return IndexOfValue(value) >= 0; + } + + public void TrimExcess() + { + if (inUse < table.Length * 0.9) + Capacity = inUse; + } + + public bool TryGetValue(TKey key, out TValue value) + { + if (key == null) + throw new ArgumentNullException("key"); + + int i = Find(key); + + if (i >= 0) + { + value = table[i].Value; + return true; + } + else + { + value = default(TValue); + return false; + } + } + + // + // Private methods + // + + private void EnsureCapacity(int n, int free) + { + KeyValuePair[] table = this.table; + KeyValuePair[] newTable = null; + int cap = Capacity; + bool gap = (free >= 0 && free < Count); + + if (n > cap) + { + newTable = new KeyValuePair[n << 1]; + } + + if (newTable != null) + { + if (gap) + { + int copyLen = free; + if (copyLen > 0) + { + Array.Copy(table, 0, newTable, 0, copyLen); + } + copyLen = Count - free; + if (copyLen > 0) + { + Array.Copy(table, free, newTable, free + 1, copyLen); + } + } + else + { + // Just a resizing, copy the entire table. + Array.Copy(table, newTable, Count); + } + this.table = newTable; + } + else if (gap) + { + Array.Copy(table, free, table, free + 1, Count - free); + } + } + + private void PutImpl(TKey key, TValue value, bool overwrite) + { + if (key == null) + throw new ArgumentNullException("null key"); + + KeyValuePair[] table = this.table; + + int freeIndx = -1; + + try + { + freeIndx = Find(key); + } + catch (Exception) + { + throw new InvalidOperationException(); + } + + if (freeIndx >= 0) + { + if (!overwrite) + throw new ArgumentException("element already exists"); + + table[freeIndx] = new KeyValuePair(key, value); + ++modificationCount; + return; + } + + freeIndx = ~freeIndx; + + if (freeIndx > Capacity + 1) + throw new Exception("SortedList::internal error (" + key + ", " + value + ") at [" + freeIndx + "]"); + + + EnsureCapacity(Count + 1, freeIndx); + + table = this.table; + table[freeIndx] = new KeyValuePair(key, value); + + ++inUse; + ++modificationCount; + + } + + private void Init(IComparer comparer, int capacity, bool forceSize) + { + if (comparer == null) + comparer = Comparer.Default; + this.comparer = comparer; + if (!forceSize && (capacity < defaultCapacity)) + capacity = defaultCapacity; + this.table = new KeyValuePair[capacity]; + this.inUse = 0; + this.modificationCount = 0; + } + + private void CopyToArray(Array arr, int i, + EnumeratorMode mode) + { + if (arr == null) + throw new ArgumentNullException("arr"); + + if (i < 0 || i + this.Count > arr.Length) + throw new ArgumentOutOfRangeException("i"); + + IEnumerator it = new Enumerator(this, mode); + + while (it.MoveNext()) + { + arr.SetValue(it.Current, i++); + } + } + + private int Find(TKey key) + { + KeyValuePair[] table = this.table; + int len = Count; + + if (len == 0) return ~0; + + int left = 0; + int right = len - 1; + + while (left <= right) + { + int guess = (left + right) >> 1; + + int cmp = comparer.Compare(table[guess].Key, key); + if (cmp == 0) return guess; + + if (cmp < 0) left = guess + 1; + else right = guess - 1; + } + + return ~left; + } + + private TKey ToKey(object key) + { + if (key == null) + throw new ArgumentNullException("key"); + if (!(key is TKey)) + throw new ArgumentException("The value \"" + key + "\" isn't of type \"" + typeof(TKey) + "\" and can't be used in this generic collection.", "key"); + return (TKey)key; + } + + private TValue ToValue(object value) + { + if (!(value is TValue)) + throw new ArgumentException("The value \"" + value + "\" isn't of type \"" + typeof(TValue) + "\" and can't be used in this generic collection.", "value"); + return (TValue)value; + } + + internal TKey KeyAt(int index) + { + if (index >= 0 && index < Count) + return table[index].Key; + else + throw new ArgumentOutOfRangeException("Index out of range"); + } + + internal TValue ValueAt(int index) + { + if (index >= 0 && index < Count) + return table[index].Value; + else + throw new ArgumentOutOfRangeException("Index out of range"); + } + + // + // Inner classes + // + + + private sealed class Enumerator : ICloneable, IDictionaryEnumerator, IEnumerator + { + + private SortedList host; + private int stamp; + private int pos; + private int size; + private EnumeratorMode mode; + + private object currentKey; + private object currentValue; + + bool invalid = false; + + private readonly static string xstr = "SortedList.Enumerator: snapshot out of sync."; + + public Enumerator(SortedList host, EnumeratorMode mode) + { + this.host = host; + stamp = host.modificationCount; + size = host.Count; + this.mode = mode; + Reset(); + } + + public Enumerator(SortedList host) + : this(host, EnumeratorMode.ENTRY_MODE) + { + } + + public void Reset() + { + if (host.modificationCount != stamp || invalid) + throw new InvalidOperationException(xstr); + + pos = -1; + currentKey = null; + currentValue = null; + } + + public bool MoveNext() + { + if (host.modificationCount != stamp || invalid) + throw new InvalidOperationException(xstr); + + KeyValuePair[] table = host.table; + + if (++pos < size) + { + KeyValuePair entry = table[pos]; + + currentKey = entry.Key; + currentValue = entry.Value; + return true; + } + + currentKey = null; + currentValue = null; + return false; + } + + public DictionaryEntry Entry + { + get + { + if (invalid || pos >= size || pos == -1) + throw new InvalidOperationException(xstr); + + return new DictionaryEntry(currentKey, + currentValue); + } + } + + public Object Key + { + get + { + if (invalid || pos >= size || pos == -1) + throw new InvalidOperationException(xstr); + return currentKey; + } + } + + public Object Value + { + get + { + if (invalid || pos >= size || pos == -1) + throw new InvalidOperationException(xstr); + return currentValue; + } + } + + public Object Current + { + get + { + if (invalid || pos >= size || pos == -1) + throw new InvalidOperationException(xstr); + + switch (mode) + { + case EnumeratorMode.KEY_MODE: + return currentKey; + case EnumeratorMode.VALUE_MODE: + return currentValue; + case EnumeratorMode.ENTRY_MODE: + return this.Entry; + + default: + throw new NotSupportedException(mode + " is not a supported mode."); + } + } + } + + // ICloneable + + public object Clone() + { + Enumerator e = new Enumerator(host, mode); + e.stamp = stamp; + e.pos = pos; + e.size = size; + e.currentKey = currentKey; + e.currentValue = currentValue; + e.invalid = invalid; + return e; + } + } + + [Serializable] + struct KeyEnumerator : IEnumerator, IDisposable + { + const int NOT_STARTED = -2; + + // this MUST be -1, because we depend on it in move next. + // we just decr the size, so, 0 - 1 == FINISHED + const int FINISHED = -1; + + SortedList l; + int idx; + int ver; + + internal KeyEnumerator(SortedList l) + { + this.l = l; + idx = NOT_STARTED; + ver = l.modificationCount; + } + + public void Dispose() + { + idx = NOT_STARTED; + } + + public bool MoveNext() + { + if (ver != l.modificationCount) + throw new InvalidOperationException("Collection was modified after the enumerator was instantiated."); + + if (idx == NOT_STARTED) + idx = l.Count; + + return idx != FINISHED && --idx != FINISHED; + } + + public TKey Current + { + get + { + if (idx < 0) + throw new InvalidOperationException(); + + return l.KeyAt(l.Count - 1 - idx); + } + } + + void IEnumerator.Reset() + { + if (ver != l.modificationCount) + throw new InvalidOperationException("Collection was modified after the enumerator was instantiated."); + + idx = NOT_STARTED; + } + + object IEnumerator.Current + { + get { return Current; } + } + } + + [Serializable] + struct ValueEnumerator : IEnumerator, IDisposable + { + const int NOT_STARTED = -2; + + // this MUST be -1, because we depend on it in move next. + // we just decr the size, so, 0 - 1 == FINISHED + const int FINISHED = -1; + + SortedList l; + int idx; + int ver; + + internal ValueEnumerator(SortedList l) + { + this.l = l; + idx = NOT_STARTED; + ver = l.modificationCount; + } + + public void Dispose() + { + idx = NOT_STARTED; + } + + public bool MoveNext() + { + if (ver != l.modificationCount) + throw new InvalidOperationException("Collection was modified after the enumerator was instantiated."); + + if (idx == NOT_STARTED) + idx = l.Count; + + return idx != FINISHED && --idx != FINISHED; + } + + public TValue Current + { + get + { + if (idx < 0) + throw new InvalidOperationException(); + + return l.ValueAt(l.Count - 1 - idx); + } + } + + void IEnumerator.Reset() + { + if (ver != l.modificationCount) + throw new InvalidOperationException("Collection was modified after the enumerator was instantiated."); + + idx = NOT_STARTED; + } + + object IEnumerator.Current + { + get { return Current; } + } + } + + private class ListKeys : IList, ICollection, IEnumerable + { + + private SortedList host; + + public ListKeys(SortedList host) + { + if (host == null) + throw new ArgumentNullException(); + + this.host = host; + } + + // ICollection + + public virtual void Add(TKey item) + { + throw new NotSupportedException(); + } + + public virtual bool Remove(TKey key) + { + throw new NotSupportedException(); + } + + public virtual void Clear() + { + throw new NotSupportedException(); + } + + public virtual void CopyTo(TKey[] array, int arrayIndex) + { + if (host.Count == 0) + return; + if (array == null) + throw new ArgumentNullException("array"); + if (arrayIndex < 0) + throw new ArgumentOutOfRangeException(); + if (arrayIndex >= array.Length) + throw new ArgumentOutOfRangeException("arrayIndex is greater than or equal to array.Length"); + if (Count > (array.Length - arrayIndex)) + throw new ArgumentOutOfRangeException("Not enough space in array from arrayIndex to end of array"); + + int j = arrayIndex; + for (int i = 0; i < Count; ++i) + array[j++] = host.KeyAt(i); + } + + public virtual bool Contains(TKey item) + { + return host.IndexOfKey(item) > -1; + } + + // + // IList + // + public virtual int IndexOf(TKey item) + { + return host.IndexOfKey(item); + } + + public virtual void Insert(int index, TKey item) + { + throw new NotSupportedException(); + } + + public virtual void RemoveAt(int index) + { + throw new NotSupportedException(); + } + + public virtual TKey this[int index] + { + get + { + return host.KeyAt(index); + } + set + { + throw new NotSupportedException("attempt to modify a key"); + } + } + + // + // IEnumerable + // + + public virtual IEnumerator GetEnumerator() + { + /* We couldn't use yield as it does not support Reset () */ + return new KeyEnumerator(host); + } + + // + // ICollection + // + + public virtual int Count + { + get + { + return host.Count; + } + } + + public virtual bool IsSynchronized + { + get + { + return ((ICollection)host).IsSynchronized; + } + } + + public virtual bool IsReadOnly + { + get + { + return true; + } + } + + public virtual Object SyncRoot + { + get + { + return ((ICollection)host).SyncRoot; + } + } + + public virtual void CopyTo(Array array, int arrayIndex) + { + host.CopyToArray(array, arrayIndex, EnumeratorMode.KEY_MODE); + } + + // + // IEnumerable + // + + IEnumerator IEnumerable.GetEnumerator() + { + for (int i = 0; i < host.Count; ++i) + yield return host.KeyAt(i); + } + } + + private class ListValues : IList, ICollection, IEnumerable + { + + private SortedList host; + + public ListValues(SortedList host) + { + if (host == null) + throw new ArgumentNullException(); + + this.host = host; + } + + // ICollection + + public virtual void Add(TValue item) + { + throw new NotSupportedException(); + } + + public virtual bool Remove(TValue value) + { + throw new NotSupportedException(); + } + + public virtual void Clear() + { + throw new NotSupportedException(); + } + + public virtual void CopyTo(TValue[] array, int arrayIndex) + { + if (host.Count == 0) + return; + if (array == null) + throw new ArgumentNullException("array"); + if (arrayIndex < 0) + throw new ArgumentOutOfRangeException(); + if (arrayIndex >= array.Length) + throw new ArgumentOutOfRangeException("arrayIndex is greater than or equal to array.Length"); + if (Count > (array.Length - arrayIndex)) + throw new ArgumentOutOfRangeException("Not enough space in array from arrayIndex to end of array"); + + int j = arrayIndex; + for (int i = 0; i < Count; ++i) + array[j++] = host.ValueAt(i); + } + + public virtual bool Contains(TValue item) + { + return host.IndexOfValue(item) > -1; + } + + // + // IList + // + public virtual int IndexOf(TValue item) + { + return host.IndexOfValue(item); + } + + public virtual void Insert(int index, TValue item) + { + throw new NotSupportedException(); + } + + public virtual void RemoveAt(int index) + { + throw new NotSupportedException(); + } + + public virtual TValue this[int index] + { + get + { + return host.ValueAt(index); + } + set + { + throw new NotSupportedException("attempt to modify a key"); + } + } + + // + // IEnumerable + // + + public virtual IEnumerator GetEnumerator() + { + /* We couldn't use yield as it does not support Reset () */ + return new ValueEnumerator(host); + } + + // + // ICollection + // + + public virtual int Count + { + get + { + return host.Count; + } + } + + public virtual bool IsSynchronized + { + get + { + return ((ICollection)host).IsSynchronized; + } + } + + public virtual bool IsReadOnly + { + get + { + return true; + } + } + + public virtual Object SyncRoot + { + get + { + return ((ICollection)host).SyncRoot; + } + } + + public virtual void CopyTo(Array array, int arrayIndex) + { + host.CopyToArray(array, arrayIndex, EnumeratorMode.VALUE_MODE); + } + + // + // IEnumerable + // + + IEnumerator IEnumerable.GetEnumerator() + { + for (int i = 0; i < host.Count; ++i) + yield return host.ValueAt(i); + } + } + + } // SortedList +} \ No newline at end of file diff --git a/projects/client/RabbitMQ.Client.WinRT/src/util/Timer.cs b/projects/client/RabbitMQ.Client.WinRT/src/util/Timer.cs new file mode 100644 index 0000000000..0b06e26c15 --- /dev/null +++ b/projects/client/RabbitMQ.Client.WinRT/src/util/Timer.cs @@ -0,0 +1,132 @@ +// This source code is dual-licensed under the Apache License, version +// 2.0, and the Mozilla Public License, version 1.1. +// +// The APL v2.0: +// +//--------------------------------------------------------------------------- +// Copyright (C) 2007-2014 GoPivotal, Inc. +// +// Licensed 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. +//--------------------------------------------------------------------------- +// +// The MPL v1.1: +// +//--------------------------------------------------------------------------- +// The contents of this file are subject to the Mozilla Public License +// Version 1.1 (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.mozilla.org/MPL/ +// +// Software distributed under the License is distributed on an "AS IS" +// basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See +// the License for the specific language governing rights and +// limitations under the License. +// +// The Original Code is RabbitMQ. +// +// The Initial Developer of the Original Code is GoPivotal, Inc. +// Copyright (c) 2013-2014 GoPivotal, Inc. All rights reserved. +//--------------------------------------------------------------------------- + +using System; +using Windows.System.Threading; + +namespace System.Threading +{ +#if NETFX_CORE + /// + /// Provides a mechanism for executing a method at specified intervals. Adapts to on Windows 8+ platforms. + /// + internal class Timer : IDisposable + { + private readonly Action callback; + private readonly object state; + + private ThreadPoolTimer threadPoolTimer; + + public Timer(Action callback) + { + this.callback = callback; + this.state = null; + } + + public void Dispose() + { + if (threadPoolTimer != null) + { + threadPoolTimer.Cancel(); + threadPoolTimer = null; + } + } + + /// + /// Changes the start time and the interval between method invocations for a timer, using 32-bit signed integers to measure time intervals. + /// + /// + /// The amount of time to delay before the invoking the callback method specified when the Timer was constructed, in milliseconds. Specify Timeout.Infinite to prevent the timer from restarting. Specify zero (0) to restart the timer immediately. + /// + /// + /// The time interval between invocations of the callback method specified when the Timer was constructed, in milliseconds. Specify Timeout.Infinite to disable periodic signaling. + /// + /// true if the timer was successfully updated; otherwise, false. + public bool Change(int dueTime, int period) + { + if (dueTime < -1) + { + throw new ArgumentOutOfRangeException("dueTime", "NeedNonNegOrNegative1"); + } + + if (period < -1) + { + throw new ArgumentOutOfRangeException("period", "NeedNonNegOrNegative1"); + } + + if (threadPoolTimer != null) + { + threadPoolTimer.Cancel(); + threadPoolTimer = null; + } + + if (dueTime == Timeout.Infinite) + { + // If dueTime is Infinite, the callback method is never invoked; the timer is disabled + return true; + } + else if (dueTime == 0) + { + // If dueTime is zero (0), the callback method is invoked immediately + StartTimers(period); + } + else + { + ThreadPoolTimer.CreateTimer(timer => this.StartTimers(period), TimeSpan.FromMilliseconds(dueTime), timer => timer.Cancel()); + } + + return true; + } + + private void StartTimers(int period) + { + if (period == Timeout.Infinite || period == 0) + { + // If period is zero (0) or Infinite, and dueTime is not Infinite, the callback method is invoked once; + threadPoolTimer = ThreadPoolTimer.CreateTimer(timer => callback(state), TimeSpan.FromMilliseconds(0), timer => timer.Cancel()); + } + else + { + threadPoolTimer = ThreadPoolTimer.CreatePeriodicTimer(timer => callback(state), TimeSpan.FromMilliseconds(period)); + } + } + } +#endif +} \ No newline at end of file diff --git a/projects/client/RabbitMQ.Client/src/client/api/ConnectionFactory.cs b/projects/client/RabbitMQ.Client/src/client/api/ConnectionFactory.cs index c40397e514..d3f852d249 100644 --- a/projects/client/RabbitMQ.Client/src/client/api/ConnectionFactory.cs +++ b/projects/client/RabbitMQ.Client/src/client/api/ConnectionFactory.cs @@ -40,8 +40,12 @@ using System; using System.Collections.Generic; -using System.Net.Security; using System.Threading.Tasks; + +#if !NETFX_CORE +using System.Net.Security; +#endif + using RabbitMQ.Client.Exceptions; using RabbitMQ.Client.Framing.Impl; using RabbitMQ.Client.Impl; @@ -339,7 +343,9 @@ private void SetUri(Uri uri) else if (string.Equals("amqps", uri.Scheme, StringComparison.OrdinalIgnoreCase)) { Ssl.Enabled = true; +#if !(NETFX_CORE) Ssl.AcceptablePolicyErrors = SslPolicyErrors.RemoteCertificateNameMismatch; +#endif Port = AmqpTcpEndpoint.DefaultAmqpSslPort; } else @@ -396,4 +402,4 @@ private string UriDecode(string uri) return System.Uri.UnescapeDataString(uri.Replace("+", "%2B")); } } -} \ No newline at end of file +} diff --git a/projects/client/RabbitMQ.Client/src/client/api/ConnectionFactoryBase.cs b/projects/client/RabbitMQ.Client/src/client/api/ConnectionFactoryBase.cs index fce1ce5a39..032ebec2b3 100644 --- a/projects/client/RabbitMQ.Client/src/client/api/ConnectionFactoryBase.cs +++ b/projects/client/RabbitMQ.Client/src/client/api/ConnectionFactoryBase.cs @@ -39,7 +39,12 @@ //--------------------------------------------------------------------------- using System; + +#if NETFX_CORE +using Windows.Networking.Sockets; +#else using System.Net.Sockets; +#endif namespace RabbitMQ.Client { @@ -48,13 +53,25 @@ public class ConnectionFactoryBase /// /// Set custom socket options by providing a SocketFactory. /// +#if NETFX_CORE + public Func SocketFactory = DefaultSocketFactory; +#else public Func SocketFactory = DefaultSocketFactory; +#endif /// /// Creates a new instance of the . /// /// Specifies the addressing scheme. /// New instance of a . +#if NETFX_CORE + public static StreamSocket DefaultSocketFactory() + { + StreamSocket tcpClient = new StreamSocket(); + tcpClient.Control.NoDelay = true; + return tcpClient; + } +#else public static TcpClient DefaultSocketFactory(AddressFamily addressFamily) { var tcpClient = new TcpClient(addressFamily) @@ -63,5 +80,6 @@ public static TcpClient DefaultSocketFactory(AddressFamily addressFamily) }; return tcpClient; } +#endif } -} \ No newline at end of file +} diff --git a/projects/client/RabbitMQ.Client/src/client/api/IProtocol.cs b/projects/client/RabbitMQ.Client/src/client/api/IProtocol.cs index f3db7230da..3f215361c4 100644 --- a/projects/client/RabbitMQ.Client/src/client/api/IProtocol.cs +++ b/projects/client/RabbitMQ.Client/src/client/api/IProtocol.cs @@ -39,7 +39,13 @@ //--------------------------------------------------------------------------- using System; + +#if !NETFX_CORE using System.Net.Sockets; +#else +using Windows.Networking.Sockets; +#endif + using RabbitMQ.Client.Impl; namespace RabbitMQ.Client @@ -95,8 +101,14 @@ public interface IProtocol /// Socket factory method. /// Timeout in milliseconds. /// Represents a TCP-addressable AMQP peer: a host name and port number. - IFrameHandler CreateFrameHandler(AmqpTcpEndpoint endpoint, Func socketFactory, int timeout); - + IFrameHandler CreateFrameHandler( + AmqpTcpEndpoint endpoint, +#if !NETFX_CORE + Func socketFactory, +#else + Func socketFactory, +#endif + int timeout); /// /// Construct a protocol model atop a given session. /// diff --git a/projects/client/RabbitMQ.Client/src/client/api/NetworkConnection.cs b/projects/client/RabbitMQ.Client/src/client/api/NetworkConnection.cs index 27d34e26bb..5e81e159f7 100644 --- a/projects/client/RabbitMQ.Client/src/client/api/NetworkConnection.cs +++ b/projects/client/RabbitMQ.Client/src/client/api/NetworkConnection.cs @@ -47,24 +47,28 @@ namespace RabbitMQ.Client /// public interface NetworkConnection { +#if !NETFX_CORE /// /// Identifies local network address. /// EndPoint LocalEndPoint { get; } +#endif /// /// Local port. /// int LocalPort { get; } +#if !NETFX_CORE /// /// Identifies remote network address. /// EndPoint RemoteEndPoint { get; } +#endif /// /// Remote port. /// int RemotePort { get; } } -} \ No newline at end of file +} diff --git a/projects/client/RabbitMQ.Client/src/client/api/SslHelper.cs b/projects/client/RabbitMQ.Client/src/client/api/SslHelper.cs index 007baa43c4..521b75b3cd 100644 --- a/projects/client/RabbitMQ.Client/src/client/api/SslHelper.cs +++ b/projects/client/RabbitMQ.Client/src/client/api/SslHelper.cs @@ -38,6 +38,8 @@ // Copyright (c) 2007-2014 GoPivotal, Inc. All rights reserved. //--------------------------------------------------------------------------- +#if !NETFX_CORE + using System; using System.IO; using System.Net.Security; @@ -105,4 +107,6 @@ private bool CertificateValidationCallback(object sender, X509Certificate certif return (sslPolicyErrors & ~_sslOption.AcceptablePolicyErrors) == SslPolicyErrors.None; } } -} \ No newline at end of file +} + +#endif diff --git a/projects/client/RabbitMQ.Client/src/client/api/SslOption.cs b/projects/client/RabbitMQ.Client/src/client/api/SslOption.cs index 843a705553..6eb6dd5e49 100644 --- a/projects/client/RabbitMQ.Client/src/client/api/SslOption.cs +++ b/projects/client/RabbitMQ.Client/src/client/api/SslOption.cs @@ -39,9 +39,14 @@ //--------------------------------------------------------------------------- using System; + +#if !NETFX_CORE using System.Net.Security; using System.Security.Authentication; using System.Security.Cryptography.X509Certificates; +#else +using Windows.Networking.Sockets; +#endif namespace RabbitMQ.Client { @@ -50,20 +55,28 @@ namespace RabbitMQ.Client /// public class SslOption { +#if !NETFX_CORE private X509CertificateCollection _certificateCollection; +#endif /// /// Constructs an SslOption specifying both the server cannonical name and the client's certificate path. /// public SslOption(string serverName, string certificatePath = "", bool enabled = false) { +#if !NETFX_CORE Version = SslProtocols.Tls; AcceptablePolicyErrors = SslPolicyErrors.None; +#endif + ServerName = serverName; CertPath = certificatePath; Enabled = enabled; + +#if !NETFX_CORE CertificateValidationCallback = null; CertificateSelectionCallback = null; +#endif } /// @@ -74,10 +87,12 @@ public SslOption() { } +#if !NETFX_CORE /// /// Retrieve or set the set of ssl policy errors that are deemed acceptable. /// public SslPolicyErrors AcceptablePolicyErrors { get; set; } +#endif /// /// Retrieve or set the path to client certificate. @@ -89,6 +104,7 @@ public SslOption() /// public string CertPath { get; set; } +#if !NETFX_CORE /// /// An optional client specified SSL certificate selection callback. If this is not specified, /// the first valid certificate found will be used. @@ -126,6 +142,7 @@ public X509CertificateCollection Certs } set { _certificateCollection = value; } } +#endif /// /// Flag specifying if Ssl should indeed be used. @@ -138,9 +155,11 @@ public X509CertificateCollection Certs /// public string ServerName { get; set; } +#if !NETFX_CORE /// /// Retrieve or set the Ssl protocol version. /// public SslProtocols Version { get; set; } +#endif } -} \ No newline at end of file +} diff --git a/projects/client/RabbitMQ.Client/src/client/content/BytesWireFormatting.cs b/projects/client/RabbitMQ.Client/src/client/content/BytesWireFormatting.cs index b8f565256b..fa1e9fba55 100644 --- a/projects/client/RabbitMQ.Client/src/client/content/BytesWireFormatting.cs +++ b/projects/client/RabbitMQ.Client/src/client/content/BytesWireFormatting.cs @@ -98,7 +98,7 @@ public static string ReadString(NetworkBinaryReader reader) { ushort length = reader.ReadUInt16(); byte[] bytes = reader.ReadBytes(length); - return Encoding.UTF8.GetString(bytes); + return Encoding.UTF8.GetString(bytes, 0, bytes.Length); } public static void Write(NetworkBinaryWriter writer, byte[] source, int offset, int count) diff --git a/projects/client/RabbitMQ.Client/src/client/content/StreamWireFormatting.cs b/projects/client/RabbitMQ.Client/src/client/content/StreamWireFormatting.cs index d5e0b65b1c..4252230a76 100644 --- a/projects/client/RabbitMQ.Client/src/client/content/StreamWireFormatting.cs +++ b/projects/client/RabbitMQ.Client/src/client/content/StreamWireFormatting.cs @@ -299,7 +299,8 @@ public static string ReadUntypedString(NetworkBinaryReader reader) byte b = reader.ReadByte(); if (b == 0) { - return Encoding.UTF8.GetString(NetworkBinaryWriter.TemporaryContents(buffer)); + byte[] temporaryContents = NetworkBinaryWriter.TemporaryContents(buffer); + return Encoding.UTF8.GetString(temporaryContents, 0, temporaryContents.Length); } buffer.Write(b); } @@ -435,4 +436,4 @@ public static void WriteUntypedString(NetworkBinaryWriter writer, string value) writer.Write((byte) 0); } } -} \ No newline at end of file +} diff --git a/projects/client/RabbitMQ.Client/src/client/exceptions/ConnectFailureException.cs b/projects/client/RabbitMQ.Client/src/client/exceptions/ConnectFailureException.cs index 2886eb057e..ddc2363dd9 100644 --- a/projects/client/RabbitMQ.Client/src/client/exceptions/ConnectFailureException.cs +++ b/projects/client/RabbitMQ.Client/src/client/exceptions/ConnectFailureException.cs @@ -43,7 +43,7 @@ namespace RabbitMQ.Client.Exceptions { /// Thrown when a connection to the broker fails - public class ConnectFailureException : SystemException + public class ConnectFailureException : Exception { public ConnectFailureException(String msg, Exception inner) : base(msg, inner) diff --git a/projects/client/RabbitMQ.Client/src/client/exceptions/OperationInterruptedException.cs b/projects/client/RabbitMQ.Client/src/client/exceptions/OperationInterruptedException.cs index f29f3d10ee..4635881c44 100644 --- a/projects/client/RabbitMQ.Client/src/client/exceptions/OperationInterruptedException.cs +++ b/projects/client/RabbitMQ.Client/src/client/exceptions/OperationInterruptedException.cs @@ -88,10 +88,12 @@ protected OperationInterruptedException(string message, Exception inner) { } +#if !(NETFX_CORE) protected OperationInterruptedException(SerializationInfo info, StreamingContext context) : base(info, context) { } +#endif ///Retrieves the explanation for the shutdown. May ///return null if no explanation is available. diff --git a/projects/client/RabbitMQ.Client/src/client/impl/AutorecoveringConnection.cs b/projects/client/RabbitMQ.Client/src/client/impl/AutorecoveringConnection.cs index f3a45b557b..ae3bbeb316 100644 --- a/projects/client/RabbitMQ.Client/src/client/impl/AutorecoveringConnection.cs +++ b/projects/client/RabbitMQ.Client/src/client/impl/AutorecoveringConnection.cs @@ -47,7 +47,6 @@ using System.Net; using System.Threading; using System.Threading.Tasks; -using Timer = System.Timers.Timer; namespace RabbitMQ.Client.Framing.Impl { @@ -277,10 +276,12 @@ public AmqpTcpEndpoint[] KnownHosts set { m_delegate.KnownHosts = value; } } +#if !NETFX_CORE public EndPoint LocalEndPoint { get { return m_delegate.LocalEndPoint; } } +#endif public int LocalPort { @@ -302,10 +303,12 @@ public IDictionary RecordedQueues get { return m_recordedQueues; } } +#if !NETFX_CORE public EndPoint RemoteEndPoint { get { return m_delegate.RemoteEndPoint; } } +#endif public int RemotePort { @@ -340,7 +343,11 @@ public void BeginAutomaticRecovery() { try { +#if NETFX_CORE + System.Threading.Tasks.Task.Delay(m_factory.NetworkRecoveryInterval).Wait(); +#else Thread.Sleep(m_factory.NetworkRecoveryInterval); +#endif self.PerformAutomaticRecovery(); } finally @@ -558,7 +565,12 @@ public void init() catch (Exception e) { // TODO: logging - Console.WriteLine("BeginAutomaticRecovery() failed: {0}", e); +#if NETFX_CORE + System.Diagnostics.Debug.WriteLine( +#else + Console.WriteLine( +#endif + "BeginAutomaticRecovery() failed: {0}", e); } } } @@ -668,7 +680,12 @@ protected void EnsureIsOpen() protected void HandleTopologyRecoveryException(TopologyRecoveryException e) { // TODO - Console.WriteLine("Topology recovery exception: {0}", e); +#if NETFX_CORE + System.Diagnostics.Debug.WriteLine( +#else + Console.WriteLine( +#endif + "Topology recovery exception: {0}", e); } protected void PropagateQueueNameChangeToBindings(string oldName, string newName) @@ -739,7 +756,11 @@ protected void RecoverConnectionDelegate() catch (Exception) { // TODO: exponential back-off +#if NETFX_CORE + System.Threading.Tasks.Task.Delay(m_factory.NetworkRecoveryInterval).Wait(); +#else Thread.Sleep(m_factory.NetworkRecoveryInterval); +#endif // TODO: provide a way to handle these exceptions } } @@ -937,4 +958,4 @@ protected bool ShouldTriggerConnectionRecovery(ShutdownEventArgs args) args.Initiator == ShutdownInitiator.Library); } } -} \ No newline at end of file +} diff --git a/projects/client/RabbitMQ.Client/src/client/impl/CommandAssembler.cs b/projects/client/RabbitMQ.Client/src/client/impl/CommandAssembler.cs index 95534b2927..6a3c74fb47 100644 --- a/projects/client/RabbitMQ.Client/src/client/impl/CommandAssembler.cs +++ b/projects/client/RabbitMQ.Client/src/client/impl/CommandAssembler.cs @@ -117,7 +117,11 @@ public Command HandleFrame(Frame f) } case AssemblyState.Complete: default: +#if NETFX_CORE + Debug.WriteLine("Received frame in invalid state {0}; {1}", m_state, f); +#else Trace.Fail(string.Format("Received frame in invalid state {0}; {1}", m_state, f)); +#endif return null; } } diff --git a/projects/client/RabbitMQ.Client/src/client/impl/Connection.cs b/projects/client/RabbitMQ.Client/src/client/impl/Connection.cs index 72e28a8812..356d684077 100644 --- a/projects/client/RabbitMQ.Client/src/client/impl/Connection.cs +++ b/projects/client/RabbitMQ.Client/src/client/impl/Connection.cs @@ -45,8 +45,16 @@ using System; using System.Collections.Generic; using System.IO; + +#if NETFX_CORE +using System.Threading.Tasks; +using Windows.Networking.Sockets; +using Windows.ApplicationModel; +#else using System.Net; using System.Net.Sockets; +#endif + using System.Reflection; using System.Text; using System.Threading; @@ -111,7 +119,21 @@ public Connection(IConnectionFactory factory, bool insist, IFrameHandler frameHa StartMainLoop(factory.UseBackgroundThreadsForIO); Open(insist); StartHeartbeatTimers(); + +#if NETFX_CORE +#pragma warning disable 0168 + try + { + Windows.UI.Xaml.Application.Current.Suspending += this.HandleApplicationSuspend; + } + catch(Exception ex) + { + // If called from a desktop app (i.e. unit tests), then there is no current application + } +#pragma warning restore 0168 +#else AppDomain.CurrentDomain.DomainUnload += HandleDomainUnload; +#endif } public event EventHandler CallbackException @@ -244,10 +266,12 @@ public bool IsOpen public AmqpTcpEndpoint[] KnownHosts { get; set; } +#if !NETFX_CORE public EndPoint LocalEndPoint { get { return m_frameHandler.LocalEndPoint; } } +#endif public int LocalPort { @@ -261,10 +285,12 @@ public ProtocolBase Protocol get { return (ProtocolBase)Endpoint.Protocol; } } +#if !NETFX_CORE public EndPoint RemoteEndPoint { get { return m_frameHandler.RemoteEndPoint; } } +#endif public int RemotePort { @@ -287,7 +313,12 @@ IProtocol IConnection.Protocol public static IDictionary DefaultClientProperties() { Assembly assembly = - Assembly.GetAssembly(typeof(Connection)); +#if NETFX_CORE + System.Reflection.IntrospectionExtensions.GetTypeInfo(typeof(Connection)).Assembly; +#else + System.Reflection.Assembly.GetAssembly(typeof(Connection)); +#endif + string version = assembly.GetName().Version.ToString(); //TODO: Get the rest of this data from the Assembly Attributes IDictionary table = new Dictionary(); @@ -382,7 +413,14 @@ public void Close(ShutdownEventArgs reason, bool abort, int timeout) TerminateMainloop(); } } - if (!m_appContinuation.WaitOne(BlockingCell.validatedTimeout(timeout), true)) + +#if NETFX_CORE + var receivedSignal = m_appContinuation.WaitOne(BlockingCell.validatedTimeout(timeout)); +#else + var receivedSignal = m_appContinuation.WaitOne(BlockingCell.validatedTimeout(timeout), true); +#endif + + if (!receivedSignal) { m_frameHandler.Close(); } @@ -471,6 +509,15 @@ public void FinishClose() m_model0.FinishClose(); } +#if NETFX_CORE + /// + /// We need to close the socket, otherwise suspending the application will take the maximum time allowed + /// + public void HandleApplicationSuspend(object sender, SuspendingEventArgs suspendingEventArgs) + { + Abort(Constants.InternalError, "Application Suspend"); + } +#else /// /// We need to close the socket, otherwise attempting to unload the domain /// could cause a CannotUnloadAppDomainException @@ -479,6 +526,7 @@ public void HandleDomainUnload(object sender, EventArgs ea) { Abort(Constants.InternalError, "Domain Unload"); } +#endif public void HandleMainLoopException(ShutdownEventArgs reason) { @@ -525,7 +573,7 @@ public void HeartbeatReadTimerCallback(object state) bool shouldTerminate = false; if (!m_closed) { - if (!m_heartbeatRead.WaitOne(0, false)) + if (!m_heartbeatRead.WaitOne(0)) { m_missedHeartbeats++; } @@ -568,7 +616,7 @@ public void HeartbeatWriteTimerCallback(object state) { if (!m_closed) { - if (!m_heartbeatWrite.WaitOne(0, false)) + if (!m_heartbeatWrite.WaitOne(0)) { WriteFrame(m_heartbeatFrame); } @@ -649,6 +697,7 @@ public void MainLoop() { shutdownCleanly = HardProtocolExceptionHandler(hpe); } +#if !NETFX_CORE catch (SocketException se) { // Possibly due to handshake timeout @@ -657,6 +706,7 @@ public void MainLoop() "Socket exception", se)); } +#endif catch (Exception ex) { HandleMainLoopException(new ShutdownEventArgs(ShutdownInitiator.Library, @@ -669,17 +719,33 @@ public void MainLoop() // connection closes. if (shutdownCleanly) { +#pragma warning disable 0168 try { ClosingLoop(); -#pragma warning disable 0168 + } +#if NETFX_CORE + catch (Exception ex) + { + if (SocketError.GetStatus(ex.HResult) != SocketErrorStatus.Unknown) + { + // means that socket was closed when frame handler + // attempted to use it. Since we are shutting down, + // ignore it. + } + else + { + throw; + } } +#else catch (SocketException se) { // means that socket was closed when frame handler // attempted to use it. Since we are shutting down, // ignore it. } +#endif #pragma warning restore 0168 } @@ -869,7 +935,20 @@ public void OnShutdown() } } } +#if NETFX_CORE +#pragma warning disable 0168 + try + { + Windows.UI.Xaml.Application.Current.Suspending -= this.HandleApplicationSuspend; + } + catch (Exception ex) + { + // If called from a desktop app (i.e. unit tests), then there is no current application + } +#pragma warning restore 0168 +#else AppDomain.CurrentDomain.DomainUnload -= HandleDomainUnload; +#endif } public void Open(bool insist) @@ -882,14 +961,29 @@ public void PrettyPrintShutdownReport() { if (ShutdownReport.Count == 0) { - Console.Error.WriteLine("No errors reported when closing connection {0}", this); +#if NETFX_CORE + System.Diagnostics.Debug.WriteLine( +#else + Console.Error.WriteLine( +#endif + "No errors reported when closing connection {0}", this); } else { - Console.Error.WriteLine("Log of errors while closing connection {0}:", this); +#if NETFX_CORE + System.Diagnostics.Debug.WriteLine( +#else + Console.Error.WriteLine( +#endif + "Log of errors while closing connection {0}:", this); foreach (ShutdownReportEntry entry in ShutdownReport) { - Console.Error.WriteLine(entry.ToString()); +#if NETFX_CORE + System.Diagnostics.Debug.WriteLine( +#else + Console.Error.WriteLine( +#endif + entry.ToString()); } } } @@ -982,10 +1076,16 @@ public void StartHeartbeatTimers() public void StartMainLoop(bool useBackgroundThread) { + var taskName = "AMQP Connection " + Endpoint; + +#if NETFX_CORE + Task.Factory.StartNew(this.MainLoop, TaskCreationOptions.LongRunning); +#else var mainLoopThread = new Thread(MainLoop); - mainLoopThread.Name = "AMQP Connection " + Endpoint; + mainLoopThread.Name = taskName; mainLoopThread.IsBackground = useBackgroundThread; mainLoopThread.Start(); +#endif } protected void StopHeartbeatTimers() @@ -1148,7 +1248,7 @@ protected void StartAndTune() bool tuned = false; try { - string mechanismsString = Encoding.UTF8.GetString(connectionStart.m_mechanisms); + string mechanismsString = Encoding.UTF8.GetString(connectionStart.m_mechanisms, 0, connectionStart.m_mechanisms.Length); string[] mechanisms = mechanismsString.Split(' '); AuthMechanismFactory mechanismFactory = m_factory.AuthMechanismFactory(mechanisms); if (mechanismFactory == null) @@ -1220,4 +1320,4 @@ private static uint NegotiatedMaxValue(uint clientValue, uint serverValue) Math.Min(clientValue, serverValue); } } -} \ No newline at end of file +} diff --git a/projects/client/RabbitMQ.Client/src/client/impl/ConsumerWorkService.cs b/projects/client/RabbitMQ.Client/src/client/impl/ConsumerWorkService.cs index a744564a07..5706bad138 100755 --- a/projects/client/RabbitMQ.Client/src/client/impl/ConsumerWorkService.cs +++ b/projects/client/RabbitMQ.Client/src/client/impl/ConsumerWorkService.cs @@ -54,7 +54,12 @@ public void ExecuteThunk() } catch (Exception e) { +#if NETFX_CORE + // To end a task, return + return; +#else Thread.CurrentThread.Interrupt(); +#endif } } diff --git a/projects/client/RabbitMQ.Client/src/client/impl/Frame.cs b/projects/client/RabbitMQ.Client/src/client/impl/Frame.cs index b9f45cd675..2f574fe112 100644 --- a/projects/client/RabbitMQ.Client/src/client/impl/Frame.cs +++ b/projects/client/RabbitMQ.Client/src/client/impl/Frame.cs @@ -40,7 +40,12 @@ using System; using System.IO; + +#if NETFX_CORE +using Windows.Networking.Sockets; +#else using System.Net.Sockets; +#endif using RabbitMQ.Client.Exceptions; using RabbitMQ.Util; using RabbitMQ.Client.Framing; @@ -121,6 +126,15 @@ public static Frame ReadFrom(NetworkBinaryReader reader) } catch (IOException ioe) { +#if NETFX_CORE + if (ioe.InnerException != null + && SocketError.GetStatus(ioe.InnerException.HResult) == SocketErrorStatus.ConnectionTimedOut) + { + throw ioe.InnerException; + } + + throw; +#else // If it's a WSAETIMEDOUT SocketException, unwrap it. // This might happen when the limit of half-open connections is // reached. @@ -131,6 +145,8 @@ public static Frame ReadFrom(NetworkBinaryReader reader) throw ioe; } throw ioe.InnerException; + +#endif } if (type == 'A') diff --git a/projects/client/RabbitMQ.Client/src/client/impl/IFrameHandler.cs b/projects/client/RabbitMQ.Client/src/client/impl/IFrameHandler.cs index 8a46728c8a..529e1efbb3 100644 --- a/projects/client/RabbitMQ.Client/src/client/impl/IFrameHandler.cs +++ b/projects/client/RabbitMQ.Client/src/client/impl/IFrameHandler.cs @@ -47,11 +47,15 @@ public interface IFrameHandler { AmqpTcpEndpoint Endpoint { get; } +#if !NETFX_CORE EndPoint LocalEndPoint { get; } +#endif int LocalPort { get; } +#if !NETFX_CORE EndPoint RemoteEndPoint { get; } +#endif int RemotePort { get; } diff --git a/projects/client/RabbitMQ.Client/src/client/impl/ModelBase.cs b/projects/client/RabbitMQ.Client/src/client/impl/ModelBase.cs index 936597b29e..ce2189506e 100644 --- a/projects/client/RabbitMQ.Client/src/client/impl/ModelBase.cs +++ b/projects/client/RabbitMQ.Client/src/client/impl/ModelBase.cs @@ -49,6 +49,10 @@ using System.IO; using System.Threading; +#if (NETFX_CORE) +using Trace = System.Diagnostics.Debug; +#endif + namespace RabbitMQ.Client.Impl { public abstract class ModelBase : IFullModel, IRecoverable @@ -66,8 +70,8 @@ public abstract class ModelBase : IFullModel, IRecoverable private readonly object m_flowSendLock = new object(); private readonly object m_shutdownLock = new object(); - private readonly SynchronizedCollection m_unconfirmedSet = - new SynchronizedCollection(); + private readonly SynchronizedList m_unconfirmedSet = + new SynchronizedList(); private EventHandler m_basicAck; private EventHandler m_basicNack; @@ -1612,4 +1616,4 @@ public class QueueDeclareRpcContinuation : SimpleBlockingRpcContinuation public QueueDeclareOk m_result; } } -} \ No newline at end of file +} diff --git a/projects/client/RabbitMQ.Client/src/client/impl/ProtocolBase.cs b/projects/client/RabbitMQ.Client/src/client/impl/ProtocolBase.cs index a8d82e5883..3949e4e1f5 100644 --- a/projects/client/RabbitMQ.Client/src/client/impl/ProtocolBase.cs +++ b/projects/client/RabbitMQ.Client/src/client/impl/ProtocolBase.cs @@ -40,7 +40,13 @@ using System; using System.Collections.Generic; + +#if !NETFX_CORE using System.Net.Sockets; +#else +using Windows.Networking.Sockets; +#endif + using RabbitMQ.Client.Impl; using RabbitMQ.Client; using RabbitMQ.Util; @@ -138,8 +144,13 @@ public IConnection CreateConnection(ConnectionFactory factory, return ac; } - public IFrameHandler CreateFrameHandler(AmqpTcpEndpoint endpoint, - Func socketFactory, + public IFrameHandler CreateFrameHandler( + AmqpTcpEndpoint endpoint, +#if !NETFX_CORE + Func socketFactory, +#else + Func socketFactory, +#endif int timeout) { return new SocketFrameHandler(endpoint, socketFactory, timeout); diff --git a/projects/client/RabbitMQ.Client/src/client/impl/SessionManager.cs b/projects/client/RabbitMQ.Client/src/client/impl/SessionManager.cs index 64846fb062..8be9bf657e 100644 --- a/projects/client/RabbitMQ.Client/src/client/impl/SessionManager.cs +++ b/projects/client/RabbitMQ.Client/src/client/impl/SessionManager.cs @@ -41,6 +41,11 @@ using System; using System.Collections.Generic; using System.Threading; + +#if NETFX_CORE +using System.Threading.Tasks; +#endif + using RabbitMQ.Client.Exceptions; using RabbitMQ.Client.Framing.Impl; using RabbitMQ.Util; @@ -111,7 +116,11 @@ public void CheckAutoClose() // deadlock as the connection thread would be // blocking waiting for its own mainloop to // reply to it. +#if NETFX_CORE + Task.Factory.StartNew(AutoCloseConnection, TaskCreationOptions.LongRunning); +#else new Thread(AutoCloseConnection).Start(); +#endif } } } diff --git a/projects/client/RabbitMQ.Client/src/client/impl/SimpleBlockingRpcContinuation.cs b/projects/client/RabbitMQ.Client/src/client/impl/SimpleBlockingRpcContinuation.cs index d3b4c28bb4..ea62cd84f5 100644 --- a/projects/client/RabbitMQ.Client/src/client/impl/SimpleBlockingRpcContinuation.cs +++ b/projects/client/RabbitMQ.Client/src/client/impl/SimpleBlockingRpcContinuation.cs @@ -59,7 +59,12 @@ public virtual Command GetReply() case EitherAlternative.Right: throw new OperationInterruptedException((ShutdownEventArgs)result.Value); default: - Trace.Fail("Illegal EitherAlternative " + result.Alternative); + string error = "Illegal EitherAlternative " + result.Alternative; +#if !(NETFX_CORE) + Trace.Fail(error); +#else + MetroEventSource.Log.Error(error); +#endif return null; } } diff --git a/projects/client/RabbitMQ.Client/src/client/impl/WireFormatting.cs b/projects/client/RabbitMQ.Client/src/client/impl/WireFormatting.cs index 5e4f508b5e..1f48e5c864 100644 --- a/projects/client/RabbitMQ.Client/src/client/impl/WireFormatting.cs +++ b/projects/client/RabbitMQ.Client/src/client/impl/WireFormatting.cs @@ -199,7 +199,8 @@ public static ushort ReadShort(NetworkBinaryReader reader) public static string ReadShortstr(NetworkBinaryReader reader) { int byteCount = reader.ReadByte(); - return Encoding.UTF8.GetString(reader.ReadBytes(byteCount)); + byte[] readBytes = reader.ReadBytes(byteCount); + return Encoding.UTF8.GetString(readBytes, 0, readBytes.Length); } ///Reads an AMQP "table" definition from the reader. diff --git a/projects/client/RabbitMQ.Client/src/client/messagepatterns/Subscription.cs b/projects/client/RabbitMQ.Client/src/client/messagepatterns/Subscription.cs index 68f5b49390..11172ca414 100644 --- a/projects/client/RabbitMQ.Client/src/client/messagepatterns/Subscription.cs +++ b/projects/client/RabbitMQ.Client/src/client/messagepatterns/Subscription.cs @@ -41,6 +41,11 @@ using System; using System.Collections; using System.IO; + +#if NETFX_CORE || NET4 // For Windows 8 Store, but could be .NET 4.0 and greater +using System.Threading.Tasks; +#endif + using RabbitMQ.Client.Events; using RabbitMQ.Client.Exceptions; @@ -315,6 +320,35 @@ public BasicDeliverEventArgs Next() return LatestEvent; } +#if NETFX_CORE || NET4 + public async Task NextAsync() { + try { + // Alias the pointer as otherwise it may change out + // from under us by the operation of Close() from + // another thread. + QueueingBasicConsumer consumer = m_consumer; + if (consumer == null) { + // Closed! + MutateLatestEvent(null); + } + else { + MutateLatestEvent(await consumer.Queue.DequeueAsync()); + } + } + catch (AggregateException ex) { + // since tasks wrap exceptions as AggregateException, + // reach in and check if the EndOfStream exception is what happened + if (ex.InnerException is EndOfStreamException) { + MutateLatestEvent(null); + } + } + catch (EndOfStreamException) { + MutateLatestEvent(null); + } + return LatestEvent; + } +#endif + ///Retrieves the next incoming delivery in our ///subscription queue, or times out after a specified number ///of milliseconds. diff --git a/projects/client/RabbitMQ.Client/src/util/BatchingWorkPool.cs b/projects/client/RabbitMQ.Client/src/util/BatchingWorkPool.cs index 6c7c18cad3..2a86c07dd3 100755 --- a/projects/client/RabbitMQ.Client/src/util/BatchingWorkPool.cs +++ b/projects/client/RabbitMQ.Client/src/util/BatchingWorkPool.cs @@ -69,6 +69,10 @@ public bool AddWorkItem(K key, V item) return false; } } + +#if NETFX_CORE + q.Add(item); +#else try { q.Add(item); @@ -77,6 +81,8 @@ public bool AddWorkItem(K key, V item) { // most likely due to shutdown. ok. } +#endif + lock (lockObject) { if (IsDormant(key)) diff --git a/projects/client/RabbitMQ.Client/src/util/DebugUtil.cs b/projects/client/RabbitMQ.Client/src/util/DebugUtil.cs index 36aed287a0..6e393f6bec 100644 --- a/projects/client/RabbitMQ.Client/src/util/DebugUtil.cs +++ b/projects/client/RabbitMQ.Client/src/util/DebugUtil.cs @@ -49,18 +49,15 @@ namespace RabbitMQ.Util /// ///Not part of the public API. /// - public class DebugUtil + public static class DebugUtil { - ///Private constructor - this class has no instances - private DebugUtil() - { - } - +#if !(NETFX_CORE) ///Print a hex dump of the supplied bytes to stdout. public static void Dump(byte[] bytes) { Dump(bytes, Console.Out); } +#endif ///Print a hex dump of the supplied bytes to the supplied TextWriter. public static void Dump(byte[] bytes, TextWriter writer) @@ -124,7 +121,7 @@ public static void DumpProperties(object value, TextWriter writer, int indent) else if (value is byte[]) { writer.WriteLine("byte[]"); - Dump((byte[])value); + Dump((byte[])value, writer); } else if (value is ValueType) { @@ -153,9 +150,13 @@ public static void DumpProperties(object value, TextWriter writer, int indent) { Type t = value.GetType(); writer.WriteLine(t.FullName); +#if !(NETFX_CORE) foreach (PropertyInfo pi in t.GetProperties(BindingFlags.Instance | BindingFlags.Public | BindingFlags.DeclaredOnly)) +#else + foreach (PropertyInfo pi in t.GetRuntimeProperties()) +#endif { if (pi.GetIndexParameters().Length == 0) { diff --git a/projects/client/RabbitMQ.Client/src/util/SharedQueue.cs b/projects/client/RabbitMQ.Client/src/util/SharedQueue.cs index 32859a2a5c..762bce66f8 100644 --- a/projects/client/RabbitMQ.Client/src/util/SharedQueue.cs +++ b/projects/client/RabbitMQ.Client/src/util/SharedQueue.cs @@ -44,6 +44,10 @@ using System.IO; using System.Threading; +#if NETFX_CORE || NET4 // For Windows 8 Store, but could be .NET 4.0 and greater +using System.Threading.Tasks; +#endif + namespace RabbitMQ.Util { ///A thread-safe shared queue implementation. @@ -66,6 +70,10 @@ public class SharedQueue : IEnumerable /// protected Queue m_queue = new Queue(); +#if NETFX_CORE || NET4 + protected Queue> m_waiting = new Queue>(); +#endif + ///Close the queue. Causes all further Enqueue() ///operations to throw EndOfStreamException, and all pending ///or subsequent Dequeue() operations to throw an @@ -76,6 +84,23 @@ public void Close() { m_isOpen = false; Monitor.PulseAll(m_queue); +#if NETFX_CORE + // let all waiting tasks know we just closed by passing them an exception + if (m_waiting.Count > 0) + { + try + { + this.EnsureIsOpen(); + } + catch (Exception ex) + { + foreach (var tcs in m_waiting) + { + tcs.TrySetException(ex); + } + } + } +#endif } } @@ -99,6 +124,29 @@ public T Dequeue() } } +#if NETFX_CORE || NET4 + /// + /// Asynchronously retrieves the first item from the queue. + /// + public Task DequeueAsync() + { + lock (m_queue) + { + EnsureIsOpen(); + if (m_queue.Count > 0) + { + return Task.FromResult(this.Dequeue()); + } + else + { + var tcs = new TaskCompletionSource(); + m_waiting.Enqueue(tcs); + return tcs.Task; + } + } + } +#endif + ///Retrieve the first item from the queue, or return ///nothing if no items are available after the given ///timeout @@ -214,6 +262,20 @@ public void Enqueue(T o) lock (m_queue) { EnsureIsOpen(); + +#if NETFX_CORE + while (m_waiting.Count > 0) + { + var tcs = m_waiting.Dequeue(); + if (tcs != null && tcs.TrySetResult(o)) + { + // We successfully set a task return result, so + // no need to Enqueue or Monitor.Pulse + return; + } + } +#endif + m_queue.Enqueue(o); Monitor.Pulse(m_queue); } diff --git a/projects/client/RabbitMQ.Client/src/util/SynchronizedList.cs b/projects/client/RabbitMQ.Client/src/util/SynchronizedList.cs index 479e6f28eb..ef4b0d3177 100644 --- a/projects/client/RabbitMQ.Client/src/util/SynchronizedList.cs +++ b/projects/client/RabbitMQ.Client/src/util/SynchronizedList.cs @@ -50,6 +50,11 @@ internal class SynchronizedList : IList private readonly IList list; private readonly object root; + internal SynchronizedList() + : this(new List()) + { + } + internal SynchronizedList(IList list) { this.list = list; @@ -84,6 +89,11 @@ public T this[int index] } } + public object SyncRoot + { + get { return root; } + } + public void Add(T item) { lock (root) diff --git a/projects/client/Unit.WinRT/RabbitMQ.Client.Unit.WinRT.csproj b/projects/client/Unit.WinRT/RabbitMQ.Client.Unit.WinRT.csproj new file mode 100644 index 0000000000..3183ab9bd4 --- /dev/null +++ b/projects/client/Unit.WinRT/RabbitMQ.Client.Unit.WinRT.csproj @@ -0,0 +1,118 @@ + + + + + + + + Debug + AnyCPU + 9.0.21022 + 2.0 + {897505A9-8373-4F41-8DE8-221BF06D877D} + Library + properties + RabbitMQ.Client.Test + unit-tests + 4.5 + 512 + + + true + full + false + build\bin\ + TRACE;DEBUG;NETFX_CORE + prompt + 4 + false + + + pdbonly + true + build\bin\ + TRACE;NETFX_CORE + prompt + 4 + false + + + + + false + + + true + $(SSL_CERTS_DIR) + + + + + + + + temp=/tmp + + + + + + + + + + + + + + + + + + + False + ..\..\..\lib\nunit\nunit.framework.dll + + + + + + + + + + + + {61D29F90-5B1C-4748-89FC-9FD2937F09C6} + RabbitMQ.Client + + + + + + + + <_DisabledWarnings>$(NoWarn) + + + + <_DisabledWarnings>$(NoWarn) + + + + + + + + + + + + + + + + + + + diff --git a/projects/client/Unit.WinRT/properties/AssemblyInfo.cs b/projects/client/Unit.WinRT/properties/AssemblyInfo.cs new file mode 100644 index 0000000000..91824f26cc --- /dev/null +++ b/projects/client/Unit.WinRT/properties/AssemblyInfo.cs @@ -0,0 +1,63 @@ +// This source code is dual-licensed under the Apache License, version +// 2.0, and the Mozilla Public License, version 1.1. +// +// The APL v2.0: +// +//--------------------------------------------------------------------------- +// Copyright (C) 2007-2014 GoPivotal, Inc. +// +// Licensed 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. +//--------------------------------------------------------------------------- +// +// The MPL v1.1: +// +//--------------------------------------------------------------------------- +// The contents of this file are subject to the Mozilla Public License +// Version 1.1 (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.mozilla.org/MPL/ +// +// Software distributed under the License is distributed on an "AS IS" +// basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See +// the License for the specific language governing rights and +// limitations under the License. +// +// The Original Code is RabbitMQ. +// +// The Initial Developer of the Original Code is GoPivotal, Inc. +// Copyright (c) 2007-2014 GoPivotal, Inc. All rights reserved. +//--------------------------------------------------------------------------- + +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("RabbitMQ.Client.WinRT Unit Tests")] +[assembly: AssemblyDescription("")] +[assembly: AssemblyConfiguration("")] +[assembly: AssemblyCompany("GoPivotal, Inc.")] +[assembly: AssemblyProduct("RabbitMQ.Client.WinRT")] +[assembly: AssemblyCopyright("Copyright © 2007-2014 GoPivotal, Inc.")] +[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("42d39d91-847a-44fa-9875-a508ae59bda6")] diff --git a/projects/client/Unit/RabbitMQ.Client.Unit.csproj b/projects/client/Unit/RabbitMQ.Client.Unit.csproj index 5c0a30971e..a9c36674d2 100644 --- a/projects/client/Unit/RabbitMQ.Client.Unit.csproj +++ b/projects/client/Unit/RabbitMQ.Client.Unit.csproj @@ -1,4 +1,4 @@ - + @@ -16,11 +16,6 @@ unit-tests $(PropTargetFramework) 512 - - - - - 3.5 true @@ -142,8 +137,10 @@ <_DisabledWarnings>$(NoWarn) + + - \ No newline at end of file + diff --git a/projects/client/Unit/src/unit/TestContentHeaderCodec.cs b/projects/client/Unit/src/unit/TestContentHeaderCodec.cs index 0e3f18d874..77b477e359 100644 --- a/projects/client/Unit/src/unit/TestContentHeaderCodec.cs +++ b/projects/client/Unit/src/unit/TestContentHeaderCodec.cs @@ -80,9 +80,9 @@ public void Check(ContentHeaderPropertyWriter w, byte[] expected) { Console.WriteLine(); Console.WriteLine("EXPECTED =================================================="); - DebugUtil.Dump(expected); + DebugUtil.Dump(expected, Console.Out); Console.WriteLine("ACTUAL ===================================================="); - DebugUtil.Dump(actual); + DebugUtil.Dump(actual, Console.Out); Console.WriteLine("==========================================================="); throw; } diff --git a/projects/client/Unit/src/unit/TestMethodArgumentCodec.cs b/projects/client/Unit/src/unit/TestMethodArgumentCodec.cs index d359dbd4d0..2f1b7cf24d 100644 --- a/projects/client/Unit/src/unit/TestMethodArgumentCodec.cs +++ b/projects/client/Unit/src/unit/TestMethodArgumentCodec.cs @@ -80,9 +80,9 @@ public void Check(MethodArgumentWriter w, byte[] expected) { Console.WriteLine(); Console.WriteLine("EXPECTED =================================================="); - DebugUtil.Dump(expected); + DebugUtil.Dump(expected, Console.Out); Console.WriteLine("ACTUAL ===================================================="); - DebugUtil.Dump(actual); + DebugUtil.Dump(actual, Console.Out); Console.WriteLine("==========================================================="); throw; } diff --git a/projects/client/Unit/src/unit/TestSsl.cs b/projects/client/Unit/src/unit/TestSsl.cs index 0f65f26afe..4cb398217e 100644 --- a/projects/client/Unit/src/unit/TestSsl.cs +++ b/projects/client/Unit/src/unit/TestSsl.cs @@ -92,7 +92,11 @@ public void TestServerVerifiedIgnoringNameMismatch() ConnectionFactory cf = new ConnectionFactory(); cf.Ssl.ServerName = "*"; + +#if !(NETFX_CORE) cf.Ssl.AcceptablePolicyErrors = SslPolicyErrors.RemoteCertificateNameMismatch; +#endif + cf.Ssl.Enabled = true; SendReceive(cf); } @@ -113,6 +117,7 @@ public void TestServerVerified() SendReceive(cf); } +#if !NETFX_CORE [Test] public void TestVersionVerified() { @@ -133,6 +138,7 @@ public void TestVersionVerified() cf.Ssl.Version = SslProtocols.Default; Assert.DoesNotThrow(() => SendReceive(cf)); } +#endif [Test] public void TestClientAndServerVerified() @@ -169,13 +175,17 @@ public void TestNoClientCertificate() ConnectionFactory cf = new ConnectionFactory(); cf.Ssl = new SslOption() { - Version = SslProtocols.Tls, - AcceptablePolicyErrors = SslPolicyErrors.RemoteCertificateNotAvailable | - SslPolicyErrors.RemoteCertificateNameMismatch, CertPath = null, Enabled = true, }; + +#if !NETFX_CORE + cf.Ssl.Version = SslProtocols.Tls; + cf.Ssl.AcceptablePolicyErrors = SslPolicyErrors.RemoteCertificateNotAvailable | + SslPolicyErrors.RemoteCertificateNameMismatch; +#endif + SendReceive(cf); } } -} \ No newline at end of file +} diff --git a/projects/client/Unit/src/unit/WireFormattingFixture.cs b/projects/client/Unit/src/unit/WireFormattingFixture.cs index 7ec476cad3..8a38dc719d 100644 --- a/projects/client/Unit/src/unit/WireFormattingFixture.cs +++ b/projects/client/Unit/src/unit/WireFormattingFixture.cs @@ -76,9 +76,9 @@ public void Check(NetworkBinaryWriter w, byte[] expected) { Console.WriteLine(); Console.WriteLine("EXPECTED =================================================="); - DebugUtil.Dump(expected); + DebugUtil.Dump(expected, Console.Out); Console.WriteLine("ACTUAL ===================================================="); - DebugUtil.Dump(actual); + DebugUtil.Dump(actual, Console.Out); Console.WriteLine("==========================================================="); throw; } diff --git a/projects/examples/WinRT/Subscriber/App.xaml b/projects/examples/WinRT/Subscriber/App.xaml new file mode 100644 index 0000000000..2166314965 --- /dev/null +++ b/projects/examples/WinRT/Subscriber/App.xaml @@ -0,0 +1,21 @@ + + + + + + + + + + + + + diff --git a/projects/examples/WinRT/Subscriber/App.xaml.cs b/projects/examples/WinRT/Subscriber/App.xaml.cs new file mode 100644 index 0000000000..1aa3f8c159 --- /dev/null +++ b/projects/examples/WinRT/Subscriber/App.xaml.cs @@ -0,0 +1,103 @@ +using System; +using System.Collections.Generic; +using System.Diagnostics.Tracing; +using System.IO; +using System.Linq; +using Windows.ApplicationModel; +using Windows.ApplicationModel.Activation; +using Windows.Foundation; +using Windows.Foundation.Collections; +using Windows.UI.Xaml; +using Windows.UI.Xaml.Controls; +using Windows.UI.Xaml.Controls.Primitives; +using Windows.UI.Xaml.Data; +using Windows.UI.Xaml.Input; +using Windows.UI.Xaml.Media; +using Windows.UI.Xaml.Navigation; + +using RabbitMQ.Util; + +// The Blank Application template is documented at http://go.microsoft.com/fwlink/?LinkId=234227 + +namespace RabbitMQ.Client.Examples.WinRT.Subscriber +{ + /// + /// Provides application-specific behavior to supplement the default Application class. + /// + sealed partial class App : Application + { + /// + /// Initializes the singleton application object. This is the first line of authored code + /// executed, and as such is the logical equivalent of main() or WinMain(). + /// + public App() + { + this.InitializeComponent(); + this.Suspending += OnSuspending; + } + + /// + /// Invoked when the application is launched normally by the end user. Other entry points + /// will be used when the application is launched to open a specific file, to display + /// search results, and so forth. + /// + /// Details about the launch request and process. + protected override void OnLaunched(LaunchActivatedEventArgs args) + { + Frame rootFrame = Window.Current.Content as Frame; + + // Do not repeat app initialization when the Window already has content, + // just ensure that the window is active + if (rootFrame == null) + { + // Create a Frame to act as the navigation context and navigate to the first page + rootFrame = new Frame(); + + if (args.PreviousExecutionState == ApplicationExecutionState.Terminated) + { + //TODO: Load state from previously suspended application + } + + // Place the frame in the current Window + Window.Current.Content = rootFrame; + } + + if (rootFrame.Content == null) + { + this.ConfigureEventListeners(); + + // When the navigation stack isn't restored navigate to the first page, + // configuring the new page by passing required information as a navigation + // parameter + if (!rootFrame.Navigate(typeof(MainPage), args.Arguments)) + { + throw new Exception("Failed to create initial page"); + } + } + // Ensure the current window is active + Window.Current.Activate(); + } + + private void ConfigureEventListeners() + { + // First time execution, initialize the logger + EventListener verboseListener = new StorageFileEventListener(); + + verboseListener.EnableEvents(MetroEventSource.Log, EventLevel.Verbose); + } + + /// + /// Invoked when application execution is being suspended. Application state is saved + /// without knowing whether the application will be terminated or resumed with the contents + /// of memory still intact. + /// + /// The source of the suspend request. + /// Details about the suspend request. + private void OnSuspending(object sender, SuspendingEventArgs e) + { + var deferral = e.SuspendingOperation.GetDeferral(); + //TODO: Save application state and stop any background activity + deferral.Complete(); + } + } +} diff --git a/projects/examples/WinRT/Subscriber/Assets/Logo.png b/projects/examples/WinRT/Subscriber/Assets/Logo.png new file mode 100644 index 0000000000..c16d44655b Binary files /dev/null and b/projects/examples/WinRT/Subscriber/Assets/Logo.png differ diff --git a/projects/examples/WinRT/Subscriber/Assets/SmallLogo.png b/projects/examples/WinRT/Subscriber/Assets/SmallLogo.png new file mode 100644 index 0000000000..450524ab0b Binary files /dev/null and b/projects/examples/WinRT/Subscriber/Assets/SmallLogo.png differ diff --git a/projects/examples/WinRT/Subscriber/Assets/SplashScreen.png b/projects/examples/WinRT/Subscriber/Assets/SplashScreen.png new file mode 100644 index 0000000000..d0e49466e1 Binary files /dev/null and b/projects/examples/WinRT/Subscriber/Assets/SplashScreen.png differ diff --git a/projects/examples/WinRT/Subscriber/Assets/StoreLogo.png b/projects/examples/WinRT/Subscriber/Assets/StoreLogo.png new file mode 100644 index 0000000000..5904b1e202 Binary files /dev/null and b/projects/examples/WinRT/Subscriber/Assets/StoreLogo.png differ diff --git a/projects/examples/WinRT/Subscriber/Assets/WideLogo.png b/projects/examples/WinRT/Subscriber/Assets/WideLogo.png new file mode 100644 index 0000000000..307d230055 Binary files /dev/null and b/projects/examples/WinRT/Subscriber/Assets/WideLogo.png differ diff --git a/projects/examples/WinRT/Subscriber/Common/StandardStyles.xaml b/projects/examples/WinRT/Subscriber/Common/StandardStyles.xaml new file mode 100644 index 0000000000..85f4ed640e --- /dev/null +++ b/projects/examples/WinRT/Subscriber/Common/StandardStyles.xaml @@ -0,0 +1,1829 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + Mouse + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/projects/examples/WinRT/Subscriber/MainPage.xaml b/projects/examples/WinRT/Subscriber/MainPage.xaml new file mode 100644 index 0000000000..e301feb363 --- /dev/null +++ b/projects/examples/WinRT/Subscriber/MainPage.xaml @@ -0,0 +1,129 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + Exchange: + + + + Exchange Type: + + + + + Routing Key: + + + + + + + Uri: + + + + + + + + + + + + + + + Send Count: + + + + + + + + + + + + + + + + + + + + diff --git a/projects/examples/WinRT/Subscriber/MainPage.xaml.cs b/projects/examples/WinRT/Subscriber/MainPage.xaml.cs new file mode 100644 index 0000000000..bd98882745 --- /dev/null +++ b/projects/examples/WinRT/Subscriber/MainPage.xaml.cs @@ -0,0 +1,252 @@ +using System; +using System.Collections.Generic; +using System.Diagnostics; +using System.IO; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +using Windows.Foundation; +using Windows.Foundation.Collections; +using Windows.UI.Core; +using Windows.UI.Popups; +using Windows.UI.Xaml; +using Windows.UI.Xaml.Controls; +using Windows.UI.Xaml.Controls.Primitives; +using Windows.UI.Xaml.Data; +using Windows.UI.Xaml.Input; +using Windows.UI.Xaml.Media; +using Windows.UI.Xaml.Navigation; + +using RabbitMQ.Client.Events; +// The Blank Page item template is documented at http://go.microsoft.com/fwlink/?LinkId=234238 +using RabbitMQ.Client.MessagePatterns; + +namespace RabbitMQ.Client.Examples.WinRT.Subscriber +{ + /// + /// An empty page that can be used on its own or navigated to within a Frame. + /// + public sealed partial class MainPage : Page + { + private MainPageViewModel viewModel; + + private int messageNumber = 0; + private int sentMessageNumber = 0; + + private ConnectionFactory connectionFactory; + private IConnection connection; + private IModel model; + private Subscription sub; + + public MainPage() + { + this.InitializeComponent(); + + this.viewModel = new MainPageViewModel(); + this.DataContext = this.viewModel; + } + + /// + /// Invoked when this page is about to be displayed in a Frame. + /// + /// Event data that describes how this page was reached. The Parameter + /// property is typically used to configure the page. + protected override void OnNavigatedTo(NavigationEventArgs e) + { + } + + private async void ConnectAction_Click(object sender, RoutedEventArgs e) + { + Exception exceptionOccurred = null; + try + { + this.Disconnect(); + + var exchange = this.viewModel.Exchange ?? string.Empty; + var exchangeType = this.viewModel.ExchangeType; + var routingKey = this.viewModel.RoutingKey; + + this.connectionFactory = new ConnectionFactory + { + Uri = this.viewModel.Uri, + }; + + await this.ConnectAsync(routingKey, exchange, exchangeType); + + this.viewModel.ConnectionStatus = "Connected"; + } + catch (Exception ex) + { + exceptionOccurred = ex; + } + + if (exceptionOccurred != null) + { + await this.ErrorOccured(exceptionOccurred); + this.viewModel.ConnectionStatus = "Error Connecting"; + } + } + + private Task ConnectAsync(string routingKey, string exchange, string exchangeType) { + var currentSynchronizationContext = TaskScheduler.FromCurrentSynchronizationContext(); + return Task.Factory.StartNew( + () => + { + this.connection = this.connectionFactory.CreateConnection(); + this.connection.ConnectionShutdown += ConnectionOnConnectionShutdown; + + this.model = this.connection.CreateModel(); + this.model.QueueDeclare(routingKey, false, false, false, null); + + this.sub = new Subscription(this.model, routingKey); + var ignoreTask = this.sub.NextAsync() + .ContinueWith(this.SubscriptionContinuation, currentSynchronizationContext); + + if (exchange != "") { + this.model.ExchangeDeclare(exchange, exchangeType); + this.model.QueueBind(routingKey, exchange, routingKey, null); + } + }); + } + + private void ConnectionOnConnectionShutdown(object sender, ShutdownEventArgs reason) { + connection.ConnectionShutdown -= this.ConnectionOnConnectionShutdown; + + Debug.WriteLine("Connection was shutdown: " + reason.ToString()); + + var ignoreTask = this.Dispatcher.RunAsync( + CoreDispatcherPriority.Normal, + () => this.viewModel.ConnectionStatus = "Shutdown - " + reason.ReplyText); + + // NOTE: Normally, one would tie into the App.Resuming event and re-connect to the AMQP broker + } + + private async void SubscriptionContinuation(Task continuation) + { + Exception exceptionOccurred = null; + try { + // receive and add to the viewmodel + BasicDeliverEventArgs eventArgs = continuation.Result; + + if (eventArgs == null) { + Debug.WriteLine("Received empty BasicDeliverEventArgs."); + return; + } + + this.AddReceivedMessage(eventArgs); + await Task.Factory.StartNew(() => this.sub.Ack(eventArgs)); + + // Receive the next message + var ignoreTask = this.sub.NextAsync() + .ContinueWith(this.SubscriptionContinuation, TaskScheduler.FromCurrentSynchronizationContext()); + } + catch (AggregateException ex) { + if (ex.InnerException is EndOfStreamException) { + Debug.WriteLine("Shutdown"); + } + else { + exceptionOccurred = ex; + } + } + catch (Exception ex) { + exceptionOccurred = ex; + } + + if (exceptionOccurred != null) + { + await this.ErrorOccured(exceptionOccurred); + } + } + + private void AddReceivedMessage(BasicDeliverEventArgs eventArgs) { + this.viewModel.MessagesReceived.Insert( + 0, + new MainPageViewModel.ReceivedMessage(this.messageNumber++, eventArgs.Body)); + } + + private void AddMessage(string message) + { + this.viewModel.MessagesReceived.Insert( + 0, + new MainPageViewModel.ReceivedMessage(this.messageNumber++, message)); + } + + private async void DisconnectAction_Click(object sender, RoutedEventArgs e) + { + Exception exceptionOccurred = null; + try + { + this.Disconnect(); + } + catch (Exception ex) + { + exceptionOccurred = ex; + } + + if (exceptionOccurred != null) + { + this.viewModel.ConnectionStatus = "Error Disconnecting"; + await this.ErrorOccured(exceptionOccurred); + } + } + + private void Disconnect() { + if (this.sub != null) { + this.sub.Close(); + } + this.sub = null; + + if (this.model != null && this.model.IsOpen) { + this.model.Abort(); + } + this.model = null; + + if (this.connection != null && this.connection.IsOpen) { + this.connection.Abort(); + } + this.connection = null; + this.viewModel.ConnectionStatus = "Disconnected"; + } + + private async void SendMessagesAction_Click(object sender, RoutedEventArgs e) + { + Exception exceptionOccurred = null; + var exchange = this.viewModel.Exchange ?? string.Empty; + if (exchange != string.Empty) + { + this.model.ExchangeDeclare(exchange, this.viewModel.ExchangeType); + } + + try + { + for (int i = 0; i < this.viewModel.SendCount; i++) { + var format = string.Format("Welcome to Caerbannog! (sent: {0})", this.sentMessageNumber++); + await this.SendMessageAsync(Encoding.UTF8.GetBytes(format), exchange, "test"); + } + } + catch (Exception ex) + { + exceptionOccurred = ex; + } + + if (exceptionOccurred != null) { + await this.ErrorOccured(exceptionOccurred); + } + } + + private Task SendMessageAsync(byte[] message, string exchange, string routingKey) { + var model = this.model; + if (model == null) throw new NullReferenceException("IModel is not set, probably not connected."); + + return Task.Factory.StartNew( + () => model.BasicPublish(exchange, routingKey, null, message)); + } + + private async Task ErrorOccured(Exception exceptionOccurred) { + Debug.WriteLine(exceptionOccurred); + var dialog = new MessageDialog(exceptionOccurred.ToString()); + await dialog.ShowAsync(); + } + } +} diff --git a/projects/examples/WinRT/Subscriber/MainPageViewModel.cs b/projects/examples/WinRT/Subscriber/MainPageViewModel.cs new file mode 100644 index 0000000000..f621c54a13 --- /dev/null +++ b/projects/examples/WinRT/Subscriber/MainPageViewModel.cs @@ -0,0 +1,209 @@ +using System.Collections.ObjectModel; +using System.ComponentModel; +using System.Runtime.CompilerServices; +using System.Text; + +using RabbitMQ.Client.Examples.WinRT.Subscriber.Annotations; + +namespace RabbitMQ.Client.Examples.WinRT.Subscriber +{ + public class MainPageViewModel : INotifyPropertyChanged + { + private bool useServerNamedQueue; + private string exchange; + private string uri; + private int sendCount; + private bool blockingReceiveSelected; + private bool enumeratingReceiveSelected; + private readonly ObservableCollection messagesReceived = new ObservableCollection(); + private readonly ObservableCollection exchangeTypes = new ObservableCollection(Client.ExchangeType.All()); + private string exchangeType; + private string routingKey; + private string connectionStatus; + + public event PropertyChangedEventHandler PropertyChanged; + + public bool UseServerNamedQueue + { + get { return this.useServerNamedQueue; } + set + { + if (value.Equals(this.useServerNamedQueue)) + { + return; + } + this.useServerNamedQueue = value; + this.OnPropertyChanged(); + } + } + + public string Exchange + { + get { return this.exchange; } + set + { + if (value == this.exchange) + { + return; + } + this.exchange = value; + this.OnPropertyChanged(); + } + } + + public string ExchangeType + { + get { return this.exchangeType; } + set + { + if (value == this.exchangeType) + { + return; + } + this.exchangeType = value; + this.OnPropertyChanged(); + } + } + + public string RoutingKey + { + get { return this.routingKey; } + set + { + if (value == this.routingKey) + { + return; + } + this.routingKey = value; + this.OnPropertyChanged(); + } + } + + public string ConnectionStatus + { + get { return this.connectionStatus; } + set + { + if (value == this.connectionStatus) + { + return; + } + this.connectionStatus = value; + this.OnPropertyChanged(); + } + } + + public string Uri + { + get { return this.uri; } + set + { + if (value == this.uri) + { + return; + } + this.uri = value; + this.OnPropertyChanged(); + } + } + + public int SendCount + { + get { return this.sendCount; } + set + { + if (value == this.sendCount) + { + return; + } + this.sendCount = value; + this.OnPropertyChanged(); + } + } + + public bool BlockingReceiveSelected + { + get { return this.blockingReceiveSelected; } + set + { + if (value.Equals(this.blockingReceiveSelected)) + { + return; + } + this.blockingReceiveSelected = value; + this.OnPropertyChanged(); + } + } + + public bool EnumeratingReceiveSelected + { + get { return this.enumeratingReceiveSelected; } + set + { + if (value.Equals(this.enumeratingReceiveSelected)) + { + return; + } + this.enumeratingReceiveSelected = value; + this.OnPropertyChanged(); + } + } + + public ObservableCollection MessagesReceived + { + get { return this.messagesReceived; } + } + + public ObservableCollection ExchangeTypes + { + get { return this.exchangeTypes; } + } + + public MainPageViewModel() + { + //this.uri = "amqp://user:pass@host:port/vhost"; + this.uri = "amqp://localhost/"; + this.exchange = string.Empty; + this.routingKey = "test"; + this.sendCount = 10; + this.blockingReceiveSelected = true; + this.useServerNamedQueue = false; + this.connectionStatus = "Disconnected"; + this.exchangeType = Client.ExchangeType.Direct; + } + + [NotifyPropertyChangedInvocator] + protected virtual void OnPropertyChanged([CallerMemberName] string propertyName = null) + { + PropertyChangedEventHandler handler = PropertyChanged; + if (handler != null) + { + handler(this, new PropertyChangedEventArgs(propertyName)); + } + } + + public class ReceivedMessage + { + public ReceivedMessage(int i, byte[] body) + :this(i, Encoding.UTF8.GetString(body, 0, body.Length)) + { + } + + public ReceivedMessage(int i, string message) + { + this.DecodedString = string.Format("Message {0}: {1}", i, message); + } + + public string DecodedString { get; set; } + } + } + + public class MainPageViewModelDesign : MainPageViewModel + { + public MainPageViewModelDesign() + { + this.MessagesReceived.Add(new ReceivedMessage(0, "Welcome to Caerbannog!")); + this.MessagesReceived.Add(new ReceivedMessage(1, "Welcome to Caerbannog!")); + } + } +} \ No newline at end of file diff --git a/projects/examples/WinRT/Subscriber/Package.appxmanifest b/projects/examples/WinRT/Subscriber/Package.appxmanifest new file mode 100644 index 0000000000..7fbd94edf7 --- /dev/null +++ b/projects/examples/WinRT/Subscriber/Package.appxmanifest @@ -0,0 +1,27 @@ + + + + + RabbitMQ.Client.Examples.WinRT.Subscriber + RabbitMQ Example + Assets\StoreLogo.png + + + 6.2.1 + 6.2.1 + + + + + + + + + + + + + + + + \ No newline at end of file diff --git a/projects/examples/WinRT/Subscriber/Properties/Annotations.cs b/projects/examples/WinRT/Subscriber/Properties/Annotations.cs new file mode 100644 index 0000000000..39fb45f925 --- /dev/null +++ b/projects/examples/WinRT/Subscriber/Properties/Annotations.cs @@ -0,0 +1,689 @@ +/* + * Copyright 2007-2012 JetBrains s.r.o. + * + * Licensed 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.ComponentModel; + +namespace RabbitMQ.Client.Examples.WinRT.Subscriber.Annotations +{ + /// + /// Indicates that marked element should be localized or not. + /// + /// + /// + /// [LocalizationRequiredAttribute(true)] + /// public class Foo + /// { + /// private string str = "my string"; // Warning: Localizable string + /// } + /// + /// + [AttributeUsage(AttributeTargets.All, AllowMultiple = false, Inherited = true)] + public sealed class LocalizationRequiredAttribute : Attribute + { + /// + /// Initializes a new instance of the class with + /// set to . + /// + public LocalizationRequiredAttribute() : this(true) + { + } + + /// + /// Initializes a new instance of the class. + /// + /// true if a element should be localized; otherwise, false. + public LocalizationRequiredAttribute(bool required) + { + Required = required; + } + + /// + /// Gets a value indicating whether a element should be localized. + /// true if a element should be localized; otherwise, false. + /// + [UsedImplicitly] public bool Required { get; private set; } + + /// + /// Returns whether the value of the given object is equal to the current . + /// + /// The object to test the value equality of. + /// + /// true if the value of the given object is equal to that of the current; otherwise, false. + /// + public override bool Equals(object obj) + { + var attribute = obj as LocalizationRequiredAttribute; + return attribute != null && attribute.Required == Required; + } + + /// + /// Returns the hash code for this instance. + /// + /// A hash code for the current . + public override int GetHashCode() + { + return base.GetHashCode(); + } + } + + /// + /// Indicates that the marked method builds string by format pattern and (optional) arguments. + /// Parameter, which contains format string, should be given in constructor. + /// The format string should be in -like form + /// + /// + /// + /// [StringFormatMethod("message")] + /// public void ShowError(string message, params object[] args) + /// { + /// //Do something + /// } + /// public void Foo() + /// { + /// ShowError("Failed: {0}"); // Warning: Non-existing argument in format string + /// } + /// + /// + [AttributeUsage(AttributeTargets.Constructor | AttributeTargets.Method, AllowMultiple = false, Inherited = true)] + public sealed class StringFormatMethodAttribute : Attribute + { + /// + /// Initializes new instance of StringFormatMethodAttribute + /// + /// Specifies which parameter of an annotated method should be treated as format-string + public StringFormatMethodAttribute(string formatParameterName) + { + FormatParameterName = formatParameterName; + } + + /// + /// Gets format parameter name + /// + [UsedImplicitly] public string FormatParameterName { get; private set; } + } + + /// + /// Indicates that the function argument should be string literal and match one of the parameters + /// of the caller function. + /// For example, ReSharper annotates the parameter of . + /// + /// + /// + /// public void Foo(string param) + /// { + /// if (param == null) + /// throw new ArgumentNullException("par"); // Warning: Cannot resolve symbol + /// } + /// + /// + [AttributeUsage(AttributeTargets.Parameter, AllowMultiple = false, Inherited = true)] + public sealed class InvokerParameterNameAttribute : Attribute { } + + /// + /// Indicates that the method is contained in a type that implements + /// interface + /// and this method is used to notify that some property value changed. + /// + /// + /// The method should be non-static and conform to one of the supported signatures: + /// + /// NotifyChanged(string) + /// NotifyChanged(params string[]) + /// NotifyChanged{T}(Expression{Func{T}}) + /// NotifyChanged{T,U}(Expression{Func{T,U}}) + /// SetProperty{T}(ref T, T, string) + /// + /// + /// + /// + /// public class Foo : INotifyPropertyChanged + /// { + /// public event PropertyChangedEventHandler PropertyChanged; + /// + /// [NotifyPropertyChangedInvocator] + /// protected virtual void NotifyChanged(string propertyName) + /// {} + /// + /// private string _name; + /// public string Name + /// { + /// get { return _name; } + /// set + /// { + /// _name = value; + /// NotifyChanged("LastName"); // Warning + /// } + /// } + /// } + /// + /// Examples of generated notifications: + /// + /// NotifyChanged("Property") + /// NotifyChanged(() => Property) + /// NotifyChanged((VM x) => x.Property) + /// SetProperty(ref myField, value, "Property") + /// + /// + [AttributeUsage(AttributeTargets.Method, AllowMultiple = false, Inherited = true)] + public sealed class NotifyPropertyChangedInvocatorAttribute : Attribute + { + public NotifyPropertyChangedInvocatorAttribute() { } + public NotifyPropertyChangedInvocatorAttribute(string parameterName) + { + ParameterName = parameterName; + } + + [UsedImplicitly] public string ParameterName { get; private set; } + } + + /// + /// Indicates that the value of the marked element could be null sometimes, + /// so the check for null is necessary before its usage. + /// + /// + /// + /// [CanBeNull] + /// public object Test() + /// { + /// return null; + /// } + /// + /// public void UseTest() + /// { + /// var p = Test(); + /// var s = p.ToString(); // Warning: Possible 'System.NullReferenceException' + /// } + /// + /// + [AttributeUsage(AttributeTargets.Method | AttributeTargets.Parameter | AttributeTargets.Property | AttributeTargets.Delegate | AttributeTargets.Field, AllowMultiple = false, Inherited = true)] + public sealed class CanBeNullAttribute : Attribute { } + + /// + /// Indicates that the value of the marked element could never be null + /// + /// + /// + /// [NotNull] + /// public object Foo() + /// { + /// return null; // Warning: Possible 'null' assignment + /// } + /// + /// + [AttributeUsage(AttributeTargets.Method | AttributeTargets.Parameter | AttributeTargets.Property | AttributeTargets.Delegate | AttributeTargets.Field, AllowMultiple = false, Inherited = true)] + public sealed class NotNullAttribute : Attribute { } + + /// + /// Describes dependency between method input and output. + /// + /// + ///

Function Definition Table syntax:

+ /// + /// FDT ::= FDTRow [;FDTRow]* + /// FDTRow ::= Input => Output | Output <= Input + /// Input ::= ParameterName: Value [, Input]* + /// Output ::= [ParameterName: Value]* {halt|stop|void|nothing|Value} + /// Value ::= true | false | null | notnull | canbenull + /// + /// If method has single input parameter, it's name could be omitted.
+ /// Using halt (or void/nothing, which is the same) for method output means that the methos doesn't return normally.
+ /// canbenull annotation is only applicable for output parameters.
+ /// You can use multiple [ContractAnnotation] for each FDT row, or use single attribute with rows separated by semicolon.
+ /// + /// + /// + /// + /// [ContractAnnotation("=> halt")] + /// public void TerminationMethod() + /// + /// + /// [ContractAnnotation("halt <= condition: false")] + /// public void Assert(bool condition, string text) // Regular Assertion method + /// + /// + /// [ContractAnnotation("s:null => true")] + /// public bool IsNullOrEmpty(string s) // String.IsNullOrEmpty + /// + /// + /// // A method that returns null if the parameter is null, and not null if the parameter is not null + /// [ContractAnnotation("null => null; notnull => notnull")] + /// public object Transform(object data) + /// + /// + /// [ContractAnnotation("s:null=>false; =>true,result:notnull; =>false, result:null")] + /// public bool TryParse(string s, out Person result) + /// + /// + /// + [AttributeUsage(AttributeTargets.Method, AllowMultiple = true, Inherited = true)] + public sealed class ContractAnnotationAttribute : Attribute + { + public ContractAnnotationAttribute([NotNull] string fdt) : this (fdt, false) + { + } + + public ContractAnnotationAttribute([NotNull] string fdt, bool forceFullStates) + { + FDT = fdt; + ForceFullStates = forceFullStates; + } + + public string FDT { get; private set; } + public bool ForceFullStates { get; private set; } + } + + /// + /// Indicates that the value of the marked type (or its derivatives) + /// cannot be compared using '==' or '!=' operators and Equals() should be used instead. + /// However, using '==' or '!=' for comparison with null is always permitted. + /// + /// + /// + /// [CannotApplyEqualityOperator] + /// class NoEquality + /// { + /// } + /// + /// class UsesNoEquality + /// { + /// public void Test() + /// { + /// var ca1 = new NoEquality(); + /// var ca2 = new NoEquality(); + /// + /// if (ca1 != null) // OK + /// { + /// bool condition = ca1 == ca2; // Warning + /// } + /// } + /// } + /// + /// + [AttributeUsage(AttributeTargets.Interface | AttributeTargets.Class | AttributeTargets.Struct, AllowMultiple = false, Inherited = true)] + public sealed class CannotApplyEqualityOperatorAttribute : Attribute { } + + /// + /// When applied to a target attribute, specifies a requirement for any type marked with + /// the target attribute to implement or inherit specific type or types. + /// + /// + /// + /// [BaseTypeRequired(typeof(IComponent)] // Specify requirement + /// public class ComponentAttribute : Attribute + /// {} + /// + /// [Component] // ComponentAttribute requires implementing IComponent interface + /// public class MyComponent : IComponent + /// {} + /// + /// + [AttributeUsage(AttributeTargets.Class, AllowMultiple = true, Inherited = true)] + [BaseTypeRequired(typeof(Attribute))] + public sealed class BaseTypeRequiredAttribute : Attribute + { + /// + /// Initializes new instance of BaseTypeRequiredAttribute + /// + /// Specifies which types are required + public BaseTypeRequiredAttribute(Type baseType) + { + BaseTypes = new[] { baseType }; + } + + /// + /// Gets enumerations of specified base types + /// + public Type[] BaseTypes { get; private set; } + } + + /// + /// Indicates that the marked symbol is used implicitly (e.g. via reflection, in external library), + /// so this symbol will not be marked as unused (as well as by other usage inspections) + /// + [AttributeUsage(AttributeTargets.All, AllowMultiple = false, Inherited = true)] + public sealed class UsedImplicitlyAttribute : Attribute + { + [UsedImplicitly] public UsedImplicitlyAttribute() + : this(ImplicitUseKindFlags.Default, ImplicitUseTargetFlags.Default) { } + + [UsedImplicitly] + public UsedImplicitlyAttribute(ImplicitUseKindFlags useKindFlags, ImplicitUseTargetFlags targetFlags) + { + UseKindFlags = useKindFlags; + TargetFlags = targetFlags; + } + + [UsedImplicitly] public UsedImplicitlyAttribute(ImplicitUseKindFlags useKindFlags) + : this(useKindFlags, ImplicitUseTargetFlags.Default) { } + + [UsedImplicitly] public UsedImplicitlyAttribute(ImplicitUseTargetFlags targetFlags) + : this(ImplicitUseKindFlags.Default, targetFlags) { } + + [UsedImplicitly] public ImplicitUseKindFlags UseKindFlags { get; private set; } + + /// + /// Gets value indicating what is meant to be used + /// + [UsedImplicitly] public ImplicitUseTargetFlags TargetFlags { get; private set; } + } + + /// + /// Should be used on attributes and causes ReSharper + /// to not mark symbols marked with such attributes as unused (as well as by other usage inspections) + /// + [AttributeUsage(AttributeTargets.Class, AllowMultiple = false, Inherited = true)] + public sealed class MeansImplicitUseAttribute : Attribute + { + [UsedImplicitly] public MeansImplicitUseAttribute() + : this(ImplicitUseKindFlags.Default, ImplicitUseTargetFlags.Default) { } + + [UsedImplicitly] + public MeansImplicitUseAttribute(ImplicitUseKindFlags useKindFlags, ImplicitUseTargetFlags targetFlags) + { + UseKindFlags = useKindFlags; + TargetFlags = targetFlags; + } + + [UsedImplicitly] public MeansImplicitUseAttribute(ImplicitUseKindFlags useKindFlags) + : this(useKindFlags, ImplicitUseTargetFlags.Default) + { + } + + [UsedImplicitly] public MeansImplicitUseAttribute(ImplicitUseTargetFlags targetFlags) + : this(ImplicitUseKindFlags.Default, targetFlags) { } + + [UsedImplicitly] public ImplicitUseKindFlags UseKindFlags { get; private set; } + + /// + /// Gets value indicating what is meant to be used + /// + [UsedImplicitly] public ImplicitUseTargetFlags TargetFlags { get; private set; } + } + + [Flags] + public enum ImplicitUseKindFlags + { + Default = Access | Assign | InstantiatedWithFixedConstructorSignature, + + /// + /// Only entity marked with attribute considered used + /// + Access = 1, + + /// + /// Indicates implicit assignment to a member + /// + Assign = 2, + + /// + /// Indicates implicit instantiation of a type with fixed constructor signature. + /// That means any unused constructor parameters won't be reported as such. + /// + InstantiatedWithFixedConstructorSignature = 4, + + /// + /// Indicates implicit instantiation of a type + /// + InstantiatedNoFixedConstructorSignature = 8, + } + + /// + /// Specify what is considered used implicitly when marked with or + /// + [Flags] + public enum ImplicitUseTargetFlags + { + Default = Itself, + + Itself = 1, + + /// + /// Members of entity marked with attribute are considered used + /// + Members = 2, + + /// + /// Entity marked with attribute and all its members considered used + /// + WithMembers = Itself | Members + } + + /// + /// This attribute is intended to mark publicly available API which should not be removed and so is treated as used. + /// + [MeansImplicitUse] + public sealed class PublicAPIAttribute : Attribute + { + public PublicAPIAttribute() { } + public PublicAPIAttribute(string comment) { } + } + + /// + /// Tells code analysis engine if the parameter is completely handled when the invoked method is on stack. + /// If the parameter is a delegate, indicates that delegate is executed while the method is executed. + /// If the parameter is an enumerable, indicates that it is enumerated while the method is executed. + /// + [AttributeUsage(AttributeTargets.Parameter, Inherited = true)] + public sealed class InstantHandleAttribute : Attribute { } + + + /// + /// Indicates that a method does not make any observable state changes. + /// The same as + /// + /// + /// + /// [Pure] + /// private int Multiply(int x, int y) + /// { + /// return x*y; + /// } + /// + /// public void Foo() + /// { + /// const int a=2, b=2; + /// Multiply(a, b); // Waring: Return value of pure method is not used + /// } + /// + /// + [AttributeUsage(AttributeTargets.Method, Inherited = true)] + public sealed class PureAttribute : Attribute { } + + /// + /// Indicates that a parameter is a path to a file or a folder within a web project. + /// Path can be relative or absolute, starting from web root (~). + /// + [AttributeUsage(AttributeTargets.Parameter)] + public class PathReferenceAttribute : Attribute + { + public PathReferenceAttribute() { } + + [UsedImplicitly] + public PathReferenceAttribute([PathReference] string basePath) + { + BasePath = basePath; + } + + [UsedImplicitly] public string BasePath { get; private set; } + } + + // ASP.NET MVC attributes + + /// + /// ASP.NET MVC attribute. If applied to a parameter, indicates that the parameter is an MVC action. + /// If applied to a method, the MVC action name is calculated implicitly from the context. + /// Use this attribute for custom wrappers similar to + /// + /// + [AttributeUsage(AttributeTargets.Parameter | AttributeTargets.Method)] + public sealed class AspMvcActionAttribute : Attribute + { + [UsedImplicitly] public string AnonymousProperty { get; private set; } + + public AspMvcActionAttribute() { } + + public AspMvcActionAttribute(string anonymousProperty) + { + AnonymousProperty = anonymousProperty; + } + } + + /// + /// ASP.NET MVC attribute. Indicates that a parameter is an MVC araa. + /// Use this attribute for custom wrappers similar to + /// + /// + [AttributeUsage(AttributeTargets.Parameter)] + public sealed class AspMvcAreaAttribute : PathReferenceAttribute + { + [UsedImplicitly] public string AnonymousProperty { get; private set; } + + [UsedImplicitly] public AspMvcAreaAttribute() { } + + public AspMvcAreaAttribute(string anonymousProperty) + { + AnonymousProperty = anonymousProperty; + } + } + + /// + /// ASP.NET MVC attribute. If applied to a parameter, indicates that the parameter is an MVC controller. + /// If applied to a method, the MVC controller name is calculated implicitly from the context. + /// Use this attribute for custom wrappers similar to + /// + /// + [AttributeUsage(AttributeTargets.Parameter | AttributeTargets.Method)] + public sealed class AspMvcControllerAttribute : Attribute + { + [UsedImplicitly] public string AnonymousProperty { get; private set; } + + public AspMvcControllerAttribute() { } + + public AspMvcControllerAttribute(string anonymousProperty) + { + AnonymousProperty = anonymousProperty; + } + } + + /// + /// ASP.NET MVC attribute. Indicates that a parameter is an MVC Master. + /// Use this attribute for custom wrappers similar to + /// + /// + [AttributeUsage(AttributeTargets.Parameter)] + public sealed class AspMvcMasterAttribute : Attribute { } + + /// + /// ASP.NET MVC attribute. Indicates that a parameter is an MVC model type. + /// Use this attribute for custom wrappers similar to + /// + /// + [AttributeUsage(AttributeTargets.Parameter)] + public sealed class AspMvcModelTypeAttribute : Attribute { } + + /// + /// ASP.NET MVC attribute. If applied to a parameter, indicates that the parameter is an MVC partial view. + /// If applied to a method, the MVC partial view name is calculated implicitly from the context. + /// Use this attribute for custom wrappers similar to + /// + /// + [AttributeUsage(AttributeTargets.Parameter | AttributeTargets.Method)] + public sealed class AspMvcPartialViewAttribute : PathReferenceAttribute { } + + /// + /// ASP.NET MVC attribute. Allows disabling all inspections for MVC views within a class or a method. + /// + [AttributeUsage(AttributeTargets.Class | AttributeTargets.Method)] + public sealed class AspMvcSupressViewErrorAttribute : Attribute { } + + /// + /// ASP.NET MVC attribute. Indicates that a parameter is an MVC display template. + /// Use this attribute for custom wrappers similar to + /// + /// + [AttributeUsage(AttributeTargets.Parameter)] + public sealed class AspMvcDisplayTemplateAttribute : Attribute { } + + /// + /// ASP.NET MVC attribute. Indicates that a parameter is an MVC editor template. + /// Use this attribute for custom wrappers similar to + /// + /// + [AttributeUsage(AttributeTargets.Parameter)] + public sealed class AspMvcEditorTemplateAttribute : Attribute { } + + /// + /// ASP.NET MVC attribute. If applied to a parameter, indicates that the parameter is an MVC view. + /// If applied to a method, the MVC view name is calculated implicitly from the context. + /// Use this attribute for custom wrappers similar to + /// + /// + [AttributeUsage(AttributeTargets.Parameter | AttributeTargets.Method)] + public sealed class AspMvcViewAttribute : PathReferenceAttribute { } + + /// + /// ASP.NET MVC attribute. When applied to a parameter of an attribute, + /// indicates that this parameter is an MVC action name. + /// + /// + /// + /// [ActionName("Foo")] + /// public ActionResult Login(string returnUrl) + /// { + /// ViewBag.ReturnUrl = Url.Action("Foo"); // OK + /// return RedirectToAction("Bar"); // Error: Cannot resolve action + /// } + /// + /// + [AttributeUsage(AttributeTargets.Parameter | AttributeTargets.Property)] + public sealed class AspMvcActionSelectorAttribute : Attribute { } + + [AttributeUsage(AttributeTargets.Parameter | AttributeTargets.Property | AttributeTargets.Field, Inherited = true)] + public sealed class HtmlElementAttributesAttribute : Attribute + { + public HtmlElementAttributesAttribute() { } + + public HtmlElementAttributesAttribute(string name) + { + Name = name; + } + + [UsedImplicitly] public string Name { get; private set; } + } + + [AttributeUsage(AttributeTargets.Parameter | AttributeTargets.Field | AttributeTargets.Property, Inherited = true)] + public sealed class HtmlAttributeValueAttribute : Attribute + { + public HtmlAttributeValueAttribute([NotNull] string name) + { + Name = name; + } + + [NotNull,UsedImplicitly] public string Name { get; private set; } + } + + // Razor attributes + + /// + /// Razor attribute. Indicates that a parameter or a method is a Razor section. + /// Use this attribute for custom wrappers similar to + /// + /// + [AttributeUsage(AttributeTargets.Parameter | AttributeTargets.Method, Inherited = true)] + public sealed class RazorSectionAttribute : Attribute { } + +} \ No newline at end of file diff --git a/projects/examples/WinRT/Subscriber/Properties/AssemblyInfo.cs b/projects/examples/WinRT/Subscriber/Properties/AssemblyInfo.cs new file mode 100644 index 0000000000..f3ed040cef --- /dev/null +++ b/projects/examples/WinRT/Subscriber/Properties/AssemblyInfo.cs @@ -0,0 +1,29 @@ +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("RabbitMQ.Client.Examples.WinRT.Subscriber")] +[assembly: AssemblyDescription("")] +[assembly: AssemblyConfiguration("")] +[assembly: AssemblyCompany("")] +[assembly: AssemblyProduct("RabbitMQ.Client.Examples.WinRT.Subscriber")] +[assembly: AssemblyCopyright("Copyright © 2014")] +[assembly: AssemblyTrademark("")] +[assembly: AssemblyCulture("")] + +// Version information for an assembly consists of the following four values: +// +// Major Version +// Minor Version +// Build Number +// Revision +// +// You can specify all the values or you can default the Build and Revision Numbers +// by using the '*' as shown below: +// [assembly: AssemblyVersion("1.0.*")] +[assembly: AssemblyVersion("1.0.0.0")] +[assembly: AssemblyFileVersion("1.0.0.0")] +[assembly: ComVisible(false)] \ No newline at end of file diff --git a/projects/examples/WinRT/Subscriber/RabbitMQ.Client.Examples.WinRT.Subscriber.csproj b/projects/examples/WinRT/Subscriber/RabbitMQ.Client.Examples.WinRT.Subscriber.csproj new file mode 100644 index 0000000000..4cf0a043b6 --- /dev/null +++ b/projects/examples/WinRT/Subscriber/RabbitMQ.Client.Examples.WinRT.Subscriber.csproj @@ -0,0 +1,174 @@ + + + + + + Debug + AnyCPU + {6F01C132-7938-4001-8B70-D84EBAA662CC} + AppContainerExe + Properties + RabbitMQ.Client.Examples.WinRT.Subscriber + RabbitMQ.Client.Examples.WinRT.Subscriber + en-US + 512 + {BC8A1FFA-BEE3-4634-8014-F334798102B3};{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC} + RabbitMQ.Client.Examples.WinRT.Subscriber_TemporaryKey.pfx + A7016A18C09D6BCA14BF3B004B80BAD680FEE679 + + + AnyCPU + true + full + false + build\bin\Debug\ + DEBUG;TRACE;NETFX_CORE + prompt + 4 + + + AnyCPU + pdbonly + true + build\bin\Release\ + TRACE;NETFX_CORE + prompt + 4 + + + true + build\bin\ARM\Debug\ + DEBUG;TRACE;NETFX_CORE + ;2008 + full + ARM + false + prompt + true + + + build\bin\ARM\Release\ + TRACE;NETFX_CORE + true + ;2008 + pdbonly + ARM + false + prompt + true + + + true + build\bin\x64\Debug\ + DEBUG;TRACE;NETFX_CORE + ;2008 + full + x64 + false + prompt + true + + + build\bin\x64\Release\ + TRACE;NETFX_CORE + true + ;2008 + pdbonly + x64 + false + prompt + true + + + true + build\bin\x86\Debug\ + DEBUG;TRACE;NETFX_CORE + ;2008 + full + x86 + false + prompt + true + + + build\bin\x86\Release\ + TRACE;NETFX_CORE + true + ;2008 + pdbonly + x86 + false + prompt + true + + + + + {61d29f90-5b1c-4748-89fc-9fd2937f09c6} + RabbitMQ.Client.WinRT + + + + + App.xaml + + + MainPage.xaml + + + + + + + + + Designer + + + + + + + + + + + + + MSBuild:Compile + Designer + + + MSBuild:Compile + Designer + + + MSBuild:Compile + Designer + + + + 11.0 + + + + + + + + + + <_DisabledWarnings>$(NoWarn) + + + + + + + + + + + + + diff --git a/projects/examples/WinRT/Subscriber/RabbitMQ.Client.Examples.WinRT.Subscriber_TemporaryKey.pfx b/projects/examples/WinRT/Subscriber/RabbitMQ.Client.Examples.WinRT.Subscriber_TemporaryKey.pfx new file mode 100644 index 0000000000..39e0ca600d Binary files /dev/null and b/projects/examples/WinRT/Subscriber/RabbitMQ.Client.Examples.WinRT.Subscriber_TemporaryKey.pfx differ diff --git a/projects/examples/WinRT/Subscriber/StorageFileEventListener.cs b/projects/examples/WinRT/Subscriber/StorageFileEventListener.cs new file mode 100644 index 0000000000..300d10bb01 --- /dev/null +++ b/projects/examples/WinRT/Subscriber/StorageFileEventListener.cs @@ -0,0 +1,12 @@ +using System.Diagnostics.Tracing; + +namespace RabbitMQ.Client.Examples.WinRT.Subscriber +{ + public class StorageFileEventListener : EventListener + { + protected override void OnEventWritten(EventWrittenEventArgs eventData) + { + throw new System.NotImplementedException(); + } + } +} \ No newline at end of file