Skip to content

Commit

Permalink
added sql server datbus storage
Browse files Browse the repository at this point in the history
  • Loading branch information
fw2568 committed Jan 10, 2023
1 parent 49e26a5 commit ecf32c7
Show file tree
Hide file tree
Showing 2 changed files with 33 additions and 0 deletions.
Original file line number Diff line number Diff line change
@@ -0,0 +1,8 @@
namespace Dbosoft.Rebus.Configuration;

public class SqlServerDataBusOptions
{
public string TableName { get; set; }

public bool AutomaticallyCreateTables { get; set; }
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,25 @@
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.Logging;
using Microsoft.Extensions.Options;
using Rebus.Config;
using Rebus.DataBus;

namespace Dbosoft.Rebus.Configuration;

public class SqlServerDataBusSelector : SqlServerSelectorBase<IDataBusStorage>
{
private readonly IOptions<SqlServerDataBusOptions> _options;

public SqlServerDataBusSelector(IOptions<SqlServerDataBusOptions> options, IConfiguration configuration, ILogger log)
: base(configuration, log)
{
_options = options;
}

public override string ConfigurationName => "store";
protected override void ConfigureSqlServer(StandardConfigurer<IDataBusStorage> configurer, string connectionString)
{
configurer.StoreInSqlServer(connectionString,
_options.Value.TableName, _options.Value.AutomaticallyCreateTables);
}
}

0 comments on commit ecf32c7

Please sign in to comment.