Unable to run Hangfire with multiple queues #5495

3 Answer(s)

• 

  0

  maliming created 5 years ago

  Support Team

  We are configuring our JobStorage in the PreInitialize function of the Abp startup module.

  What is the specific code? I want to reproduce this problem.

  Save Cancel
• 

  0

  jefftindall created 5 years ago

  Here is the code we are using to setup the SqlServerStorage:

  var optServiceBusQueue = ConfigurationManager.AppSettings[AppSettings.Hangfire.ServiceBusQueue];
  var optServiceBusQueuePrefix = ConfigurationManager.AppSettings[AppSettings.Hangfire.ServiceBusQueuePrefix];
  var sqlStorage = new SqlServerStorage("Default");
  var connectionString = ConfigurationManager.ConnectionStrings["Microsoft.ServiceBus.ConnectionString"];
  int timeToLiveDays = 14;
  Action<QueueDescription> configureAction = qd =>
  {
      qd.MaxSizeInMegabytes = 5120;
      qd.DefaultMessageTimeToLive = new TimeSpan(timeToLiveDays, 0, 0, 0);
  };
  
  sqlStorage.UseServiceBusQueues(new ServiceBusQueueOptions
  {
      ConnectionString = connectionString.ConnectionString,
  
      Configure = configureAction,
  
      // The actual queues used in Azure will have this prefix if specified
      // (e.g. the "default" queue will be created as "my-prefix-default")
      //
      // This can be useful in development environments particularly where the machine
      // name could be used to separate individual developers machines automatically
      // (i.e. "my-prefix-{machine-name}".Replace("{machine-name}", Environment.MachineName))
      QueuePrefix = optServiceBusQueuePrefix,
  
      // The queues to monitor. This *must* be specified, even to set just
      // the default queue as done here
      Queues = new[] { EnqueuedState.DefaultQueue, optServiceBusQueue },
  
      // By default queues will be checked and created on startup. This option
      // can be disabled if the application will only be sending / listening to 
      // the queue and you want to remove the 'Manage' permission from the shared
      // access policy.
      //
      // Note that the dashboard *must* have the 'Manage' permission otherwise the
      // queue length cannot be read
      CheckAndCreateQueues = true
  });
  Configuration.BackgroundJobs.UseHangfire(configuration =>
  {
      configuration.GlobalConfiguration.UseStorage(sqlStorage);
      var autoRetry = new AutomaticRetryAttribute
      {
          Attempts = retryCount,
          OnAttemptsExceeded = attemptsExceededAction
      };
      configuration.GlobalConfiguration.UseFilter(autoRetry);
  });
  

  Save Cancel
• 

  0

  maliming created 5 years ago

  Support Team

  Can you download a Zero MVC Test Project(<a class="postlink" href="https://aspnetzero.com/Download">https://aspnetzero.com/Download</a>) and reproduce it and share it?

  I can specify queue in abp.

  <a class="postlink" href="http://docs.hangfire.io/en/latest/background-processing/configuring-queues.html">http://docs.hangfire.io/en/latest/backg ... ueues.html</a>

  public static class Test
  {
  	[Queue("secondary")]
  	public static void SomeMethod()
  	{
  
  	}
  
  	[Queue("default")]
  	public static void SomeMethod2()
  	{
  
  	}
  }
  
  BackgroundJob.Enqueue(() => Test.SomeMethod());
  BackgroundJob.Enqueue(() => Test.SomeMethod2());
  

  Save Cancel