diff --git a/src/BuildingBlocks/EventBus/EventBusServiceBus/DefaultServiceBusPersisterConnection.cs b/src/BuildingBlocks/EventBus/EventBusServiceBus/DefaultServiceBusPersisterConnection.cs index 3b9d9bda4..c85c1ecfe 100644 --- a/src/BuildingBlocks/EventBus/EventBusServiceBus/DefaultServiceBusPersisterConnection.cs +++ b/src/BuildingBlocks/EventBus/EventBusServiceBus/DefaultServiceBusPersisterConnection.cs @@ -5,35 +5,31 @@ using System.IO; namespace Microsoft.eShopOnContainers.BuildingBlocks.EventBusServiceBus { - public class DefaultServiceBusPersisterConnection : ServiceBusConnection, IServiceBusPersisterConnection + public class DefaultServiceBusPersisterConnection :IServiceBusPersisterConnection { - private readonly ILogger _logger; + private readonly ILogger _logger; private readonly ServiceBusConnectionStringBuilder _serviceBusConnectionStringBuilder; private ITopicClient _topicClient; bool _disposed; - object sync_root = new object(); public DefaultServiceBusPersisterConnection(ServiceBusConnectionStringBuilder serviceBusConnectionStringBuilder, - TimeSpan operationTimeout, RetryPolicy retryPolicy, ILogger logger) - : base(operationTimeout, retryPolicy) + TimeSpan operationTimeout, RetryPolicy retryPolicy, ILogger logger) { _logger = logger ?? throw new ArgumentNullException(nameof(logger)); - - InitializeConnection(serviceBusConnectionStringBuilder); + _serviceBusConnectionStringBuilder = serviceBusConnectionStringBuilder ?? throw new ArgumentNullException(nameof(serviceBusConnectionStringBuilder)); + _topicClient = new TopicClient(_serviceBusConnectionStringBuilder, RetryPolicy.Default); } - public bool IsConnected => _topicClient.IsClosedOrClosing; - public ServiceBusConnectionStringBuilder ServiceBusConnectionStringBuilder => _serviceBusConnectionStringBuilder; public ITopicClient CreateModel() { if(_topicClient.IsClosedOrClosing) { - _topicClient = new TopicClient(_serviceBusConnectionStringBuilder, RetryPolicy); + _topicClient = new TopicClient(_serviceBusConnectionStringBuilder, RetryPolicy.Default); } return _topicClient;