-
Notifications
You must be signed in to change notification settings - Fork 14
HeartBeatConfiguration
Brian Lehnen edited this page Mar 2, 2020
·
4 revisions
The heart beat configuration controls how often heartbeats are issued, and how long before a record is considered to be outside of the heartbeat window.
The update time controls how often the heartbeat will be updated.
queue.Configuration.HeartBeat.UpdateTime = "sec(*%10)"; //set a heartbeat every 10 seconds
Once the heartbeat is outside of this window, the record is considered for re-queuing to another worker
queue.Configuration.HeartBeat.Time = TimeSpan.FromSeconds(35); //records with no heartbeat after 35 seconds are considered dead
How often the queue will check for records that need to be re-queued, because they are outside of the time window.
queue.Configuration.HeartBeat.MonitorTime = TimeSpan.FromSeconds(15); //check for dead records every 15 seconds
How many threads to use to update heartbeats. If you will de-queue many records at once, and you are using a short heartbeat window, you may need more than 1 thread.
queue.Configuration.HeartBeat.ThreadPoolConfiguration.ThreadsMax = 1;
For any issues please use the GitHub issues