Hangfire EnqueuedJobs 参数
Hangfire EnqueuedJobs parameters
我正在尝试使用以下代码在 Hangfire 中检索排队的作业:
IMonitoringApi monitor = JobStorage.Current.GetMonitoringApi();
var jobData = monitor.EnqueuedJobs(?, 0, 1);
api表示第一个参数是字符串,(字符串队列)。我的问题是,那个字符串队列表示什么,我如何得到它?谢谢
这是您放置作业的队列的名称,因为您可以在 Hangfire 中创建尽可能多的队列。
var options = new BackgroundJobServerOptions
{
Queues = new[] { "critical", "default" }
};
app.UseHangfireServer(options);
这里有两个队列,一个是关键队列,第二个是默认队列
所以如果您还没有创建任何队列,那么在这里您将通过默认设置,因为默认队列是默认队列。
将函数实现为
public JobList<EnqueuedJobDto> EnqueuedJobs(string queue, int @from, int perPage)
{
return UseConnection(connection =>
{
var queueApi = GetQueueApi(connection, queue);
var enqueuedJobIds = queueApi.GetEnqueuedJobIds(queue, from, perPage);
return EnqueuedJobs(connection, enqueuedJobIds);
});
}
Link 在这里实现 https://searchcode.com/codesearch/raw/97584324/
如果你完成了请告诉我。
我正在尝试使用以下代码在 Hangfire 中检索排队的作业:
IMonitoringApi monitor = JobStorage.Current.GetMonitoringApi();
var jobData = monitor.EnqueuedJobs(?, 0, 1);
api表示第一个参数是字符串,(字符串队列)。我的问题是,那个字符串队列表示什么,我如何得到它?谢谢
这是您放置作业的队列的名称,因为您可以在 Hangfire 中创建尽可能多的队列。
var options = new BackgroundJobServerOptions
{
Queues = new[] { "critical", "default" }
};
app.UseHangfireServer(options);
这里有两个队列,一个是关键队列,第二个是默认队列
所以如果您还没有创建任何队列,那么在这里您将通过默认设置,因为默认队列是默认队列。
将函数实现为
public JobList<EnqueuedJobDto> EnqueuedJobs(string queue, int @from, int perPage)
{
return UseConnection(connection =>
{
var queueApi = GetQueueApi(connection, queue);
var enqueuedJobIds = queueApi.GetEnqueuedJobIds(queue, from, perPage);
return EnqueuedJobs(connection, enqueuedJobIds);
});
}
Link 在这里实现 https://searchcode.com/codesearch/raw/97584324/
如果你完成了请告诉我。