add dynamic queue update interval to server config

Signed-off-by: Artem Torubarov <[email protected]>

Author: arttor

server.go

@@ -185,6 +185,12 @@ type Config struct {
 	//     StrictPriority: true,
 	DynamicQueues bool
 
+	// DynamicQueueUpdateInterval specifies the interval between updating list of dynamic queue names.
+	// Parameter corresponds with the latency of the server to pick up the first task from a newly created dynamic queue.
+	//
+	// If unset or zero, default interval of 5 seconds is used.
+	DynamicQueueUpdateInterval time.Duration
+
 	// ErrorHandler handles errors returned by the task handler.
 	//
 	// HandleError is invoked only if the task handler returns a non-nil error.
@@ -535,10 +541,14 @@ func NewServerFromRedisClient(c redis.UniversalClient, cfg Config) *Server {
 	srvState := &serverState{value: srvStateNew}
 	cancels := base.NewCancelations()
 
+	dynamicQueueUpdateInterval := cfg.DynamicQueueUpdateInterval
+	if dynamicQueueUpdateInterval == 0 {
+		dynamicQueueUpdateInterval = defaultDynamicQueueUpdateInterval
+	}
 	queueManager := newQueueManager(queueManagerParams{
 		logger:         logger,
 		broker:         rdb,
-		interval:       defaultDynamicQueueUpdateInterval,
+		interval:       dynamicQueueUpdateInterval,
 		queues:         queues,
 		strictPriority: cfg.StrictPriority,
 		dynamicQueues:  cfg.DynamicQueues,