Sqlite Inbox
Usage
private static IHostBuilder CreateHostBuilder(string[] args) =>
Host.CreateDefaultBuilder(args)
.ConfigureServices(hostContext, services) =>
{
ConfigureBrighter(hostContext, services);
}
private static void ConfigureBrighter(HostBuilderContext hostContext, IServiceCollection services)
{
services.AddConsumers(options =>
{
var configuration = new RelationalDatabaseConfiguration(connectionString, "brighter", inboxTableName: "inbox_messages");
opt.InboxConfiguration = new InboxConfiguration(new SqliteInbox(configuration), actionOnExists: OnceOnlyAction.Warn);
...
});
}
...
Last updated
Was this helpful?
