From 390654a8854799eb453d02b56220f580d8facd8f Mon Sep 17 00:00:00 2001 From: Christian Arenas Date: Wed, 24 May 2017 16:26:56 +0200 Subject: [PATCH] Remove old ServiceBusConnection declaration --- .../DefaultServiceBusPersisterConnection.cs | 16 ++++++---------- 1 file changed, 6 insertions(+), 10 deletions(-) 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;