Changeset 4728
- Timestamp:
- 06/18/08 23:23:04 (6 months ago)
- Files:
-
- trunk/nuxleus/Source/CodeSamples/AwsSdbSOAP_Test/AwsSdbSOAP_Test.csproj (modified) (1 diff)
- trunk/nuxleus/Source/CodeSamples/AwsSdbSOAP_Test/Handler/ExceptionHandler.cs (modified) (1 diff)
- trunk/nuxleus/Source/CodeSamples/AwsSdbSOAP_Test/LoadBalancer/WorkerQueue.cs (modified) (1 diff)
- trunk/nuxleus/Source/CodeSamples/AwsSdbSOAP_Test/Program.cs (modified) (1 diff)
- trunk/nuxleus/Source/CodeSamples/HttpGetAsyncResponse_Test/HttpGetAsyncResponse_Test.csproj (modified) (2 diffs)
- trunk/nuxleus/Source/CodeSamples/HttpGetAsyncResponse_Test/Program.cs (modified) (1 diff)
- trunk/nuxleus/Source/CodeSamples/HttpGetRequestAsyncWorkflow_Test/HttpGetRequestAsyncWorkflow_Test.csproj (modified) (1 diff)
- trunk/nuxleus/Source/CodeSamples/HttpGetRequestAsyncWorkflow_Test/Program.cs (modified) (1 diff)
- trunk/nuxleus/Source/Nuxleus.Asynchronous (added)
- trunk/nuxleus/Source/Nuxleus.Asynchronous/Async.cs (added)
- trunk/nuxleus/Source/Nuxleus.Asynchronous/Extf.Net.snk (added)
- trunk/nuxleus/Source/Nuxleus.Asynchronous/Nuxleus.Asynchronous.csproj (added)
- trunk/nuxleus/Source/Nuxleus.Asynchronous/Properties (added)
- trunk/nuxleus/Source/Nuxleus.Asynchronous/Properties/AssemblyInfo.cs (added)
- trunk/nuxleus/Source/Nuxleus.Extension.Aws/Agent.cs (modified) (3 diffs)
- trunk/nuxleus/Source/Nuxleus.Extension.Aws/Handler/ExceptionHandler.cs (modified) (1 diff)
- trunk/nuxleus/Source/Nuxleus.Extension.Aws/HttpQueryConnection.cs (added)
- trunk/nuxleus/Source/Nuxleus.Extension.Aws/IAwsConnection.cs (added)
- trunk/nuxleus/Source/Nuxleus.Extension.Aws/LoadBalancer/WorkerQueue.cs (modified) (1 diff)
- trunk/nuxleus/Source/Nuxleus.Extension.Aws/Nuxleus.Extension.Aws.csproj (modified) (7 diffs)
- trunk/nuxleus/Source/Nuxleus.Extension.Aws/Response/CreateDomainResponse.cs (added)
- trunk/nuxleus/Source/Nuxleus.Extension.Aws/Response/DeleteDomainResponse.cs (added)
- trunk/nuxleus/Source/Nuxleus.Extension.Aws/Response/GetAttributesResponse.cs (added)
- trunk/nuxleus/Source/Nuxleus.Extension.Aws/Response/IResponse.cs (modified) (1 diff)
- trunk/nuxleus/Source/Nuxleus.Extension.Aws/Response/ListDomainsResponse.cs (added)
- trunk/nuxleus/Source/Nuxleus.Extension.Aws/Response/PutAttributesResponse.cs (added)
- trunk/nuxleus/Source/Nuxleus.Extension.Aws/Response/QueryResponse.cs (added)
- trunk/nuxleus/Source/Nuxleus.Extension.Aws/SimpleDB/Operation/Operation.cs (modified) (1 diff)
- trunk/nuxleus/Source/Nuxleus.Extension.Aws/SimpleDB/SdbAction.cs (deleted)
- trunk/nuxleus/Source/Nuxleus.Extension.Aws/SimpleDB/SimpleDBService.cs (modified) (5 diffs)
- trunk/nuxleus/Source/Nuxleus.Extension.Aws/SimpleDB/Task/CreateDomain.cs (modified) (3 diffs)
- trunk/nuxleus/Source/Nuxleus.Extension.Aws/SimpleDB/Task/DeleteDomain.cs (modified) (1 diff)
- trunk/nuxleus/Source/Nuxleus.Extension.Aws/SimpleDB/Task/GetAttributes.cs (modified) (3 diffs)
- trunk/nuxleus/Source/Nuxleus.Extension.Aws/SimpleDB/Task/ITask.cs (modified) (2 diffs)
- trunk/nuxleus/Source/Nuxleus.Extension.Aws/SimpleDB/Task/ListDomains.cs (modified) (1 diff)
- trunk/nuxleus/Source/Nuxleus.Extension.Aws/SimpleDB/Task/PutAttributes.cs (modified) (4 diffs)
- trunk/nuxleus/Source/Nuxleus.Extension.Aws/SimpleDB/Task/Query.cs (modified) (5 diffs)
- trunk/nuxleus/Source/Nuxleus.Extension.Aws/log4net.config (added)
- trunk/nuxleus/Source/Nuxleus.Web/Agent.cs (modified) (1 diff)
- trunk/nuxleus/Source/Nuxleus.Web/HttpHandler/NuxleusHttpAsyncXmlServiceOperationHandler.cs (modified) (1 diff)
- trunk/nuxleus/Source/nuXleus.sln (modified) (2 diffs)
- trunk/nuxleus/Source/nux.build (modified) (56 diffs)
Legend:
- Unmodified
- Added
- Removed
- Modified
- Copied
- Moved
trunk/nuxleus/Source/CodeSamples/AwsSdbSOAP_Test/AwsSdbSOAP_Test.csproj
r4715 r4728 66 66 <Name>Scope</Name> 67 67 </ProjectReference> 68 <ProjectReference Include="..\..\Nuxleus.Asynchronous\Nuxleus.Asynchronous.csproj"> 69 <Project>{EDD96E5A-5BEE-4A0C-89AA-A6C9CE68C710}</Project> 70 <Name>Nuxleus.Asynchronous</Name> 71 </ProjectReference> 68 72 <ProjectReference Include="..\..\Nuxleus.Extension.Aws\Nuxleus.Extension.Aws.csproj"> 69 73 <Project>{058E925F-6FD0-4FAF-AA97-22D48D62923E}</Project> 70 74 <Name>Nuxleus.Extension.Aws</Name> 71 </ProjectReference>72 <ProjectReference Include="..\..\Nuxleus.Extension.Linq\Nuxleus.Extension.Linq.csproj">73 <Project>{D937BA9E-1E6C-4757-98CC-7D932F4697B0}</Project>74 <Name>Nuxleus.Extension.Linq</Name>75 75 </ProjectReference> 76 76 </ItemGroup> trunk/nuxleus/Source/CodeSamples/AwsSdbSOAP_Test/Handler/ExceptionHandler.cs
r4697 r4728 5 5 using VVMF.SOA.Common; 6 6 using System.Net; 7 using EeekSoft.Asynchronous;7 using Nuxleus.Asynchronous; 8 8 using System.IO; 9 9 using System.Xml.Linq; trunk/nuxleus/Source/CodeSamples/AwsSdbSOAP_Test/LoadBalancer/WorkerQueue.cs
r4700 r4728 2 2 using System.Threading; 3 3 using System.Collections.Generic; 4 using EeekSoft.Asynchronous;4 using Nuxleus.Asynchronous; 5 5 6 6 namespace AwsSdbSOAP_Test { trunk/nuxleus/Source/CodeSamples/AwsSdbSOAP_Test/Program.cs
r4724 r4728 17 17 static void Main(string[] args) { 18 18 19 Agent agent = new Agent();19 Agent<Program> agent = new Agent<Program>(); 20 20 21 21 System.Environment.SetEnvironmentVariable("AWS_PUBLIC_KEY", ConfigurationManager.AppSettings["AWS_PUBLIC_KEY"]); trunk/nuxleus/Source/CodeSamples/HttpGetAsyncResponse_Test/HttpGetAsyncResponse_Test.csproj
r4649 r4728 4 4 <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration> 5 5 <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform> 6 <ProductVersion>9.0. 20706</ProductVersion>6 <ProductVersion>9.0.30428</ProductVersion> 7 7 <SchemaVersion>2.0</SchemaVersion> 8 8 <ProjectGuid>{A128AED6-F1C8-4D86-A22B-97EB0D892C70}</ProjectGuid> … … 54 54 <Name>Nuxleus.Agent</Name> 55 55 </ProjectReference> 56 <ProjectReference Include="..\..\Nuxleus. Extension.Linq\Nuxleus.Extension.Linq.csproj">57 <Project>{ D937BA9E-1E6C-4757-98CC-7D932F4697B0}</Project>58 <Name>Nuxleus. Extension.Linq</Name>56 <ProjectReference Include="..\..\Nuxleus.Asynchronous\Nuxleus.Asynchronous.csproj"> 57 <Project>{EDD96E5A-5BEE-4A0C-89AA-A6C9CE68C710}</Project> 58 <Name>Nuxleus.Asynchronous</Name> 59 59 </ProjectReference> 60 60 <ProjectReference Include="..\..\Nuxleus.Web\Nuxleus.Web.csproj"> trunk/nuxleus/Source/CodeSamples/HttpGetAsyncResponse_Test/Program.cs
r4579 r4728 7 7 using System.Threading; 8 8 using System.Diagnostics; 9 using EeekSoft.Asynchronous;9 using Nuxleus.Asynchronous; 10 10 using System.Collections; 11 11 trunk/nuxleus/Source/CodeSamples/HttpGetRequestAsyncWorkflow_Test/HttpGetRequestAsyncWorkflow_Test.csproj
r4689 r4728 56 56 <Name>Nuxleus.Agent</Name> 57 57 </ProjectReference> 58 <ProjectReference Include="..\..\Nuxleus. Extension.Linq\Nuxleus.Extension.Linq.csproj">59 <Project>{ D937BA9E-1E6C-4757-98CC-7D932F4697B0}</Project>60 <Name>Nuxleus. Extension.Linq</Name>58 <ProjectReference Include="..\..\Nuxleus.Asynchronous\Nuxleus.Asynchronous.csproj"> 59 <Project>{EDD96E5A-5BEE-4A0C-89AA-A6C9CE68C710}</Project> 60 <Name>Nuxleus.Asynchronous</Name> 61 61 </ProjectReference> 62 62 </ItemGroup> trunk/nuxleus/Source/CodeSamples/HttpGetRequestAsyncWorkflow_Test/Program.cs
r4689 r4728 6 6 using System.Threading; 7 7 using System.Diagnostics; 8 using EeekSoft.Asynchronous;8 using Nuxleus.Asynchronous; 9 9 using System.Net; 10 10 using System.Text.RegularExpressions; trunk/nuxleus/Source/Nuxleus.Extension.Aws/Agent.cs
r4723 r4728 3 3 using Nuxleus.Extension.AWS.SimpleDB; 4 4 using VVMF.SOA.Common; 5 using EeekSoft.Asynchronous;5 using Nuxleus.Asynchronous; 6 6 using System.Net; 7 7 using System.Configuration; … … 12 12 using Nuxleus.Extension.AWS.SimpleDB.Model; 13 13 using System.Xml.Linq; 14 using Nuxleus.Extension; 15 using log4net; 16 using log4net.Config; 14 17 15 18 namespace Nuxleus.Extension.Aws { 16 19 17 public struct Agent { 20 public struct Agent<T> { 21 22 static readonly ILog m_loggerInstance = LogManager.GetLogger(typeof(T)); 18 23 19 24 static LoggerScope logger = new LoggerScope(); … … 21 26 static ProfilerScope profiler = new ProfilerScope(); 22 27 static int m_workers = (int.Parse(ConfigurationManager.AppSettings["WorkerQueueMultiplier"]) * System.Environment.ProcessorCount); 28 29 public static ILog GetBasicLogger() { 30 XmlConfigurator.Configure(new System.IO.FileInfo(("log4net.config"))); 31 return m_loggerInstance; 32 } 23 33 24 34 public void Initialize() { trunk/nuxleus/Source/Nuxleus.Extension.Aws/Handler/ExceptionHandler.cs
r4717 r4728 5 5 using VVMF.SOA.Common; 6 6 using System.Net; 7 using EeekSoft.Asynchronous;7 using Nuxleus.Asynchronous; 8 8 using System.IO; 9 9 using System.Xml.Linq; trunk/nuxleus/Source/Nuxleus.Extension.Aws/LoadBalancer/WorkerQueue.cs
r4723 r4728 2 2 using System.Threading; 3 3 using System.Collections.Generic; 4 using EeekSoft.Asynchronous;4 using Nuxleus.Asynchronous; 5 5 6 6 namespace Nuxleus.Extension.AWS.SimpleDB { trunk/nuxleus/Source/Nuxleus.Extension.Aws/Nuxleus.Extension.Aws.csproj
r4727 r4728 35 35 </PropertyGroup> 36 36 <ItemGroup> 37 <Reference Include="log4net, Version=1.2.10.0, Culture=neutral, PublicKeyToken=1b44e1d426115821, processorArchitecture=MSIL"> 38 <SpecificVersion>False</SpecificVersion> 39 <HintPath>..\Dependencies\log4net.dll</HintPath> 40 </Reference> 37 41 <Reference Include="System" /> 38 42 <Reference Include="System.configuration" /> … … 60 64 <ItemGroup> 61 65 <Compile Include="Agent.cs" /> 62 <Compile Include="AwsConnection\HttpQueryConnection.cs" />63 <Compile Include="AwsConnection\IAwsConnection.cs" />64 66 <Compile Include="Handler\ExceptionHandler.cs" /> 67 <Compile Include="HttpQueryConnection.cs" /> 68 <Compile Include="IAwsConnection.cs" /> 65 69 <Compile Include="LoadBalancer\WorkerQueue.cs" /> 66 70 <Compile Include="Properties\AssemblyInfo.cs" /> … … 77 81 <Compile Include="Request\IRequest.cs" /> 78 82 <Compile Include="Request\PutAttributesRequest.cs" /> 83 <Compile Include="Response\CreateDomainResponse.cs" /> 84 <Compile Include="Response\DeleteDomainResponse.cs" /> 85 <Compile Include="Response\QueryResponse.cs" /> 86 <Compile Include="Response\ListDomainsResponse.cs" /> 87 <Compile Include="Response\GetAttributesResponse.cs" /> 79 88 <Compile Include="Response\IResponse.cs" /> 89 <Compile Include="Response\PutAttributesResponse.cs" /> 80 90 <Compile Include="Scope\LoggerScope.cs" /> 81 91 <Compile Include="Scope\ProfilerScope.cs" /> … … 84 94 <Compile Include="SimpleDB\Model\Item.cs" /> 85 95 <Compile Include="SimpleDB\Operation\Operation.cs" /> 86 <Compile Include="SimpleDB\SdbAction.cs" />87 96 <Compile Include="SimpleDB\SimpleDBService.cs" /> 88 97 <Compile Include="SimpleDB\Task\CreateDomain.cs" /> … … 93 102 <Compile Include="SimpleDB\Task\PutAttributes.cs" /> 94 103 <Compile Include="SimpleDB\Task\Query.cs" /> 95 <Compile Include="SimpleDB\Task\Task.cs" />96 <Compile Include="Utils\HMACSigner.cs" />97 104 </ItemGroup> 98 105 <ItemGroup> 99 106 <None Include="Extf.Net.snk" /> 107 <None Include="log4net.config"> 108 <CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory> 109 </None> 100 110 <None Include="Properties\Settings.settings"> 101 111 <Generator>SettingsSingleFileGenerator</Generator> … … 118 128 <Name>Nuxleus.Agent</Name> 119 129 </ProjectReference> 130 <ProjectReference Include="..\Nuxleus.Asynchronous\Nuxleus.Asynchronous.csproj"> 131 <Project>{EDD96E5A-5BEE-4A0C-89AA-A6C9CE68C710}</Project> 132 <Name>Nuxleus.Asynchronous</Name> 133 </ProjectReference> 120 134 <ProjectReference Include="..\Nuxleus.Extension.Linq\Nuxleus.Extension.Linq.csproj"> 121 135 <Project>{D937BA9E-1E6C-4757-98CC-7D932F4697B0}</Project> … … 131 145 </ProjectReference> 132 146 </ItemGroup> 147 <ItemGroup> 148 <Folder Include="Utils\" /> 149 </ItemGroup> 133 150 <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" /> 134 151 <!-- To modify your build process, add your task inside one of the targets below and uncomment it. trunk/nuxleus/Source/Nuxleus.Extension.Aws/Response/IResponse.cs
r4727 r4728 8 8 public interface IResponse { 9 9 KeyValuePair<string,string>[] Headers { get; set;} 10 String Response { get; set;}10 String Response { get; } 11 11 } 12 12 } trunk/nuxleus/Source/Nuxleus.Extension.Aws/SimpleDB/Operation/Operation.cs
r4715 r4728 3 3 using System.Linq; 4 4 using System.Text; 5 using EeekSoft.Asynchronous;5 using Nuxleus.Asynchronous; 6 6 using VVMF.SOA.Common; 7 7 trunk/nuxleus/Source/Nuxleus.Extension.Aws/SimpleDB/SimpleDBService.cs
r4727 r4728 11 11 using System.Globalization; 12 12 using Nuxleus.Extension; 13 using EeekSoft.Asynchronous;13 using Nuxleus.Asynchronous; 14 14 using System.Collections.Generic; 15 15 using System.Threading; … … 17 17 using System.Collections; 18 18 using System.Xml.Serialization; 19 using Nuxleus.Extension.Aws; 20 using log4net; 19 21 20 22 namespace Nuxleus.Extension.AWS.SimpleDB { … … 45 47 static XNamespace i = "http://www.w3.org/2001/XMLSchema-instance"; 46 48 static XmlSerializer m_xSerializer = new XmlSerializer(typeof(TRequestType)); 49 static ILog m_logger = Agent<SimpleDBService<TRequestType>>.GetBasicLogger(); 47 50 48 51 public static IEnumerable<IAsync> CallWebService<TResultType>(ITask task, IRequest sdbRequest, Dictionary<IRequest, TResultType> responseList) { … … 64 67 } 65 68 69 Console.WriteLine("TaskID: {0}", task.TaskID); 70 66 71 string soapMessage = output.ToString(); 67 72 sdbRequest.RequestMessage = soapMessage; 68 //Console.WriteLine("XML: {0}", soapMessage);73 m_logger.DebugFormat("SOAP message for task {0}: {1}", task.TaskID, soapMessage); 69 74 70 75 byte[] buffer = encoding.GetBytes(soapMessage); … … 79 84 } 80 85 81 //System.Console.WriteLine("Start Request: Thread is background: {0}, Thread ID: {1}, Thread is managed: {2}", Thread.CurrentThread.IsBackground, Thread.CurrentThread.ManagedThreadId, Thread.CurrentThread.IsThreadPoolThread);86 m_logger.DebugFormat("Start Request: Thread is background: {0}, Thread ID: {1}, Thread is managed: {2}", Thread.CurrentThread.IsBackground, Thread.CurrentThread.ManagedThreadId, Thread.CurrentThread.IsThreadPoolThread); 82 87 83 88 using (Stream newStream = request.GetRequestStream()) { 84 89 newStream.Write(buffer, 0, contentLength); 90 m_logger.DebugFormat("Sending request for task {0} on thread: {1}", task.TaskID, Thread.CurrentThread.ManagedThreadId); 85 91 Async<WebResponse> response = request.GetResponseAsync(); 86 92 yield return response; 87 //System.Console.WriteLine("[] got response on thread: {0}", Thread.CurrentThread.ManagedThreadId);93 m_logger.DebugFormat("Received response for task {0} on thread: {1}", task.TaskID, Thread.CurrentThread.ManagedThreadId); 88 94 Stream stream = response.Result.GetResponseStream(); 89 95 Async<TResultType> responseObject = stream.ReadToEndAsync<TResultType>().ExecuteAsync<TResultType>(); trunk/nuxleus/Source/Nuxleus.Extension.Aws/SimpleDB/Task/CreateDomain.cs
r4727 r4728 2 2 using System.Collections.Generic; 3 3 using System.Xml.Serialization; 4 using EeekSoft.Asynchronous; 5 using Nuxleus.Extension.AWS.SimpleDB.Model; 4 using Nuxleus.Asynchronous; 6 5 7 6 namespace Nuxleus.Extension.AWS.SimpleDB { … … 12 11 13 12 string m_domainName; 14 List<String> m_attributeNameArray;15 static Guid m_taskID = new Guid();16 static IRequest m_request = new GetAttributesRequest();13 Guid m_taskID; 14 IRequest m_request; 15 IResponse m_response; 17 16 18 17 [XmlElementAttribute(ElementName = "DomainName")] 19 18 public string DomainName { 20 get { return m_domainName; } 19 get { 20 return m_domainName; } 21 21 set { m_domainName = value; } 22 22 } … … 32 32 } 33 33 34 public IResponse Response { get; set; } 34 public IResponse Response { 35 get { 36 return m_response; 37 } 38 } 35 39 36 40 public IEnumerable<IAsync> Invoke<T>(Dictionary<IRequest, T> responseList) { 41 Init(); 37 42 return SimpleDBService<CreateDomain>.CallWebService<T>(this, Request, responseList); 43 } 44 45 void Init() { 46 m_request = new CreateDomainRequest(); 47 m_response = new CreateDomainResponse(); 48 m_taskID = System.Guid.NewGuid(); 38 49 } 39 50 } trunk/nuxleus/Source/Nuxleus.Extension.Aws/SimpleDB/Task/DeleteDomain.cs
r4715 r4728 1 1 using System; 2 2 using System.Collections.Generic; 3 using System.Linq; 4 using System.Text; 3 using System.Xml.Serialization; 4 using Nuxleus.Asynchronous; 5 using Nuxleus.Extension.AWS.SimpleDB.Model; 5 6 6 7 namespace Nuxleus.Extension.AWS.SimpleDB { 7 class DeleteDomain { 8 9 [XmlTypeAttribute(Namespace = "http://sdb.amazonaws.com/doc/2007-11-07/")] 10 [XmlRootAttribute(Namespace = "http://sdb.amazonaws.com/doc/2007-11-07/", IsNullable = false)] 11 public struct DeleteDomain : ITask { 12 13 string m_domainName; 14 List<String> m_attributeNameArray; 15 Guid m_taskID; 16 IRequest m_request; 17 IResponse m_response; 18 19 [XmlElementAttribute(ElementName = "DomainName")] 20 public string DomainName { 21 get { 22 return m_domainName; 23 } 24 set { m_domainName = value; } 25 } 26 27 public Guid TaskID { 28 get { return m_taskID; } 29 } 30 31 public IRequest Request { 32 get { 33 return m_request; 34 } 35 } 36 37 public IResponse Response { 38 get { 39 return m_response; 40 } 41 } 42 43 public IEnumerable<IAsync> Invoke<T>(Dictionary<IRequest, T> responseList) { 44 Init(); 45 return SimpleDBService<CreateDomain>.CallWebService<T>(this, Request, responseList); 46 } 47 48 void Init() { 49 m_request = new DeleteDomainRequest(); 50 m_response = new DeleteDomainResponse(); 51 m_taskID = System.Guid.NewGuid(); 52 } 8 53 } 9 54 } trunk/nuxleus/Source/Nuxleus.Extension.Aws/SimpleDB/Task/GetAttributes.cs
r4727 r4728 2 2 using System.Collections.Generic; 3 3 using System.Xml.Serialization; 4 using EeekSoft.Asynchronous;4 using Nuxleus.Asynchronous; 5 5 using Nuxleus.Extension.AWS.SimpleDB.Model; 6 6 … … 14 14 string m_itemName; 15 15 List<String> m_attributeNameArray; 16 static Guid m_taskID = new Guid(); 17 static IRequest m_request = new GetAttributesRequest(); 16 Guid m_taskID; 17 IRequest m_request; 18 IResponse m_response; 18 19 19 20 [XmlElementAttribute(ElementName = "DomainName")] 20 21 public string DomainName { 21 get { return m_domainName; } 22 get { 23 return m_domainName; 24 } 22 25 set { m_domainName = value; } 23 26 } … … 45 48 } 46 49 47 public IResponse Response { get; set; } 50 public IResponse Response { 51 get { 52 return m_response; 53 } 54 } 48 55 49 56 public IEnumerable<IAsync> Invoke<T>(Dictionary<IRequest, T> responseList) { 57 Init(); 50 58 return SimpleDBService<GetAttributes>.CallWebService<T>(this, Request, responseList); 59 } 60 61 void Init() { 62 m_request = new GetAttributesRequest(); 63 m_response = new GetAttributesResponse(); 64 m_taskID = System.Guid.NewGuid(); 51 65 } 52 66 } trunk/nuxleus/Source/Nuxleus.Extension.Aws/SimpleDB/Task/ITask.cs
r4727 r4728 4 4 using System.Text; 5 5 using System.Xml.Linq; 6 using EeekSoft.Asynchronous;6 using Nuxleus.Asynchronous; 7 7 8 8 namespace Nuxleus.Extension.AWS.SimpleDB { … … 10 10 Guid TaskID { get; } 11 11 IRequest Request { get; } 12 IResponse Response { get; set;}12 IResponse Response { get; } 13 13 IEnumerable<IAsync> Invoke<T>(Dictionary<IRequest, T> responseList); 14 14 } trunk/nuxleus/Source/Nuxleus.Extension.Aws/SimpleDB/Task/ListDomains.cs
r4715 r4728 1 1 using System; 2 2 using System.Collections.Generic; 3 using System. Linq;4 using System.Text;3 using System.Xml.Serialization; 4 using Nuxleus.Asynchronous; 5 5 6 6 namespace Nuxleus.Extension.AWS.SimpleDB { 7 class ListDomains { 7 8 [XmlTypeAttribute(Namespace = "http://sdb.amazonaws.com/doc/2007-11-07/")] 9 [XmlRootAttribute(Namespace = "http://sdb.amazonaws.com/doc/2007-11-07/", IsNullable = false)] 10 public struct ListDomains : ITask { 11 12 string m_maxNumberOfItems; 13 string m_nextToken; 14 Guid m_taskID; 15 IRequest m_request; 16 IResponse m_response; 17 18 [XmlElementAttribute(ElementName = "MaxNumberOfItems")] 19 public String MaxNumberOfItems { 20 get { 21 return m_maxNumberOfItems; 22 } 23 set { m_maxNumberOfItems = value; } 24 } 25 26 [XmlElementAttribute(ElementName = "NextToken")] 27 public String NextToken { 28 get { return m_nextToken; } 29 set { m_nextToken = value; } 30 } 31 32 33 #region ITask Members 34 35 public RequestType RequestType { 36 get { throw new NotImplementedException(); } 37 } 38 39 public IRequest Request { 40 get { throw new NotImplementedException(); } 41 set { throw new NotImplementedException(); } 42 } 43 44 public IResponse Response { 45 get { 46 return m_response; 47 } 48 } 49 50 public Guid TaskID { 51 get { return m_taskID; } 52 } 53 54 public IEnumerable<IAsync> Invoke<T>(Dictionary<IRequest, T> responseList) { 55 Init(); 56 throw new NotImplementedException(); 57 } 58 59 #endregion 60 61 void Init() { 62 m_request = new ListDomainsRequest(); 63 m_response = new ListDomainsResponse(); 64 m_taskID = System.Guid.NewGuid(); 65 } 8 66 } 9 67 } trunk/nuxleus/Source/Nuxleus.Extension.Aws/SimpleDB/Task/PutAttributes.cs
r4727 r4728 1 1 using System.Collections.Generic; 2 2 using System.Xml.Serialization; 3 using EeekSoft.Asynchronous;3 using Nuxleus.Asynchronous; 4 4 using Nuxleus.Extension.AWS.SimpleDB.Model; 5 5 … … 14 14 string m_itemName; 15 15 List<Attribute> m_attributeArray; 16 static System.Guid m_taskID = new System.Guid(); 17 static IRequest m_request = new PutAttributesRequest(); 16 System.Guid m_taskID; 17 IRequest m_request; 18 IResponse m_response; 18 19 19 20 [XmlElementAttribute(ElementName = "DomainName")] 20 21 public string DomainName { 21 22 get { return m_domainName; } 22 set { m_domainName = value; } 23 set { 24 m_domainName = value; 25 } 23 26 } 24 27 … … 36 39 37 40 public System.Guid TaskID { 38 get { return m_taskID; } 41 get { 42 return m_taskID; 43 } 39 44 } 40 45 … … 45 50 } 46 51 47 public IResponse Response { get; set; } 52 public IResponse Response { 53 get { 54 return m_response; 55 } 56 } 48 57 49 58 public IEnumerable<IAsync> Invoke<T>(Dictionary<IRequest, T> responseList) { 59 Init(); 50 60 return SimpleDBService<PutAttributes>.CallWebService<T>(this, Request, responseList); 61 } 62 63 void Init() { 64 m_request = new PutAttributesRequest(); 65 m_response = new PutAttributesResponse(); 66 m_taskID = System.Guid.NewGuid(); 51 67 } 52 68 } trunk/nuxleus/Source/Nuxleus.Extension.Aws/SimpleDB/Task/Query.cs
r4727 r4728 2 2 using System.Collections.Generic; 3 3 using System.Xml.Serialization; 4 using EeekSoft.Asynchronous;4 using Nuxleus.Asynchronous; 5 5 6 6 namespace Nuxleus.Extension.AWS.SimpleDB { … … 14 14 string m_maxNumberOfItems; 15 15 string m_nextToken; 16 static Guid m_taskID = new Guid(); 16 Guid m_taskID; 17 IRequest m_request; 18 IResponse m_response; 17 19 18 20 [XmlElementAttribute(ElementName = "DomainName")] 19 21 public String DomainName { 20 get { return m_domainName; } 22 get { 23 return m_domainName; 24 } 21 25 set { m_domainName = value; } 22 26 } … … 40 44 } 41 45 42 43 46 #region ITask Members 44 47 … … 52 55 } 53 56 54 public IResponse Response { get; set; } 57 public IResponse Response { 58 get { 59 return m_response; 60 } 61 } 55 62 56 63 public Guid TaskID { … … 59 66 60 67 public IEnumerable<IAsync> Invoke<T>(Dictionary<IRequest, T> responseList) { 68 Init(); 61 69 throw new NotImplementedException(); 70 } 71 72 void Init() { 73 m_request = new QueryRequest(); 74 m_response = new QueryResponse(); 75 m_taskID = System.Guid.NewGuid(); 62 76 } 63 77 trunk/nuxleus/Source/Nuxleus.Web/Agent.cs
r4674 r4728 9 9 namespace Nuxleus.Web { 10 10 11 public struct Agent : IAgent {11 public struct Agent<T> : IAgent { 12 12 13 static readonly ILog m_loggerInstance = LogManager.GetLogger(typeof( Agent));13 static readonly ILog m_loggerInstance = LogManager.GetLogger(typeof(T)); 14 14 15 15 public System.Collections.Hashtable Result { trunk/nuxleus/Source/Nuxleus.Web/HttpHandler/NuxleusHttpAsyncXmlServiceOperationHandler.cs
r4674 r4728 73 73 IAsyncResult m_asyncResult; 74 74 XmlReader initialReader; 75 static ILog m_logger = Web.Agent .GetBasicLogger();75 static ILog m_logger = Web.Agent<NuxleusHttpAsyncXmlServiceOperationHandler>.GetBasicLogger(); 76 76 77 77 public void ProcessRequest ( HttpContext context ) { trunk/nuxleus/Source/nuXleus.sln
r4709 r4728 135 135 EndProject 136 136 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "SaxonExtensionFunction_Test", "CodeSamples\SaxonExtensionFunction_Test\SaxonExtensionFunction_Test.csproj", "{A36FBFC7-9C35-42B3-BCEE-10BA7524204C}" 137 EndProject 138 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Nuxleus.Asynchronous", "Nuxleus.Asynchronous\Nuxleus.Asynchronous.csproj", "{EDD96E5A-5BEE-4A0C-89AA-A6C9CE68C710}" 137 139 EndProject 138 140 Global … … 1092 1094 {A36FBFC7-9C35-42B3-BCEE-10BA7524204C}.Release|x64.ActiveCfg = Release|Any CPU 1093 1095 {A36FBFC7-9C35-42B3-BCEE-10BA7524204C}.Release|x86.ActiveCfg = Release|Any CPU 1096 {EDD96E5A-5BEE-4A0C-89AA-A6C9CE68C710}.Debug|.NET.ActiveCfg = Debug|Any CPU 1097 {EDD96E5A-5BEE-4A0C-89AA-A6C9CE68C710}.Debug|Any CPU.ActiveCfg = Debug|Any CPU 1098 {EDD96E5A-5BEE-4A0C-89AA-A6C9CE68C710}.Debug|Any CPU.Build.0 = Debug|Any CPU 1099 {EDD96E5A-5BEE-4A0C-89AA-A6C9CE68C710}.Debug|Mixed Platforms.ActiveCfg = Debug|Any CPU 1100 {EDD96E5A-5BEE-4A0C-89AA-A6C9CE68C710}.Debug|Mixed Platforms.Build.0 = Debug|Any CPU 1101 {EDD96E5A-5BEE-4A0C-89AA-A6C9CE68C710}.Debug|x64.ActiveCfg = Debug|Any CPU 1102 {EDD96E5A-5BEE-4A0C-89AA-A6C9CE68C710}.Debug|x86.ActiveCfg = Debug|Any CPU 1103 {EDD96E5A-5BEE-4A0C-89AA-A6C9CE68C710}.Release|.NET.ActiveCfg = Release|Any CPU 1104 {EDD96E5A-5BEE-4A0C-89AA-A6C9CE68C710}.Release|Any CPU.ActiveCfg = Release|Any CPU 1105 {EDD96E5A-5BEE-4A0C-89AA-A6C9CE68C710}.Release|Any CPU.Build.0 = Release|Any CPU 1106 {EDD96E5A-5BEE-4A0C-89AA-A6C9CE68C710}.Release|Mixed Platforms.ActiveCfg = Release|Any CPU 1107 {EDD96E5A-5BEE-4A0C-89AA-A6C9CE68C710}.Release|Mixed Platforms.Build.0 = Release|Any CPU 1108 {EDD96E5A-5BEE-4A0C-89AA-A6C9CE68C710}.Release|x64.ActiveCfg = Release|Any CPU 1109 {EDD96E5A-5BEE-4A0C-89AA-A6C9CE68C710}.Release|x86.ActiveCfg = Release|Any CPU 1094 1110 EndGlobalSection 1095 1111 GlobalSection(SolutionProperties) = preSolution trunk/nuxleus/Source/nux.build
r4715 r4728 13 13 <target name="Xameleon" depends="init Nuxleus.Authentication Nuxleus.Agent Nuxleus.Command Nuxleus.Configuration Nuxleus.Cryptography Nuxleus.Extension.Facebook Nuxleus.Extension.Aws.Sdb Nuxleus.Extension.Aws Nuxleus.IO Nuxleus.Messaging Nuxleus.Process Nuxleus.PubSub Nuxleus.Utility"> 14 14 <csc target="library" output="${build.dir}/Xameleon.dll" unsafe="True" keyfile="./Dependencies/Extf.Net.snk"> 15 <arg if="${platform::is-unix()}" value="-langversion:linq"/>16 15 <sources> 17 16 <include name="${source.dir}/Xameleon/*.cs"/> … … 64 63 <target name="XSP" depends="init Nuxleus.Web"> 65 64 <csc target="exe" output="${build.dir}/xsp2.exe" keyfile="./Dependencies/Extf.Net.snk"> 66 <arg if="${platform::is-unix()}" value="-langversion:linq"/>67 65 <sources> 68 66 <include name="${source.dir}/XSP/**/*.cs"/> … … 79 77 <target name="Nuxleus" depends="init Xameleon Nuxleus.Agent Nuxleus.Messaging Nuxleus.Command Nuxleus.Entity Nuxleus.Service Nuxleus.Extension"> 80 78 <csc target="exe" output="${build.dir}/Nuxleus.exe" keyfile="./Dependencies/Extf.Net.snk"> 81 <arg if="${platform::is-unix()}" value="-langversion:linq"/>82 79 <sources> 83 80 <include name="${source.dir}/Nuxleus/**/*.cs"/> … … 104 101 <target name="Nuxleus.Agent" depends="init"> 105 102 <csc target="library" output="${build.dir}/Nuxleus.Agent.dll" keyfile="./Dependencies/Extf.Net.snk"> 106 <arg if="${platform::is-unix()}" value="-langversion:linq"/>107 103 <sources> 108 104 <include name="${source.dir}/Nuxleus.Agent/**/*.cs"/> … … 111 107 <include name="System.dll"/> 112 108 <include name="System.Web.dll"/> 109 </references> 110 </csc> 111 </target> 112 <target name="Nuxleus.Asynchronous" depends="init"> 113 <csc target="library" output="${build.dir}/Nuxleus.Asynchronous.dll" keyfile="./Dependencies/Extf.Net.snk"> 114 <sources> 115 <include name="${source.dir}/Nuxleus.Asynchronous/**/*.cs"/> 116 </sources> 117 <references> 118 <include name="System.dll"/> 119 <include name="System.Data.dll"/> 120 <include name="System.Linq.dll"/> 121 <include name="System.Xml.Linq.dll"/> 122 <include name="System.Xml.dll"/> 123 <include name="System.Web.dll"/> 124 <include name="System.Web.Services.dll"/> 125 <include name="System.EnterpriseServices.dll"/> 113 126 </references> 114 127 </csc> … … 116 129 <target name="Nuxleus.Authentication" depends="init Nuxleus.Utility"> 117 130 <csc target="library" output="${build.dir}/Nuxleus.Authentication.dll" keyfile="./Dependencies/Extf.Net.snk"> 118 <arg if="${platform::is-unix()}" value="-langversion:linq"/>119 131 <sources> 120 132 <include name="${source.dir}/Nuxleus.Authentication/**/*.cs"/> &
