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()