Fix period value

Signed-off-by: Damien Grisonnet <[email protected]>
argoproj · Oct 15, 2019 · 80b8f91 · 80b8f91
1 parent c46ca67
commit 80b8f91
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/gateways/core/stream/amqp/start.go b/gateways/core/stream/amqp/start.go
@@ -46,7 +46,7 @@ func (ese *AMQPEventSourceExecutor) StartEventSource(eventSource *gateways.Event
 }
 
 func getLimitedDelivery(ch *amqplib.Channel, a *amqp, delivery chan amqplib.Delivery, queue string) {
-	period := time.Duration(a.RatePeriod)
+	period := time.Duration(a.RatePeriod) * time.Second
 	for {
 		startTime := time.Now()