HangFire.TopicExtensions

Setup

 services
 .AddHangfire(x =>
 x
 .UseSqlServerStorage(
 "<connection>")
 .UseTopics()
 );
services.AddHangfireServer();
services.AddTopicServices();

Example Sending Topic

topicPublisher.EnqueueTopic("topic1");
topicPublisher.EnqueueTopic("topic1", someParams);

Example Subscriber

 [SubscriberJob("topic1")]
 public class SampleSubscriber : ISubscriber
 {
 private readonly IConfiguration _config;
 public SampleSubscriber(IConfiguration config)
 {
 _config = config;
 }
 public void Execute(object context)
 {
 
 }
 }