SQL

PM> Install-Package Shuttle.Esb.Sql.Subscription

Contains a sql-based ISubscriptionService implementation. The subscription service caches all subscriptions but a timeout for the cache may be set. If you need to be sure that a new subscriber is picked up by a publisher the safest is to restart the relevant publisher(s).

Registration

The required components may be registered by calling:

services.AddSqlSubscription(builder => { // defaults builder.Options.ConnectionStringName = "Subscription"; builder.Options.Schema = "dbo"; builder.Options.CacheTimeout = TimeSpan.FromMinutes(5); builder.UseSqlServer(); // SqlServer builder.UseNpgsql(); // Postgres });

The SubscriptionService that implements the ISubscriptionService interface makes use of the SubscriptionOptions configured with the ServiceBusOptions to register, or ensure, any subscriptions:

services.AddServiceBus(builder => { builder.Subscription.SubscribeType = SubscribeType.Normal; // default // add subscription to message types directly; else below options on builder builder.Subscription.MessageTypes.Add(messageType); // using type builder.AddSubscription(typeof(Event1)); builder.AddSubscription(typeof(Event2)); // using a full type name builder.AddSubscription(typeof(Event1).FullName); builder.AddSubscription(typeof(Event2).FullName); // using a generic builder.AddSubscription<Event1>(); builder.AddSubscription<Event2>(); });

And the JSON configuration structure:

{ "Shuttle": { "Sql": { "Subscription": { "ConnectionStringName": "Subscription", "Schema": "dbo", "CacheTimeout": "00:05:00" } }, "ServiceBus": { "Subscription": { "SubscribeType": "Normal", "MessageTypes": [ "message-type-a", "message-type-b" ] } } } }

Options

Option