fix: not multiplied by the number of seconds
This commit is contained in:
		
							parent
							
								
									e57a27e12a
								
							
						
					
					
						commit
						e69fdaf48b
					
				| @ -112,7 +112,7 @@ type MessagePoolEvtMessage struct { | |||||||
| 
 | 
 | ||||||
| func init() { | func init() { | ||||||
| 	// if the republish interval is too short compared to the pubsub timecache, adjust it
 | 	// if the republish interval is too short compared to the pubsub timecache, adjust it
 | ||||||
| 	minInterval := pubsub.TimeCacheDuration + time.Duration(build.PropagationDelaySecs) | 	minInterval := pubsub.TimeCacheDuration + time.Duration(build.PropagationDelaySecs)*time.Second | ||||||
| 	if RepublishInterval < minInterval { | 	if RepublishInterval < minInterval { | ||||||
| 		RepublishInterval = minInterval | 		RepublishInterval = minInterval | ||||||
| 	} | 	} | ||||||
|  | |||||||
		Loading…
	
		Reference in New Issue
	
	Block a user