Skip to content

Commit

Permalink
Code cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
yang-xiaodong committed Aug 26, 2023
1 parent ec4817b commit ff76dea
Show file tree
Hide file tree
Showing 127 changed files with 6,099 additions and 6,388 deletions.
428 changes: 205 additions & 223 deletions src/DotNetCore.CAP.AmazonSQS/AmazonPolicyExtensions.cs

Large diffs are not rendered by default.

382 changes: 182 additions & 200 deletions src/DotNetCore.CAP.AmazonSQS/AmazonSQSConsumerClient.cs

Large diffs are not rendered by default.

32 changes: 16 additions & 16 deletions src/DotNetCore.CAP.AmazonSQS/AmazonSQSConsumerClientFactory.cs
Original file line number Diff line number Diff line change
@@ -1,31 +1,31 @@
// Copyright (c) .NET Core Community. All rights reserved.
// Licensed under the MIT License. See License.txt in the project root for license information.

using System;
using DotNetCore.CAP.Transport;
using Microsoft.Extensions.Options;

namespace DotNetCore.CAP.AmazonSQS
namespace DotNetCore.CAP.AmazonSQS;

internal sealed class AmazonSQSConsumerClientFactory : IConsumerClientFactory
{
internal sealed class AmazonSQSConsumerClientFactory : IConsumerClientFactory
private readonly IOptions<AmazonSQSOptions> _amazonSQSOptions;

public AmazonSQSConsumerClientFactory(IOptions<AmazonSQSOptions> amazonSQSOptions)
{
private readonly IOptions<AmazonSQSOptions> _amazonSQSOptions;
_amazonSQSOptions = amazonSQSOptions;
}

public AmazonSQSConsumerClientFactory(IOptions<AmazonSQSOptions> amazonSQSOptions)
public IConsumerClient Create(string groupId)
{
try
{
_amazonSQSOptions = amazonSQSOptions;
var client = new AmazonSQSConsumerClient(groupId, _amazonSQSOptions);
return client;
}

public IConsumerClient Create(string groupId)
catch (Exception e)
{
try
{
var client = new AmazonSQSConsumerClient(groupId, _amazonSQSOptions);
return client;
}
catch (System.Exception e)
{
throw new BrokerConnectionException(e);
}
throw new BrokerConnectionException(e);
}
}
}
30 changes: 14 additions & 16 deletions src/DotNetCore.CAP.AmazonSQS/CAP.AmazonSQSOptions.cs
Original file line number Diff line number Diff line change
Expand Up @@ -5,24 +5,22 @@
using Amazon.Runtime;

// ReSharper disable once CheckNamespace
namespace DotNetCore.CAP
{
// ReSharper disable once InconsistentNaming
public class AmazonSQSOptions
{
public RegionEndpoint Region { get; set; } = default!;
namespace DotNetCore.CAP;

public AWSCredentials? Credentials { get; set; }
// ReSharper disable once InconsistentNaming
public class AmazonSQSOptions
{
public RegionEndpoint Region { get; set; } = default!;

/// <summary>
/// Overrides Service Url deduced from AWS Region. To use in local development environments like localstack.
/// </summary>
public string? SNSServiceUrl { get; set; }
public AWSCredentials? Credentials { get; set; }

/// <summary>
/// Overrides Service Url deduced from AWS Region. To use in local development environments like localstack.
/// </summary>
public string? SQSServiceUrl { get; set; }
/// <summary>
/// Overrides Service Url deduced from AWS Region. To use in local development environments like localstack.
/// </summary>
public string? SNSServiceUrl { get; set; }

}
/// <summary>
/// Overrides Service Url deduced from AWS Region. To use in local development environments like localstack.
/// </summary>
public string? SQSServiceUrl { get; set; }
}
29 changes: 14 additions & 15 deletions src/DotNetCore.CAP.AmazonSQS/CAP.AmazonSQSOptionsExtension.cs
Original file line number Diff line number Diff line change
Expand Up @@ -7,24 +7,23 @@
using Microsoft.Extensions.DependencyInjection;

// ReSharper disable once CheckNamespace
namespace DotNetCore.CAP
namespace DotNetCore.CAP;

internal sealed class AmazonSQSOptionsExtension : ICapOptionsExtension
{
internal sealed class AmazonSQSOptionsExtension : ICapOptionsExtension
private readonly Action<AmazonSQSOptions> _configure;

public AmazonSQSOptionsExtension(Action<AmazonSQSOptions> configure)
{
private readonly Action<AmazonSQSOptions> _configure;
_configure = configure;
}

public AmazonSQSOptionsExtension(Action<AmazonSQSOptions> configure)
{
_configure = configure;
}
public void AddServices(IServiceCollection services)
{
services.AddSingleton(new CapMessageQueueMakerService("Amazon SQS"));

public void AddServices(IServiceCollection services)
{
services.AddSingleton(new CapMessageQueueMakerService("Amazon SQS"));

services.Configure(_configure);
services.AddSingleton<ITransport, AmazonSQSTransport>();
services.AddSingleton<IConsumerClientFactory, AmazonSQSConsumerClientFactory>();
}
services.Configure(_configure);
services.AddSingleton<ITransport, AmazonSQSTransport>();
services.AddSingleton<IConsumerClientFactory, AmazonSQSConsumerClientFactory>();
}
}
26 changes: 11 additions & 15 deletions src/DotNetCore.CAP.AmazonSQS/CAP.Options.Extensions.cs
Original file line number Diff line number Diff line change
Expand Up @@ -6,25 +6,21 @@
using DotNetCore.CAP;

// ReSharper disable once CheckNamespace
namespace Microsoft.Extensions.DependencyInjection
namespace Microsoft.Extensions.DependencyInjection;

public static class CapOptionsExtensions
{
public static class CapOptionsExtensions
public static CapOptions UseAmazonSQS(this CapOptions options, RegionEndpoint region)
{
public static CapOptions UseAmazonSQS(this CapOptions options, RegionEndpoint region)
{
return options.UseAmazonSQS(opt => { opt.Region = region; });
}
return options.UseAmazonSQS(opt => { opt.Region = region; });
}

public static CapOptions UseAmazonSQS(this CapOptions options, Action<AmazonSQSOptions> configure)
{
if (configure == null)
{
throw new ArgumentNullException(nameof(configure));
}
public static CapOptions UseAmazonSQS(this CapOptions options, Action<AmazonSQSOptions> configure)
{
if (configure == null) throw new ArgumentNullException(nameof(configure));

options.RegisterExtension(new AmazonSQSOptionsExtension(configure));
options.RegisterExtension(new AmazonSQSOptionsExtension(configure));

return options;
}
return options;
}
}
Loading

0 comments on commit ff76dea

Please sign in to comment.