From 22743b7fd4d335556832c1f054438ddb6f808fbd Mon Sep 17 00:00:00 2001
From: Damien Grisonnet <damien.grisonnet@epita.fr>
Date: Wed, 16 Oct 2019 01:41:11 +0200
Subject: [PATCH] Fix period value

Signed-off-by: Damien Grisonnet <damien.grisonnet@epita.fr>
---
 gateways/core/stream/amqp/start.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/gateways/core/stream/amqp/start.go b/gateways/core/stream/amqp/start.go
index 3e126abe67..ce383e84aa 100644
--- 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()